8 from framework import VppTestCase, VppTestRunner, running_extended_tests, \
10 from vpp_ip_route import VppIpTable, VppIpRoute, VppRoutePath, DpoProto
13 class VCLAppWorker(Worker):
14 """ VCL Test Application Worker """
16 def __init__(self, build_dir, appname, args, logger, env={}):
17 vcl_lib_dir = "%s/vpp/lib" % build_dir
18 if "iperf" in appname:
20 env.update({'LD_PRELOAD':
21 "%s/libvcl_ldpreload.so" % vcl_lib_dir})
22 elif "sock" in appname:
23 app = "%s/vpp/bin/%s" % (build_dir, appname)
24 env.update({'LD_PRELOAD':
25 "%s/libvcl_ldpreload.so" % vcl_lib_dir})
27 app = "%s/vpp/bin/%s" % (build_dir, appname)
28 self.args = [app] + args
29 super(VCLAppWorker, self).__init__(self.args, logger, env)
32 class VCLTestCase(VppTestCase):
33 """ VCL Test Class """
37 super(VCLTestCase, cls).setUpClass()
40 def tearDownClass(cls):
41 super(VCLTestCase, cls).tearDownClass()
45 self.build_dir = os.getenv(var, None)
46 if self.build_dir is None:
47 raise Exception("Environment variable `%s' not set" % var)
48 self.vppDebug = 'vpp_debug' in self.build_dir
49 self.server_addr = "127.0.0.1"
50 self.server_port = "22000"
51 self.server_args = [self.server_port]
52 self.server_ipv6_addr = "::1"
53 self.server_ipv6_args = ["-6", self.server_port]
55 self.echo_phrase = "Hello, world! Jenny is a friend of mine."
56 self.pre_test_sleep = 0.3
57 self.post_test_sleep = 0.2
59 if os.path.isfile("/tmp/ldp_server_af_unix_socket"):
60 os.remove("/tmp/ldp_server_af_unix_socket")
62 super(VCLTestCase, self).setUp()
64 def cut_thru_setup(self):
65 self.vapi.session_enable_disable(is_enabled=1)
67 def cut_thru_tear_down(self):
68 self.vapi.session_enable_disable(is_enabled=0)
70 def cut_thru_test(self, server_app, server_args, client_app, client_args):
71 self.env = {'VCL_API_PREFIX': self.shm_prefix,
72 'VCL_APP_SCOPE_LOCAL': "true"}
74 worker_server = VCLAppWorker(self.build_dir, server_app, server_args,
75 self.logger, self.env)
77 self.sleep(self.pre_test_sleep)
78 worker_client = VCLAppWorker(self.build_dir, client_app, client_args,
79 self.logger, self.env)
81 worker_client.join(self.timeout)
83 self.validateResults(worker_client, worker_server, self.timeout)
84 except Exception as error:
85 self.fail("Failed with %s" % error)
86 self.sleep(self.post_test_sleep)
88 def thru_host_stack_setup(self):
89 self.vapi.session_enable_disable(is_enabled=1)
90 self.create_loopback_interfaces(2)
94 for i in self.lo_interfaces:
98 tbl = VppIpTable(self, table_id)
101 i.set_table_ip4(table_id)
105 # Configure namespaces
106 self.vapi.app_namespace_add_del(namespace_id=b"1", secret=1234,
107 sw_if_index=self.loop0.sw_if_index)
108 self.vapi.app_namespace_add_del(namespace_id=b"2", secret=5678,
109 sw_if_index=self.loop1.sw_if_index)
111 # Add inter-table routes
112 ip_t01 = VppIpRoute(self, self.loop1.local_ip4, 32,
113 [VppRoutePath("0.0.0.0",
115 nh_table_id=2)], table_id=1)
116 ip_t10 = VppIpRoute(self, self.loop0.local_ip4, 32,
117 [VppRoutePath("0.0.0.0",
119 nh_table_id=1)], table_id=2)
120 ip_t01.add_vpp_config()
121 ip_t10.add_vpp_config()
122 self.logger.debug(self.vapi.cli("show ip fib"))
124 def thru_host_stack_tear_down(self):
125 for i in self.lo_interfaces:
130 self.vapi.session_enable_disable(is_enabled=0)
132 def thru_host_stack_ipv6_setup(self):
133 self.vapi.session_enable_disable(is_enabled=1)
134 self.create_loopback_interfaces(2)
138 for i in self.lo_interfaces:
141 tbl = VppIpTable(self, table_id, is_ip6=1)
144 i.set_table_ip6(table_id)
148 # Configure namespaces
149 self.vapi.app_namespace_add_del(namespace_id=b"1", secret=1234,
150 sw_if_index=self.loop0.sw_if_index)
151 self.vapi.app_namespace_add_del(namespace_id=b"2", secret=5678,
152 sw_if_index=self.loop1.sw_if_index)
154 # Add inter-table routes
155 ip_t01 = VppIpRoute(self, self.loop1.local_ip6, 128,
156 [VppRoutePath("::0", 0xffffffff,
158 proto=DpoProto.DPO_PROTO_IP6)],
159 table_id=1, is_ip6=1)
160 ip_t10 = VppIpRoute(self, self.loop0.local_ip6, 128,
161 [VppRoutePath("::0", 0xffffffff,
163 proto=DpoProto.DPO_PROTO_IP6)],
164 table_id=2, is_ip6=1)
165 ip_t01.add_vpp_config()
166 ip_t10.add_vpp_config()
167 self.logger.debug(self.vapi.cli("show interface addr"))
168 self.logger.debug(self.vapi.cli("show ip6 fib"))
170 def thru_host_stack_ipv6_tear_down(self):
171 for i in self.lo_interfaces:
176 self.vapi.session_enable_disable(is_enabled=0)
178 def thru_host_stack_test(self, server_app, server_args,
179 client_app, client_args):
180 self.env = {'VCL_API_PREFIX': self.shm_prefix,
181 'VCL_APP_SCOPE_GLOBAL': "true",
182 'VCL_APP_NAMESPACE_ID': "1",
183 'VCL_APP_NAMESPACE_SECRET': "1234"}
185 worker_server = VCLAppWorker(self.build_dir, server_app, server_args,
186 self.logger, self.env)
187 worker_server.start()
188 self.sleep(self.pre_test_sleep)
190 self.env.update({'VCL_APP_NAMESPACE_ID': "2",
191 'VCL_APP_NAMESPACE_SECRET': "5678"})
192 worker_client = VCLAppWorker(self.build_dir, client_app, client_args,
193 self.logger, self.env)
194 worker_client.start()
195 worker_client.join(self.timeout)
198 self.validateResults(worker_client, worker_server, self.timeout)
199 except Exception as error:
200 self.fail("Failed with %s" % error)
201 self.sleep(self.post_test_sleep)
203 def validateResults(self, worker_client, worker_server, timeout):
204 if os.path.isdir('/proc/{}'.format(worker_server.process.pid)):
205 self.logger.info("Killing server worker process (pid %d)" %
206 worker_server.process.pid)
207 os.killpg(os.getpgid(worker_server.process.pid), signal.SIGKILL)
209 self.logger.info("Client worker result is `%s'" % worker_client.result)
211 if worker_client.result is None:
215 "Timeout: %ss! Killing client worker process (pid %d)" %
216 (timeout, worker_client.process.pid))
217 os.killpg(os.getpgid(worker_client.process.pid),
222 "Couldn't kill client worker process")
226 "Timeout! Client worker did not finish in %ss" % timeout)
227 self.assert_equal(worker_client.result, 0, "Binary test return code")
230 class LDPCutThruTestCase(VCLTestCase):
231 """ LDP Cut Thru Tests """
235 super(LDPCutThruTestCase, cls).setUpClass()
238 def tearDownClass(cls):
239 super(LDPCutThruTestCase, cls).tearDownClass()
242 super(LDPCutThruTestCase, self).setUp()
244 self.cut_thru_setup()
245 self.client_echo_test_args = ["-E", self.echo_phrase, "-X",
246 self.server_addr, self.server_port]
247 self.client_iperf3_timeout = 20
248 self.client_iperf3_args = ["-V4d", "-t 2", "-c", self.server_addr]
249 self.server_iperf3_args = ["-V4d", "-s"]
250 self.client_uni_dir_nsock_timeout = 20
251 self.client_uni_dir_nsock_test_args = ["-N", "1000", "-U", "-X",
255 self.client_bi_dir_nsock_timeout = 20
256 self.client_bi_dir_nsock_test_args = ["-N", "1000", "-B", "-X",
262 self.logger.debug(self.vapi.cli("show session verbose 2"))
263 self.cut_thru_tear_down()
264 super(LDPCutThruTestCase, self).tearDown()
266 @unittest.skipUnless(running_extended_tests, "part of extended tests")
267 def test_ldp_cut_thru_echo(self):
268 """ run LDP cut thru echo test """
270 self.cut_thru_test("sock_test_server", self.server_args,
271 "sock_test_client", self.client_echo_test_args)
273 def test_ldp_cut_thru_iperf3(self):
274 """ run LDP cut thru iperf3 test """
277 subprocess.check_output(['iperf3', '-v'])
278 except subprocess.CalledProcessError:
280 "WARNING: Subprocess returned non-0 running 'iperf3 -v")
281 self.logger.error(" 'test_ldp_cut_thru_iperf3' not run!")
285 "WARNING: Subprocess returned with OS error (%s) %s\n"
286 " 'iperf3' is likely not installed,",
288 self.logger.error(" 'test_ldp_cut_thru_iperf3' not run!")
291 self.logger.exception(
292 "Subprocess returned non-0 running 'iperf3 -v")
294 self.timeout = self.client_iperf3_timeout
295 self.cut_thru_test("iperf3", self.server_iperf3_args,
296 "iperf3", self.client_iperf3_args)
298 @unittest.skipUnless(running_extended_tests, "part of extended tests")
299 def test_ldp_cut_thru_uni_dir_nsock(self):
300 """ run LDP cut thru uni-directional (multiple sockets) test """
302 self.timeout = self.client_uni_dir_nsock_timeout
303 self.cut_thru_test("sock_test_server", self.server_args,
305 self.client_uni_dir_nsock_test_args)
307 @unittest.skipUnless(running_extended_tests, "part of extended tests")
308 def test_ldp_cut_thru_bi_dir_nsock(self):
309 """ run LDP cut thru bi-directional (multiple sockets) test """
311 self.timeout = self.client_bi_dir_nsock_timeout
312 self.cut_thru_test("sock_test_server", self.server_args,
314 self.client_bi_dir_nsock_test_args)
317 class VCLCutThruTestCase(VCLTestCase):
318 """ VCL Cut Thru Tests """
322 super(VCLCutThruTestCase, cls).setUpClass()
325 def tearDownClass(cls):
326 super(VCLCutThruTestCase, cls).tearDownClass()
329 super(VCLCutThruTestCase, self).setUp()
331 self.cut_thru_setup()
332 self.client_echo_test_args = ["-E", self.echo_phrase, "-X",
333 self.server_addr, self.server_port]
335 self.client_uni_dir_nsock_timeout = 20
336 self.client_uni_dir_nsock_test_args = ["-N", "1000", "-U", "-X",
340 self.client_bi_dir_nsock_timeout = 20
341 self.client_bi_dir_nsock_test_args = ["-N", "1000", "-B", "-X",
347 self.cut_thru_tear_down()
349 super(VCLCutThruTestCase, self).tearDown()
351 def test_vcl_cut_thru_echo(self):
352 """ run VCL cut thru echo test """
354 self.cut_thru_test("vcl_test_server", self.server_args,
355 "vcl_test_client", self.client_echo_test_args)
357 def test_vcl_cut_thru_uni_dir_nsock(self):
358 """ run VCL cut thru uni-directional (multiple sockets) test """
360 self.timeout = self.client_uni_dir_nsock_timeout
361 self.cut_thru_test("vcl_test_server", self.server_args,
363 self.client_uni_dir_nsock_test_args)
365 def test_vcl_cut_thru_bi_dir_nsock(self):
366 """ run VCL cut thru bi-directional (multiple sockets) test """
368 self.timeout = self.client_bi_dir_nsock_timeout
369 self.cut_thru_test("vcl_test_server", self.server_args,
371 self.client_bi_dir_nsock_test_args)
374 class VCLThruHostStackEcho(VCLTestCase):
375 """ VCL Thru Host Stack Echo """
379 super(VCLThruHostStackEcho, cls).setUpClass()
382 def tearDownClass(cls):
383 super(VCLThruHostStackEcho, cls).tearDownClass()
386 super(VCLThruHostStackEcho, self).setUp()
388 self.thru_host_stack_setup()
389 self.client_bi_dir_nsock_timeout = 20
390 self.client_bi_dir_nsock_test_args = ["-N", "1000", "-B", "-X",
392 self.loop0.local_ip4,
394 self.client_echo_test_args = ["-E", self.echo_phrase, "-X",
395 self.loop0.local_ip4,
399 self.logger.debug(self.vapi.cli("show app server"))
400 self.logger.debug(self.vapi.cli("show session verbose"))
401 self.thru_host_stack_tear_down()
402 super(VCLThruHostStackEcho, self).tearDown()
405 class VCLThruHostStackTLS(VCLTestCase):
406 """ VCL Thru Host Stack TLS """
410 super(VCLThruHostStackTLS, cls).setUpClass()
413 def tearDownClass(cls):
414 super(VCLThruHostStackTLS, cls).tearDownClass()
417 super(VCLThruHostStackTLS, self).setUp()
419 self.thru_host_stack_setup()
420 self.client_uni_dir_tls_timeout = 20
421 self.server_tls_args = ["-L", self.server_port]
422 self.client_uni_dir_tls_test_args = ["-N", "1000", "-U", "-X", "-L",
423 self.loop0.local_ip4,
426 def test_vcl_thru_host_stack_tls_uni_dir(self):
427 """ run VCL thru host stack uni-directional TLS test """
429 self.timeout = self.client_uni_dir_tls_timeout
430 self.thru_host_stack_test("vcl_test_server", self.server_tls_args,
432 self.client_uni_dir_tls_test_args)
435 self.logger.debug(self.vapi.cli("show app server"))
436 self.logger.debug(self.vapi.cli("show session verbose 2"))
437 self.thru_host_stack_tear_down()
438 super(VCLThruHostStackTLS, self).tearDown()
441 class VCLThruHostStackBidirNsock(VCLTestCase):
442 """ VCL Thru Host Stack Bidir Nsock """
446 super(VCLThruHostStackBidirNsock, cls).setUpClass()
449 def tearDownClass(cls):
450 super(VCLThruHostStackBidirNsock, cls).tearDownClass()
453 super(VCLThruHostStackBidirNsock, self).setUp()
455 self.thru_host_stack_setup()
456 self.client_bi_dir_nsock_timeout = 20
457 self.client_bi_dir_nsock_test_args = ["-N", "1000", "-B", "-X",
459 self.loop0.local_ip4,
461 self.client_echo_test_args = ["-E", self.echo_phrase, "-X",
462 self.loop0.local_ip4,
466 self.logger.debug(self.vapi.cli("show session verbose 2"))
467 self.thru_host_stack_tear_down()
468 super(VCLThruHostStackBidirNsock, self).tearDown()
470 def test_vcl_thru_host_stack_bi_dir_nsock(self):
471 """ run VCL thru host stack bi-directional (multiple sockets) test """
473 self.timeout = self.client_bi_dir_nsock_timeout
474 self.thru_host_stack_test("vcl_test_server", self.server_args,
476 self.client_bi_dir_nsock_test_args)
479 class LDPThruHostStackBidirNsock(VCLTestCase):
480 """ LDP Thru Host Stack Bidir Nsock """
484 super(LDPThruHostStackBidirNsock, cls).setUpClass()
487 def tearDownClass(cls):
488 super(LDPThruHostStackBidirNsock, cls).tearDownClass()
491 super(LDPThruHostStackBidirNsock, self).setUp()
493 self.thru_host_stack_setup()
495 self.client_bi_dir_nsock_timeout = 20
496 self.client_bi_dir_nsock_test_args = ["-N", "1000", "-B", "-X",
497 # OUCH! Host Stack Bug?
499 self.loop0.local_ip4,
502 self.client_bi_dir_nsock_timeout = 20
503 self.client_bi_dir_nsock_test_args = ["-N", "1000", "-B", "-X",
504 # OUCH! Host Stack Bug?
506 self.loop0.local_ip4,
510 self.logger.debug(self.vapi.cli("show session verbose 2"))
511 self.thru_host_stack_tear_down()
512 super(LDPThruHostStackBidirNsock, self).tearDown()
514 def test_ldp_thru_host_stack_bi_dir_nsock(self):
515 """ run LDP thru host stack bi-directional (multiple sockets) test """
517 self.timeout = self.client_bi_dir_nsock_timeout
518 self.thru_host_stack_test("sock_test_server", self.server_args,
520 self.client_bi_dir_nsock_test_args)
523 class LDPThruHostStackNsock(VCLTestCase):
524 """ LDP Thru Host Stack Nsock """
528 super(LDPThruHostStackNsock, cls).setUpClass()
531 def tearDownClass(cls):
532 super(LDPThruHostStackNsock, cls).tearDownClass()
535 super(LDPThruHostStackNsock, self).setUp()
537 self.thru_host_stack_setup()
539 self.client_uni_dir_nsock_timeout = 20
540 self.numSockets = "2"
542 self.client_uni_dir_nsock_timeout = 20
543 self.numSockets = "5"
545 self.client_uni_dir_nsock_test_args = ["-N", "1000", "-U", "-X",
546 "-I", self.numSockets,
547 self.loop0.local_ip4,
551 self.thru_host_stack_tear_down()
552 super(LDPThruHostStackNsock, self).tearDown()
554 def test_ldp_thru_host_stack_uni_dir_nsock(self):
555 """ run LDP thru host stack uni-directional (multiple sockets) test """
557 self.timeout = self.client_uni_dir_nsock_timeout
558 self.thru_host_stack_test("sock_test_server", self.server_args,
560 self.client_uni_dir_nsock_test_args)
563 class VCLThruHostStackNsock(VCLTestCase):
564 """ VCL Thru Host Stack Nsock """
568 super(VCLThruHostStackNsock, cls).setUpClass()
571 def tearDownClass(cls):
572 super(VCLThruHostStackNsock, cls).tearDownClass()
575 super(VCLThruHostStackNsock, self).setUp()
577 self.thru_host_stack_setup()
579 self.client_uni_dir_nsock_timeout = 20
580 self.numSockets = "2"
582 self.client_uni_dir_nsock_timeout = 20
583 self.numSockets = "5"
585 self.client_uni_dir_nsock_test_args = ["-N", "1000", "-U", "-X",
586 "-I", self.numSockets,
587 self.loop0.local_ip4,
591 self.thru_host_stack_tear_down()
592 super(VCLThruHostStackNsock, self).tearDown()
594 def test_vcl_thru_host_stack_uni_dir_nsock(self):
595 """ run VCL thru host stack uni-directional (multiple sockets) test """
597 self.timeout = self.client_uni_dir_nsock_timeout
598 self.thru_host_stack_test("vcl_test_server", self.server_args,
600 self.client_uni_dir_nsock_test_args)
603 class LDPThruHostStackIperf(VCLTestCase):
604 """ LDP Thru Host Stack Iperf """
608 super(LDPThruHostStackIperf, cls).setUpClass()
611 def tearDownClass(cls):
612 super(LDPThruHostStackIperf, cls).tearDownClass()
615 super(LDPThruHostStackIperf, self).setUp()
617 self.thru_host_stack_setup()
618 self.client_iperf3_timeout = 20
619 self.client_iperf3_args = ["-V4d", "-t 2", "-c", self.loop0.local_ip4]
620 self.server_iperf3_args = ["-V4d", "-s"]
623 self.logger.debug(self.vapi.cli("show session verbose 2"))
624 self.thru_host_stack_tear_down()
625 super(LDPThruHostStackIperf, self).tearDown()
627 def test_ldp_thru_host_stack_iperf3(self):
628 """ run LDP thru host stack iperf3 test """
631 subprocess.check_output(['iperf3', '-v'])
632 except subprocess.CalledProcessError:
633 self.logger.error("WARNING: 'iperf3' is not installed,")
635 " 'test_ldp_thru_host_stack_iperf3' not run!")
638 self.logger.error("WARNING: 'iperf3' is not installed,")
639 self.logger.error(" 'test' not run!")
641 except Exception as e:
642 self.logger.error("WARNING: 'iperf3' unexpected error,")
643 self.logger.error(" 'test' not run!")
646 self.timeout = self.client_iperf3_timeout
647 self.thru_host_stack_test("iperf3", self.server_iperf3_args,
648 "iperf3", self.client_iperf3_args)
651 class LDPIpv6CutThruTestCase(VCLTestCase):
652 """ LDP IPv6 Cut Thru Tests """
656 super(LDPIpv6CutThruTestCase, cls).setUpClass()
659 def tearDownClass(cls):
660 super(LDPIpv6CutThruTestCase, cls).tearDownClass()
663 super(LDPIpv6CutThruTestCase, self).setUp()
665 self.cut_thru_setup()
666 self.client_iperf3_timeout = 20
667 self.client_uni_dir_nsock_timeout = 20
668 self.client_bi_dir_nsock_timeout = 20
669 self.client_ipv6_echo_test_args = ["-6", "-E", self.echo_phrase, "-X",
670 self.server_ipv6_addr,
672 self.client_ipv6_iperf3_args = ["-V6d", "-t 2", "-c",
673 self.server_ipv6_addr]
674 self.server_ipv6_iperf3_args = ["-V6d", "-s"]
675 self.client_ipv6_uni_dir_nsock_test_args = ["-N", "1000", "-U", "-X",
678 self.server_ipv6_addr,
680 self.client_ipv6_bi_dir_nsock_test_args = ["-N", "1000", "-B", "-X",
683 self.server_ipv6_addr,
687 self.cut_thru_tear_down()
689 super(LDPIpv6CutThruTestCase, self).tearDown()
691 def test_ldp_ipv6_cut_thru_echo(self):
692 """ run LDP IPv6 cut thru echo test """
694 self.cut_thru_test("sock_test_server",
695 self.server_ipv6_args,
697 self.client_ipv6_echo_test_args)
699 @unittest.skipUnless(running_extended_tests, "part of extended tests")
700 def test_ldp_ipv6_cut_thru_iperf3(self):
701 """ run LDP IPv6 cut thru iperf3 test """
704 subprocess.check_output(['iperf3', '-v'])
706 self.logger.error("WARNING: 'iperf3' is not installed,")
708 " 'test_ldp_ipv6_cut_thru_iperf3' not run!")
711 self.timeout = self.client_iperf3_timeout
712 self.cut_thru_test("iperf3", self.server_ipv6_iperf3_args,
713 "iperf3", self.client_ipv6_iperf3_args)
715 @unittest.skipUnless(running_extended_tests, "part of extended tests")
716 def test_ldp_ipv6_cut_thru_uni_dir_nsock(self):
717 """ run LDP IPv6 cut thru uni-directional (multiple sockets) test """
719 self.timeout = self.client_uni_dir_nsock_timeout
720 self.cut_thru_test("sock_test_server", self.server_ipv6_args,
722 self.client_ipv6_uni_dir_nsock_test_args)
724 @unittest.skipUnless(running_extended_tests, "part of extended tests")
725 def test_ldp_ipv6_cut_thru_bi_dir_nsock(self):
726 """ run LDP IPv6 cut thru bi-directional (multiple sockets) test """
728 self.timeout = self.client_bi_dir_nsock_timeout
729 self.cut_thru_test("sock_test_server", self.server_ipv6_args,
731 self.client_ipv6_bi_dir_nsock_test_args)
734 class VCLIpv6CutThruTestCase(VCLTestCase):
735 """ VCL IPv6 Cut Thru Tests """
739 super(VCLIpv6CutThruTestCase, cls).setUpClass()
742 def tearDownClass(cls):
743 super(VCLIpv6CutThruTestCase, cls).tearDownClass()
746 super(VCLIpv6CutThruTestCase, self).setUp()
748 self.cut_thru_setup()
749 self.client_uni_dir_nsock_timeout = 20
750 self.client_bi_dir_nsock_timeout = 20
751 self.client_ipv6_echo_test_args = ["-6", "-E", self.echo_phrase, "-X",
752 self.server_ipv6_addr,
754 self.client_ipv6_uni_dir_nsock_test_args = ["-N", "1000", "-U", "-X",
757 self.server_ipv6_addr,
759 self.client_ipv6_bi_dir_nsock_test_args = ["-N", "1000", "-B", "-X",
762 self.server_ipv6_addr,
766 self.cut_thru_tear_down()
768 super(VCLIpv6CutThruTestCase, self).tearDown()
770 def test_vcl_ipv6_cut_thru_echo(self):
771 """ run VCL IPv6 cut thru echo test """
773 self.cut_thru_test("vcl_test_server",
774 self.server_ipv6_args,
776 self.client_ipv6_echo_test_args)
778 @unittest.skipUnless(running_extended_tests, "part of extended tests")
779 def test_vcl_ipv6_cut_thru_uni_dir_nsock(self):
780 """ run VCL IPv6 cut thru uni-directional (multiple sockets) test """
782 self.timeout = self.client_uni_dir_nsock_timeout
783 self.cut_thru_test("vcl_test_server", self.server_ipv6_args,
785 self.client_ipv6_uni_dir_nsock_test_args)
787 @unittest.skipUnless(running_extended_tests, "part of extended tests")
788 def test_vcl_ipv6_cut_thru_bi_dir_nsock(self):
789 """ run VCL IPv6 cut thru bi-directional (multiple sockets) test """
791 self.timeout = self.client_bi_dir_nsock_timeout
792 self.cut_thru_test("vcl_test_server", self.server_ipv6_args,
794 self.client_ipv6_bi_dir_nsock_test_args)
797 class VCLIpv6ThruHostStackEcho(VCLTestCase):
798 """ VCL IPv6 Thru Host Stack Echo """
802 super(VCLIpv6ThruHostStackEcho, cls).setUpClass()
805 def tearDownClass(cls):
806 super(VCLIpv6ThruHostStackEcho, cls).tearDownClass()
809 super(VCLIpv6ThruHostStackEcho, self).setUp()
811 self.thru_host_stack_ipv6_setup()
812 self.client_ipv6_echo_test_args = ["-6", "-E", self.echo_phrase, "-X",
813 self.loop0.local_ip6,
817 self.thru_host_stack_ipv6_tear_down()
818 super(VCLIpv6ThruHostStackEcho, self).tearDown()
820 def test_vcl_ipv6_thru_host_stack_echo(self):
821 """ run VCL IPv6 thru host stack echo test """
823 self.thru_host_stack_test("vcl_test_server",
824 self.server_ipv6_args,
826 self.client_ipv6_echo_test_args)
829 if __name__ == '__main__':
830 unittest.main(testRunner=VppTestRunner)