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(namespace_id="1", secret=1234,
107 sw_if_index=self.loop0.sw_if_index)
108 self.vapi.app_namespace_add(namespace_id="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(namespace_id="1", secret=1234,
150 sw_if_index=self.loop0.sw_if_index)
151 self.vapi.app_namespace_add(namespace_id="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.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 LDPThruHostStackEcho(VCLTestCase):
375 """ LDP Thru Host Stack Echo """
379 super(LDPThruHostStackEcho, cls).setUpClass()
382 def tearDownClass(cls):
383 super(LDPThruHostStackEcho, cls).tearDownClass()
386 super(LDPThruHostStackEcho, self).setUp()
388 self.thru_host_stack_setup()
389 self.client_echo_test_args = ["-E", self.echo_phrase, "-X",
390 self.loop0.local_ip4,
394 self.thru_host_stack_tear_down()
395 super(LDPThruHostStackEcho, self).tearDown()
397 def test_ldp_thru_host_stack_echo(self):
398 """ run LDP thru host stack echo test """
400 self.thru_host_stack_test("sock_test_server", self.server_args,
402 self.client_echo_test_args)
405 class VCLThruHostStackEcho(VCLTestCase):
406 """ VCL Thru Host Stack Echo """
410 super(VCLThruHostStackEcho, cls).setUpClass()
413 def tearDownClass(cls):
414 super(VCLThruHostStackEcho, cls).tearDownClass()
417 super(VCLThruHostStackEcho, self).setUp()
419 self.thru_host_stack_setup()
420 self.client_bi_dir_nsock_timeout = 20
421 self.client_bi_dir_nsock_test_args = ["-N", "1000", "-B", "-X",
423 self.loop0.local_ip4,
425 self.client_echo_test_args = ["-E", self.echo_phrase, "-X",
426 self.loop0.local_ip4,
430 self.logger.debug(self.vapi.cli("show app server"))
431 self.logger.debug(self.vapi.cli("show session verbose"))
432 self.thru_host_stack_tear_down()
433 super(VCLThruHostStackEcho, self).tearDown()
436 class VCLThruHostStackTLS(VCLTestCase):
437 """ VCL Thru Host Stack TLS """
441 super(VCLThruHostStackTLS, cls).setUpClass()
444 def tearDownClass(cls):
445 super(VCLThruHostStackTLS, cls).tearDownClass()
448 super(VCLThruHostStackTLS, self).setUp()
450 self.thru_host_stack_setup()
451 self.client_uni_dir_tls_timeout = 20
452 self.server_tls_args = ["-S", self.server_port]
453 self.client_uni_dir_tls_test_args = ["-N", "1000", "-U", "-X", "-S",
454 self.loop0.local_ip4,
457 def test_vcl_thru_host_stack_tls_uni_dir(self):
458 """ run VCL thru host stack uni-directional TLS test """
460 self.timeout = self.client_uni_dir_tls_timeout
461 self.thru_host_stack_test("vcl_test_server", self.server_tls_args,
463 self.client_uni_dir_tls_test_args)
466 self.logger.debug(self.vapi.cli("show app server"))
467 self.logger.debug(self.vapi.cli("show session verbose 2"))
468 self.thru_host_stack_tear_down()
469 super(VCLThruHostStackTLS, self).tearDown()
472 class VCLThruHostStackBidirNsock(VCLTestCase):
473 """ VCL Thru Host Stack Bidir Nsock """
477 super(VCLThruHostStackBidirNsock, cls).setUpClass()
480 def tearDownClass(cls):
481 super(VCLThruHostStackBidirNsock, cls).tearDownClass()
484 super(VCLThruHostStackBidirNsock, self).setUp()
486 self.thru_host_stack_setup()
487 self.client_bi_dir_nsock_timeout = 20
488 self.client_bi_dir_nsock_test_args = ["-N", "1000", "-B", "-X",
490 self.loop0.local_ip4,
492 self.client_echo_test_args = ["-E", self.echo_phrase, "-X",
493 self.loop0.local_ip4,
497 self.thru_host_stack_tear_down()
498 super(VCLThruHostStackBidirNsock, self).tearDown()
500 def test_vcl_thru_host_stack_bi_dir_nsock(self):
501 """ run VCL thru host stack bi-directional (multiple sockets) test """
503 self.timeout = self.client_bi_dir_nsock_timeout
504 self.thru_host_stack_test("vcl_test_server", self.server_args,
506 self.client_bi_dir_nsock_test_args)
509 class LDPThruHostStackBidirNsock(VCLTestCase):
510 """ LDP Thru Host Stack Bidir Nsock """
514 super(LDPThruHostStackBidirNsock, cls).setUpClass()
517 def tearDownClass(cls):
518 super(LDPThruHostStackBidirNsock, cls).tearDownClass()
521 super(LDPThruHostStackBidirNsock, self).setUp()
523 self.thru_host_stack_setup()
525 self.client_bi_dir_nsock_timeout = 20
526 self.client_bi_dir_nsock_test_args = ["-N", "1000", "-B", "-X",
527 # OUCH! Host Stack Bug?
529 self.loop0.local_ip4,
532 self.client_bi_dir_nsock_timeout = 20
533 self.client_bi_dir_nsock_test_args = ["-N", "1000", "-B", "-X",
534 # OUCH! Host Stack Bug?
536 self.loop0.local_ip4,
540 self.thru_host_stack_tear_down()
541 super(LDPThruHostStackBidirNsock, self).tearDown()
543 def test_ldp_thru_host_stack_bi_dir_nsock(self):
544 """ run LDP thru host stack bi-directional (multiple sockets) test """
546 self.timeout = self.client_bi_dir_nsock_timeout
547 self.thru_host_stack_test("sock_test_server", self.server_args,
549 self.client_bi_dir_nsock_test_args)
552 class LDPThruHostStackNsock(VCLTestCase):
553 """ LDP Thru Host Stack Nsock """
557 super(LDPThruHostStackNsock, cls).setUpClass()
560 def tearDownClass(cls):
561 super(LDPThruHostStackNsock, cls).tearDownClass()
564 super(LDPThruHostStackNsock, self).setUp()
566 self.thru_host_stack_setup()
568 self.client_uni_dir_nsock_timeout = 20
569 self.numSockets = "2"
571 self.client_uni_dir_nsock_timeout = 20
572 self.numSockets = "5"
574 self.client_uni_dir_nsock_test_args = ["-N", "1000", "-U", "-X",
575 "-I", self.numSockets,
576 self.loop0.local_ip4,
580 self.thru_host_stack_tear_down()
581 super(LDPThruHostStackNsock, self).tearDown()
583 def test_ldp_thru_host_stack_uni_dir_nsock(self):
584 """ run LDP thru host stack uni-directional (multiple sockets) test """
586 self.timeout = self.client_uni_dir_nsock_timeout
587 self.thru_host_stack_test("sock_test_server", self.server_args,
589 self.client_uni_dir_nsock_test_args)
592 class VCLThruHostStackNsock(VCLTestCase):
593 """ VCL Thru Host Stack Nsock """
597 super(VCLThruHostStackNsock, cls).setUpClass()
600 def tearDownClass(cls):
601 super(VCLThruHostStackNsock, cls).tearDownClass()
604 super(VCLThruHostStackNsock, self).setUp()
606 self.thru_host_stack_setup()
608 self.client_uni_dir_nsock_timeout = 20
609 self.numSockets = "2"
611 self.client_uni_dir_nsock_timeout = 20
612 self.numSockets = "5"
614 self.client_uni_dir_nsock_test_args = ["-N", "1000", "-U", "-X",
615 "-I", self.numSockets,
616 self.loop0.local_ip4,
620 self.thru_host_stack_tear_down()
621 super(VCLThruHostStackNsock, self).tearDown()
623 def test_vcl_thru_host_stack_uni_dir_nsock(self):
624 """ run VCL thru host stack uni-directional (multiple sockets) test """
626 self.timeout = self.client_uni_dir_nsock_timeout
627 self.thru_host_stack_test("vcl_test_server", self.server_args,
629 self.client_uni_dir_nsock_test_args)
632 class LDPThruHostStackIperf(VCLTestCase):
633 """ LDP Thru Host Stack Iperf """
637 super(LDPThruHostStackIperf, cls).setUpClass()
640 def tearDownClass(cls):
641 super(LDPThruHostStackIperf, cls).tearDownClass()
644 super(LDPThruHostStackIperf, self).setUp()
646 self.thru_host_stack_setup()
647 self.client_iperf3_timeout = 20
648 self.client_iperf3_args = ["-V4d", "-t 2", "-c", self.loop0.local_ip4]
649 self.server_iperf3_args = ["-V4d", "-s"]
652 self.logger.debug(self.vapi.cli("show session verbose 2"))
653 self.thru_host_stack_tear_down()
654 super(LDPThruHostStackIperf, self).tearDown()
656 def test_ldp_thru_host_stack_iperf3(self):
657 """ run LDP thru host stack iperf3 test """
660 subprocess.check_output(['iperf3', '-v'])
661 except subprocess.CalledProcessError:
662 self.logger.error("WARNING: 'iperf3' is not installed,")
664 " 'test_ldp_thru_host_stack_iperf3' not run!")
667 self.logger.error("WARNING: 'iperf3' is not installed,")
668 self.logger.error(" 'test' not run!")
670 except Exception as e:
671 self.logger.error("WARNING: 'iperf3' unexpected error,")
672 self.logger.error(" 'test' not run!")
675 self.timeout = self.client_iperf3_timeout
676 self.thru_host_stack_test("iperf3", self.server_iperf3_args,
677 "iperf3", self.client_iperf3_args)
680 class LDPIpv6CutThruTestCase(VCLTestCase):
681 """ LDP IPv6 Cut Thru Tests """
685 super(LDPIpv6CutThruTestCase, cls).setUpClass()
688 def tearDownClass(cls):
689 super(LDPIpv6CutThruTestCase, cls).tearDownClass()
692 super(LDPIpv6CutThruTestCase, self).setUp()
694 self.cut_thru_setup()
695 self.client_iperf3_timeout = 20
696 self.client_uni_dir_nsock_timeout = 20
697 self.client_bi_dir_nsock_timeout = 20
698 self.client_ipv6_echo_test_args = ["-6", "-E", self.echo_phrase, "-X",
699 self.server_ipv6_addr,
701 self.client_ipv6_iperf3_args = ["-V6d", "-t 2", "-c",
702 self.server_ipv6_addr]
703 self.server_ipv6_iperf3_args = ["-V6d", "-s"]
704 self.client_ipv6_uni_dir_nsock_test_args = ["-N", "1000", "-U", "-X",
707 self.server_ipv6_addr,
709 self.client_ipv6_bi_dir_nsock_test_args = ["-N", "1000", "-B", "-X",
712 self.server_ipv6_addr,
716 self.cut_thru_tear_down()
718 super(LDPIpv6CutThruTestCase, self).tearDown()
720 def test_ldp_ipv6_cut_thru_echo(self):
721 """ run LDP IPv6 cut thru echo test """
723 self.cut_thru_test("sock_test_server",
724 self.server_ipv6_args,
726 self.client_ipv6_echo_test_args)
728 @unittest.skipUnless(running_extended_tests, "part of extended tests")
729 def test_ldp_ipv6_cut_thru_iperf3(self):
730 """ run LDP IPv6 cut thru iperf3 test """
733 subprocess.check_output(['iperf3', '-v'])
735 self.logger.error("WARNING: 'iperf3' is not installed,")
737 " 'test_ldp_ipv6_cut_thru_iperf3' not run!")
740 self.timeout = self.client_iperf3_timeout
741 self.cut_thru_test("iperf3", self.server_ipv6_iperf3_args,
742 "iperf3", self.client_ipv6_iperf3_args)
744 @unittest.skipUnless(running_extended_tests, "part of extended tests")
745 def test_ldp_ipv6_cut_thru_uni_dir_nsock(self):
746 """ run LDP IPv6 cut thru uni-directional (multiple sockets) test """
748 self.timeout = self.client_uni_dir_nsock_timeout
749 self.cut_thru_test("sock_test_server", self.server_ipv6_args,
751 self.client_ipv6_uni_dir_nsock_test_args)
753 @unittest.skipUnless(running_extended_tests, "part of extended tests")
754 def test_ldp_ipv6_cut_thru_bi_dir_nsock(self):
755 """ run LDP IPv6 cut thru bi-directional (multiple sockets) test """
757 self.timeout = self.client_bi_dir_nsock_timeout
758 self.cut_thru_test("sock_test_server", self.server_ipv6_args,
760 self.client_ipv6_bi_dir_nsock_test_args)
763 class VCLIpv6CutThruTestCase(VCLTestCase):
764 """ VCL IPv6 Cut Thru Tests """
768 super(VCLIpv6CutThruTestCase, cls).setUpClass()
771 def tearDownClass(cls):
772 super(VCLIpv6CutThruTestCase, cls).tearDownClass()
775 super(VCLIpv6CutThruTestCase, self).setUp()
777 self.cut_thru_setup()
778 self.client_uni_dir_nsock_timeout = 20
779 self.client_bi_dir_nsock_timeout = 20
780 self.client_ipv6_echo_test_args = ["-6", "-E", self.echo_phrase, "-X",
781 self.server_ipv6_addr,
783 self.client_ipv6_uni_dir_nsock_test_args = ["-N", "1000", "-U", "-X",
786 self.server_ipv6_addr,
788 self.client_ipv6_bi_dir_nsock_test_args = ["-N", "1000", "-B", "-X",
791 self.server_ipv6_addr,
795 self.cut_thru_tear_down()
797 super(VCLIpv6CutThruTestCase, self).tearDown()
799 def test_vcl_ipv6_cut_thru_echo(self):
800 """ run VCL IPv6 cut thru echo test """
802 self.cut_thru_test("vcl_test_server",
803 self.server_ipv6_args,
805 self.client_ipv6_echo_test_args)
807 @unittest.skipUnless(running_extended_tests, "part of extended tests")
808 def test_vcl_ipv6_cut_thru_uni_dir_nsock(self):
809 """ run VCL IPv6 cut thru uni-directional (multiple sockets) test """
811 self.timeout = self.client_uni_dir_nsock_timeout
812 self.cut_thru_test("vcl_test_server", self.server_ipv6_args,
814 self.client_ipv6_uni_dir_nsock_test_args)
816 @unittest.skipUnless(running_extended_tests, "part of extended tests")
817 def test_vcl_ipv6_cut_thru_bi_dir_nsock(self):
818 """ run VCL IPv6 cut thru bi-directional (multiple sockets) test """
820 self.timeout = self.client_bi_dir_nsock_timeout
821 self.cut_thru_test("vcl_test_server", self.server_ipv6_args,
823 self.client_ipv6_bi_dir_nsock_test_args)
826 class VCLIpv6ThruHostStackEcho(VCLTestCase):
827 """ VCL IPv6 Thru Host Stack Echo """
831 super(VCLIpv6ThruHostStackEcho, cls).setUpClass()
834 def tearDownClass(cls):
835 super(VCLIpv6ThruHostStackEcho, cls).tearDownClass()
838 super(VCLIpv6ThruHostStackEcho, self).setUp()
840 self.thru_host_stack_ipv6_setup()
841 self.client_ipv6_echo_test_args = ["-6", "-E", self.echo_phrase, "-X",
842 self.loop0.local_ip6,
846 self.thru_host_stack_ipv6_tear_down()
847 super(VCLIpv6ThruHostStackEcho, self).tearDown()
849 def test_vcl_ipv6_thru_host_stack_echo(self):
850 """ run VCL IPv6 thru host stack echo test """
852 self.thru_host_stack_test("vcl_test_server",
853 self.server_ipv6_args,
855 self.client_ipv6_echo_test_args)
858 if __name__ == '__main__':
859 unittest.main(testRunner=VppTestRunner)