7 from config import config
8 from asfframework import VppAsfTestCase, VppTestRunner, Worker, tag_fixme_vpp_workers
9 from vpp_ip_route import VppIpTable, VppIpRoute, VppRoutePath
12 class QUICAppWorker(Worker):
13 """QUIC Test Application Worker"""
30 app = f"{config.vpp_build_dir}/vpp/bin/{appname}"
31 self.args = [app] + executable_args
33 self.wait_for_gdb = "wait-for-gdb"
34 self.testcase = testcase
35 super(QUICAppWorker, self).__init__(self.args, logger, env, *args, **kwargs)
38 super(QUICAppWorker, self).run()
40 def teardown(self, logger, timeout):
41 if self.process is None:
44 logger.debug(f"Killing worker process (pid {self.process.pid})")
45 os.killpg(os.getpgid(self.process.pid), signal.SIGKILL)
48 logger.debug("Couldn't kill worker process")
53 @unittest.skipIf("quic" in config.excluded_plugins, "Exclude QUIC plugin tests")
54 class QUICTestCase(VppAsfTestCase):
60 server_appns = "server"
61 server_appns_secret = None
62 client_appns = "client"
63 client_appns_secret = None
67 cls.extra_vpp_plugin_config.append("plugin quic_plugin.so { enable }")
68 super(QUICTestCase, cls).setUpClass()
71 super(QUICTestCase, self).setUp()
72 self.vppDebug = "vpp_debug" in config.vpp_build_dir
74 self.create_loopback_interfaces(2)
75 self.uri = f"quic://{self.loop0.local_ip4}/1234"
77 for i in self.lo_interfaces:
81 tbl = VppIpTable(self, table_id)
84 i.set_table_ip4(table_id)
88 # Configure namespaces
89 self.vapi.app_namespace_add_del_v4(
90 namespace_id=self.server_appns,
91 secret=self.server_appns_secret,
92 sw_if_index=self.loop0.sw_if_index,
94 self.vapi.app_namespace_add_del_v4(
95 namespace_id=self.client_appns,
96 secret=self.client_appns_secret,
97 sw_if_index=self.loop1.sw_if_index,
100 # Add inter-table routes
101 self.ip_t01 = VppIpRoute(
103 self.loop1.local_ip4,
105 [VppRoutePath("0.0.0.0", 0xFFFFFFFF, nh_table_id=2)],
108 self.ip_t10 = VppIpRoute(
110 self.loop0.local_ip4,
112 [VppRoutePath("0.0.0.0", 0xFFFFFFFF, nh_table_id=1)],
115 self.ip_t01.add_vpp_config()
116 self.ip_t10.add_vpp_config()
117 self.logger.debug(self.vapi.cli("show ip fib"))
120 # Delete inter-table routes
121 self.ip_t01.remove_vpp_config()
122 self.ip_t10.remove_vpp_config()
124 for i in self.lo_interfaces:
128 super(QUICTestCase, self).tearDown()
131 class QUICEchoIntTestCase(QUICTestCase):
132 """QUIC Echo Internal Test Case"""
134 test_bytes = " test-bytes"
135 extra_vpp_config = ["session", "{", "enable", "poll-main", "}"]
138 super(QUICEchoIntTestCase, self).setUp()
140 f"uri {self.uri} fifo-size 64k{self.test_bytes} appns {self.client_appns} "
142 self.server_args = f"uri {self.uri} fifo-size 64k appns {self.server_appns} "
145 super(QUICEchoIntTestCase, self).tearDown()
147 def server(self, *args):
148 _args = self.server_args + " ".join(args)
149 error = self.vapi.cli(f"test echo server {_args}")
151 self.logger.critical(error)
152 self.assertNotIn("failed", error)
154 def client(self, *args):
155 _args = self.client_args + " ".join(args)
156 error = self.vapi.cli(f"test echo client {_args}")
158 self.logger.critical(error)
159 self.assertNotIn("failed", error)
162 @tag_fixme_vpp_workers
163 class QUICEchoIntTransferTestCase(QUICEchoIntTestCase):
164 """QUIC Echo Internal Transfer Test Case"""
166 def test_quic_int_transfer(self):
167 """QUIC internal transfer"""
169 self.client("mbytes", "2")
172 @tag_fixme_vpp_workers
173 class QUICEchoIntSerialTestCase(QUICEchoIntTestCase):
174 """QUIC Echo Internal Serial Transfer Test Case"""
176 def test_quic_serial_int_transfer(self):
177 """QUIC serial internal transfer"""
179 self.client("mbytes", "2")
180 self.client("mbytes", "2")
181 self.client("mbytes", "2")
182 self.client("mbytes", "2")
183 self.client("mbytes", "2")
186 @tag_fixme_vpp_workers
187 class QUICEchoIntMStreamTestCase(QUICEchoIntTestCase):
188 """QUIC Echo Internal MultiStream Test Case"""
190 def test_quic_int_multistream_transfer(self):
191 """QUIC internal multi-stream transfer"""
193 self.client("nclients", "10", "mbytes", "1")
196 class QUICEchoExtTestCase(QUICTestCase):
197 quic_setup = "default"
198 test_bytes = "test-bytes:assert"
204 server_fifo_size = "1M"
205 client_fifo_size = "4M"
211 "use-app-socket-api",
212 "wrk-mqs-segment-size",
214 "event-queue-length",
216 "preallocated-sessions",
218 "v4-session-table-buckets",
220 "v4-session-table-memory",
222 "v4-halfopen-table-buckets",
224 "v4-halfopen-table-memory",
226 "local-endpoints-table-buckets",
228 "local-endpoints-table-memory",
234 self.server_appns_secret = 1234
235 self.client_appns_secret = 5678
236 super(QUICEchoExtTestCase, self).setUp()
248 "use-app-socket-api",
250 self.server_echo_test_args = common_args + [
253 f"{self.server_appns}",
255 f"{self.server_fifo_size}",
257 f"{self.tempdir}/app_ns_sockets/{self.server_appns}",
259 self.client_echo_test_args = common_args + [
262 f"{self.client_appns}",
264 f"{self.client_fifo_size}",
266 f"{self.tempdir}/app_ns_sockets/{self.client_appns}",
268 error = self.vapi.cli("quic set fifo-size 2M")
270 self.logger.critical(error)
271 self.assertNotIn("failed", error)
273 def server(self, *args):
274 _args = self.server_echo_test_args + list(args)
275 self.worker_server = QUICAppWorker(
276 self.app, _args, self.logger, self.server_appns, self
278 self.worker_server.start()
279 self.sleep(self.pre_test_sleep)
281 def client(self, *args):
282 _args = self.client_echo_test_args + list(args)
283 self.worker_client = QUICAppWorker(
284 self.app, _args, self.logger, self.client_appns, self
286 self.worker_client.start()
287 timeout = None if self.debug_all else self.timeout
288 self.worker_client.join(timeout)
289 if self.worker_client.is_alive():
290 error = f"Client failed to complete in {timeout} seconds!"
291 self.logger.critical(error)
293 self.worker_server.join(timeout)
294 if self.worker_server.is_alive():
295 error = f"Server failed to complete in {timeout} seconds!"
296 self.logger.critical(error)
297 self.sleep(self.post_test_sleep)
299 def validate_ext_test_results(self):
300 server_result = self.worker_server.result
301 self.logger.debug(self.vapi.cli(f"show session verbose 2"))
302 client_result = self.worker_client.result
303 self.logger.info(f"Server worker result is `{server_result}'")
304 self.logger.info(f"Client worker result is `{client_result}'")
305 server_kill_error = False
306 if self.worker_server.result is None:
307 server_kill_error = self.worker_server.teardown(self.logger, self.timeout)
308 if self.worker_client.result is None:
309 self.worker_client.teardown(self.logger, self.timeout)
310 err_msg = f"Wrong server worker return code ({server_result})"
311 self.assertEqual(server_result, 0, err_msg)
312 self.assertIsNotNone(
313 client_result, f"Timeout! Client worker did not finish in {self.timeout}s"
315 err_msg = f"Wrong client worker return code ({client_result})"
316 self.assertEqual(client_result, 0, err_msg)
317 self.assertFalse(server_kill_error, "Server kill errored")
320 class QUICEchoExtTransferTestCase(QUICEchoExtTestCase):
321 """QUIC Echo External Transfer Test Case"""
325 def test_quic_ext_transfer(self):
326 """QUIC external transfer"""
329 self.validate_ext_test_results()
332 class QUICEchoExtTransferBigTestCase(QUICEchoExtTestCase):
333 """QUIC Echo External Transfer Big Test Case"""
335 server_fifo_size = "4M"
336 client_fifo_size = "4M"
340 @unittest.skipUnless(config.extended, "part of extended tests")
341 def test_quic_ext_transfer_big(self):
342 """QUIC external transfer, big stream"""
343 self.server("TX=0", "RX=2G")
344 self.client("TX=2G", "RX=0")
345 self.validate_ext_test_results()
348 class QUICEchoExtQcloseRxTestCase(QUICEchoExtTestCase):
349 """QUIC Echo External Transfer Qclose Rx Test Case"""
351 @unittest.skipUnless(config.extended, "part of extended tests")
352 @unittest.skip("testcase under development")
353 def test_quic_ext_qclose_rx(self):
354 """QUIC external transfer, rx close"""
355 self.server("TX=0", "RX=10M", "qclose=Y", "sclose=N")
356 self.client("TX=10M", "RX=0", "qclose=W", "sclose=W")
357 self.validate_ext_test_results()
360 class QUICEchoExtQcloseTxTestCase(QUICEchoExtTestCase):
361 """QUIC Echo External Transfer Qclose Tx Test Case"""
363 @unittest.skipUnless(config.extended, "part of extended tests")
364 @unittest.skip("testcase under development")
365 def test_quic_ext_qclose_tx(self):
366 """QUIC external transfer, tx close"""
367 self.server("TX=0", "RX=10M", "qclose=W", "sclose=W", "rx-results-diff")
368 self.client("TX=10M", "RX=0", "qclose=Y", "sclose=N")
369 self.validate_ext_test_results()
372 class QUICEchoExtEarlyQcloseRxTestCase(QUICEchoExtTestCase):
373 """QUIC Echo External Transfer Early Qclose Rx Test Case"""
375 @unittest.skipUnless(config.extended, "part of extended tests")
376 @unittest.skip("testcase under development")
377 def test_quic_ext_early_qclose_rx(self):
378 """QUIC external transfer, early rx close"""
379 self.server("TX=0", "RX=10M", "qclose=Y", "sclose=N")
380 self.client("TX=20M", "RX=0", "qclose=W", "sclose=W", "tx-results-diff")
381 self.validate_ext_test_results()
384 class QUICEchoExtEarlyQcloseTxTestCase(QUICEchoExtTestCase):
385 """QUIC Echo External Transfer Early Qclose Tx Test Case"""
387 @unittest.skipUnless(config.extended, "part of extended tests")
388 @unittest.skip("testcase under development")
389 def test_quic_ext_early_qclose_tx(self):
390 """QUIC external transfer, early tx close"""
391 self.server("TX=0", "RX=20M", "qclose=W", "sclose=W", "rx-results-diff")
392 self.client("TX=10M", "RX=0", "qclose=Y", "sclose=N")
393 self.validate_ext_test_results()
396 class QUICEchoExtScloseRxTestCase(QUICEchoExtTestCase):
397 """QUIC Echo External Transfer Sclose Rx Test Case"""
399 @unittest.skipUnless(config.extended, "part of extended tests")
400 @unittest.skip("testcase under development")
401 def test_quic_ext_sclose_rx(self):
402 """QUIC external transfer, rx stream close"""
403 self.server("TX=0", "RX=10M", "qclose=N", "sclose=Y")
404 self.client("TX=10M", "RX=0", "qclose=W", "sclose=W")
405 self.validate_ext_test_results()
408 class QUICEchoExtScloseTxTestCase(QUICEchoExtTestCase):
409 """QUIC Echo External Transfer Sclose Tx Test Case"""
411 @unittest.skipUnless(config.extended, "part of extended tests")
412 @unittest.skip("testcase under development")
413 def test_quic_ext_sclose_tx(self):
414 """QUIC external transfer, tx stream close"""
415 self.server("TX=0", "RX=10M", "qclose=W", "sclose=W")
416 self.client("TX=10M", "RX=0", "qclose=Y", "sclose=Y")
417 self.validate_ext_test_results()
420 class QUICEchoExtEarlyScloseRxTestCase(QUICEchoExtTestCase):
421 """QUIC Echo External Transfer Early Sclose Rx Test Case"""
423 @unittest.skipUnless(config.extended, "part of extended tests")
424 @unittest.skip("testcase under development")
425 def test_quic_ext_early_sclose_rx(self):
426 """QUIC external transfer, early rx stream close"""
427 self.server("TX=0", "RX=10M", "qclose=N", "sclose=Y")
428 self.client("TX=20M", "RX=0", "qclose=W", "sclose=W", "tx-results-diff")
429 self.validate_ext_test_results()
432 class QUICEchoExtEarlyScloseTxTestCase(QUICEchoExtTestCase):
433 """QUIC Echo External Transfer Early Sclose Tx Test Case"""
435 @unittest.skipUnless(config.extended, "part of extended tests")
436 @unittest.skip("testcase under development")
437 def test_quic_ext_early_sclose_tx(self):
438 """QUIC external transfer, early tx stream close"""
439 self.server("TX=0", "RX=20M", "qclose=W", "sclose=W", "rx-results-diff")
440 self.client("TX=10M", "RX=0", "qclose=Y", "sclose=Y")
441 self.validate_ext_test_results()
444 class QUICEchoExtServerStreamTestCase(QUICEchoExtTestCase):
445 """QUIC Echo External Transfer Server Stream Test Case"""
447 quic_setup = "serverstream"
450 def test_quic_ext_transfer_server_stream(self):
451 """QUIC external server transfer"""
452 self.server("TX=10M", "RX=0")
453 self.client("TX=0", "RX=10M")
454 self.validate_ext_test_results()
457 class QUICEchoExtServerStreamBigTestCase(QUICEchoExtTestCase):
458 """QUIC Echo External Transfer Server Stream Big Test Case"""
460 quic_setup = "serverstream"
461 server_fifo_size = "4M"
462 client_fifo_size = "4M"
466 @unittest.skipUnless(config.extended, "part of extended tests")
467 def test_quic_ext_transfer_server_stream_big(self):
468 """QUIC external server transfer, big stream"""
469 self.server("TX=2G", "RX=0")
470 self.client("TX=0", "RX=2G")
471 self.validate_ext_test_results()
474 class QUICEchoExtServerStreamQcloseRxTestCase(QUICEchoExtTestCase):
475 """QUIC Echo External Transfer Server Stream Qclose Rx Test Case"""
477 quic_setup = "serverstream"
479 @unittest.skipUnless(config.extended, "part of extended tests")
480 @unittest.skip("testcase under development")
481 def test_quic_ext_server_stream_qclose_rx(self):
482 """QUIC external server transfer, rx close"""
483 self.server("TX=10M", "RX=0", "qclose=W", "sclose=W")
484 self.client("TX=0", "RX=10M", "qclose=Y", "sclose=N")
485 self.validate_ext_test_results()
488 class QUICEchoExtServerStreamQcloseTxTestCase(QUICEchoExtTestCase):
489 """QUIC Echo External Transfer Server Stream Qclose Tx Test Case"""
491 quic_setup = "serverstream"
493 @unittest.skipUnless(config.extended, "part of extended tests")
494 @unittest.skip("testcase under development")
495 def test_quic_ext_server_stream_qclose_tx(self):
496 """QUIC external server transfer, tx close"""
497 self.server("TX=10M", "RX=0", "qclose=Y", "sclose=N")
498 self.client("TX=0", "RX=10M", "qclose=W", "sclose=W", "rx-results-diff")
499 self.validate_ext_test_results()
502 class QUICEchoExtServerStreamEarlyQcloseRxTestCase(QUICEchoExtTestCase):
503 """QUIC Echo External Transfer Server Stream Early Qclose Rx Test Case"""
505 quic_setup = "serverstream"
507 @unittest.skipUnless(config.extended, "part of extended tests")
508 @unittest.skip("testcase under development")
509 def test_quic_ext_server_stream_early_qclose_rx(self):
510 """QUIC external server transfer, early rx close"""
511 self.server("TX=20M", "RX=0", "qclose=W", "sclose=W", "tx-results-diff")
512 self.client("TX=0", "RX=10M", "qclose=Y", "sclose=N")
513 self.validate_ext_test_results()
516 class QUICEchoExtServerStreamEarlyQcloseTxTestCase(QUICEchoExtTestCase):
517 """QUIC Echo External Transfer Server Stream Early Qclose Tx Test Case"""
519 quic_setup = "serverstream"
521 @unittest.skipUnless(config.extended, "part of extended tests")
522 @unittest.skip("testcase under development")
523 def test_quic_ext_server_stream_early_qclose_tx(self):
524 """QUIC external server transfer, early tx close"""
525 self.server("TX=10M", "RX=0", "qclose=Y", "sclose=N")
526 self.client("TX=0", "RX=20M", "qclose=W", "sclose=W", "rx-results-diff")
527 self.validate_ext_test_results()
530 class QUICEchoExtServerStreamScloseRxTestCase(QUICEchoExtTestCase):
531 """QUIC Echo External Transfer Server Stream Sclose Rx Test Case"""
533 quic_setup = "serverstream"
535 @unittest.skipUnless(config.extended, "part of extended tests")
536 @unittest.skip("testcase under development")
537 def test_quic_ext_server_stream_sclose_rx(self):
538 """QUIC external server transfer, rx stream close"""
539 self.server("TX=10M", "RX=0", "qclose=W", "sclose=W")
540 self.client("TX=0", "RX=10M", "qclose=N", "sclose=Y")
541 self.validate_ext_test_results()
544 class QUICEchoExtServerStreamScloseTxTestCase(QUICEchoExtTestCase):
545 """QUIC Echo External Transfer Server Stream Sclose Tx Test Case"""
547 quic_setup = "serverstream"
549 @unittest.skipUnless(config.extended, "part of extended tests")
550 @unittest.skip("testcase under development")
551 def test_quic_ext_server_stream_sclose_tx(self):
552 """QUIC external server transfer, tx stream close"""
553 self.server("TX=10M", "RX=0", "qclose=Y", "sclose=Y")
554 self.client("TX=0", "RX=10M", "qclose=W", "sclose=W")
555 self.validate_ext_test_results()
558 class QUICEchoExtServerStreamEarlyScloseRxTestCase(QUICEchoExtTestCase):
559 """QUIC Echo External Transfer Server Stream Early Sclose Rx Test Case"""
561 quic_setup = "serverstream"
563 @unittest.skipUnless(config.extended, "part of extended tests")
564 @unittest.skip("testcase under development")
565 def test_quic_ext_server_stream_early_sclose_rx(self):
566 """QUIC external server transfer, early rx stream close"""
567 self.server("TX=20M", "RX=0", "qclose=W", "sclose=W", "tx-results-diff")
568 self.client("TX=0", "RX=10M", "qclose=N", "sclose=Y")
569 self.validate_ext_test_results()
572 class QUICEchoExtServerStreamEarlyScloseTxTestCase(QUICEchoExtTestCase):
573 """QUIC Echo Ext Transfer Server Stream Early Sclose Tx Test Case"""
575 quic_setup = "serverstream"
577 @unittest.skipUnless(config.extended, "part of extended tests")
578 @unittest.skip("testcase under development")
579 def test_quic_ext_server_stream_early_sclose_tx(self):
580 """QUIC external server transfer, early tx stream close"""
581 self.server("TX=10M", "RX=0", "qclose=Y", "sclose=Y")
582 self.client("TX=0", "RX=20M", "qclose=W", "sclose=W", "rx-results-diff")
583 self.validate_ext_test_results()
586 class QUICEchoExtServerStreamWorkersTestCase(QUICEchoExtTestCase):
587 """QUIC Echo External Transfer Server Stream MultiWorker Test Case"""
589 quic_setup = "serverstream"
591 @unittest.skipUnless(config.extended, "part of extended tests")
592 @unittest.skip("testcase under development")
593 def test_quic_ext_transfer_server_stream_multi_workers(self):
594 """QUIC external server transfer, multi-worker"""
595 self.server("nclients", "4", "quic-streams", "4", "TX=10M", "RX=0")
596 self.client("nclients", "4", "quic-streams", "4", "TX=0", "RX=10M")
597 self.validate_ext_test_results()
600 if __name__ == "__main__":
601 unittest.main(testRunner=VppTestRunner)