1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
# -*- coding: utf-8 eval: (blacken-mode 1) -*-
# SPDX-License-Identifier: ISC
#
# May 2 2023, Christian Hopps <chopps@labn.net>
#
# Copyright (c) 2023, LabN Consulting, L.L.C.
#
"""
Verify large set of routes present when staticd (backend client) is started after it's
startup config is present during launch.
"""
import logging
import os
import pytest
from lib.common_config import step
from lib.topogen import Topogen, TopoRouter
from munet.base import Timeout
from util import check_kernel, check_vtysh_up, write_big_route_conf
CWD = os.path.dirname(os.path.realpath(__file__))
pytestmark = [pytest.mark.staticd, pytest.mark.mgmtd]
track = Timeout(0)
ROUTE_COUNT = 2500
ROUTE_RANGE = [None, None]
@pytest.fixture(scope="module")
def tgen(request):
"Setup/Teardown the environment and provide tgen argument to tests"
global start_time
topodef = {
"s1": ("r1",),
}
tgen = Topogen(topodef, request.module.__name__)
tgen.start_topology()
prologue = open(f"{CWD}/r1/mgmtd.conf").read()
confpath = f"{tgen.gears['r1'].gearlogdir}/r1-late-big.conf"
start, end = write_big_route_conf("10.0.0.0/8", ROUTE_COUNT, confpath, prologue)
ROUTE_RANGE[0] = start
ROUTE_RANGE[1] = end
# configure mgmtd using current mgmtd config file
tgen.gears["r1"].load_config(TopoRouter.RD_ZEBRA, "zebra.conf")
tgen.gears["r1"].load_config(TopoRouter.RD_MGMTD, confpath)
# Explicit disable staticd now..
tgen.gears["r1"].net.daemons["staticd"] = 0
tgen.start_router()
yield tgen
tgen.stop_topology()
def test_staticd_latestart(tgen):
if tgen.routers_have_failure():
pytest.skip(tgen.errors)
r1 = tgen.routers()["r1"]
check_vtysh_up(r1)
logging.info("r1: vtysh connected after %ss", track.elapsed())
result = check_kernel(r1, ROUTE_RANGE[0], retry_timeout=60, expected=False)
assert result is not None, "first route present and should not be"
result = check_kernel(r1, ROUTE_RANGE[1], retry_timeout=60, expected=False)
assert result is not None, "last route present and should not be"
step("Starting staticd")
t2 = Timeout(0)
r1.startDaemons(["staticd"])
result = check_kernel(r1, ROUTE_RANGE[0], retry_timeout=60)
assert result is None, "first route not present and should be"
logging.info("r1: elapsed time for first route %ss", t2.elapsed())
count = 0
ocount = 0
while count < ROUTE_COUNT:
rc, o, e = r1.net.cmd_status("ip -o route | wc -l")
if not rc:
if count > ocount + 100:
ocount = count
logging.info("r1: elapsed time for %d routes %s", count, t2.elapsed())
count = int(o)
result = check_kernel(r1, ROUTE_RANGE[1], retry_timeout=1200)
assert result is None, "last route not present and should be"
logging.info("r1: elapsed time for last route %ss", t2.elapsed())
|
