| 686 | return capture[0].packets |
| 687 | |
| 688 | def send_and_expect_load_balancing( |
| 689 | self, input, pkts, outputs, worker=None, trace=True |
| 690 | ): |
| 691 | self.pg_send(input, pkts, worker=worker, trace=trace) |
| 692 | rxs = [] |
| 693 | for oo in outputs: |
| 694 | rx = oo._get_capture() |
| 695 | self.assertNotEqual(0, len(rx), f"0 != len(rx) ({len(rx)})") |
| 696 | rxs.append(rx) |
| 697 | if trace: |
| 698 | self.logger.debug(self.vapi.cli("show trace")) |
| 699 | return rxs |
| 700 | |
| 701 | def send_and_expect_some(self, intf, pkts, output, worker=None, trace=True): |
| 702 | self.pg_send(intf, pkts, worker=worker, trace=trace) |