Method test_tracepath_multi_thread

test/test_tracepath.py:108–157

Test that show trace paths aggregates paths across worker threads

(self)

        super().tearDownClass()

    def test_tracepath_multi_thread(self):
        """Test that show trace paths aggregates paths across worker threads"""
        n_pkts = 5

        fwd_pkt = (
            Ether(src=self.pg0.remote_mac, dst=self.pg0.local_mac)
            / IP(src=self.pg0.remote_ip4, dst=self.pg1.remote_ip4)
            / UDP(sport=1234, dport=5678)
        )
        drop_pkt = (
            Ether(src=self.pg0.remote_mac, dst=self.pg0.local_mac)
            / IP(src=self.pg0.remote_ip4, dst="192.0.2.1")
            / UDP(sport=1234, dport=5678)
        )

        drop_route = VppIpRoute(
            self,
            "192.0.2.0",
            24,
            [VppRoutePath("0.0.0.0", 0xFFFFFFFF, type=FibPathType.FIB_PATH_TYPE_DROP)],
        )
        drop_route.add_vpp_config()

        # Send traffic & do not clear traces after first send_and_expect call
        # fwd path traffic (workers 0, 1)
        self.send_and_expect(self.pg0, [fwd_pkt] * n_pkts, self.pg1, worker=0)
        self.send_and_expect(
            self.pg0, [fwd_pkt] * n_pkts, self.pg1, worker=1, trace=False
        )

        # drop path traffic (worker 0)
        self.pg_send(self.pg0, [drop_pkt] * n_pkts, trace=False)
        out = self.vapi.cli("show trace paths")

        # Two unique paths: forwarding and drop
        self.assertEqual(out.count("Count:"), 2)

        # Fwd path seen on workers 0,1
        self.assertIn(f"Count: {n_pkts * 2}", out)
        fwd_line = next(l for l in out.splitlines() if f"Count: {n_pkts * 2}" in l)
        # check comma is present, which is used
        self.assertIn("Threads: [1, 2]", fwd_line)

        # Drop path seen on worker 0 only
        self.assertIn(f"Count: {n_pkts}", out)
        drop_line = next(l for l in out.splitlines() if f"Count: {n_pkts}" in l)
        # No comma, used to delimit between worker threads
        self.assertIn("Threads: [1]", drop_line)

        drop_route.remove_vpp_config()


if __name__ == "__main__":