5 from vpp_papi.vpp_stats import VPPStats
7 from framework import tag_fixme_vpp_workers
8 from framework import VppTestCase, VppTestRunner
9 from scapy.layers.l2 import Ether
10 from scapy.layers.inet import IP
13 @tag_fixme_vpp_workers
14 class StatsClientTestCase(VppTestCase):
15 """Test Stats Client"""
19 super(StatsClientTestCase, cls).setUpClass()
22 def tearDownClass(cls):
23 super(StatsClientTestCase, cls).tearDownClass()
26 def setUpConstants(cls):
27 cls.extra_vpp_statseg_config = "per-node-counters on"
28 cls.extra_vpp_statseg_config += "update-interval 0.05"
29 super(StatsClientTestCase, cls).setUpConstants()
31 def test_set_errors(self):
33 self.assertEqual(self.statistics.set_errors(), {})
35 self.statistics.get_counter('/err/ethernet-input/no error'), [0])
37 def test_client_fd_leak(self):
38 """Test file descriptor count - VPP-1486"""
42 initial_fds = p.num_fds()
45 stats = VPPStats(socketname=cls.get_stats_sock_path())
48 ending_fds = p.num_fds()
49 self.assertEqual(initial_fds, ending_fds,
50 "initial client side file descriptor count: %s "
52 "ending client side file descriptor count: %s" % (
53 initial_fds, ending_fds))
55 def test_symlink_values(self):
56 """Test symlinks reported values"""
57 self.create_pg_interfaces(range(2))
59 for i in self.pg_interfaces:
66 packet = (Ether(src=self.pg0.remote_mac, dst=self.pg0.local_mac) /
67 IP(src=self.pg0.remote_ip4, dst=self.pg1.remote_ip4))
70 self.send_and_expect(self.pg0, p, self.pg1)
72 pg1_tx = self.statistics.get_counter('/interfaces/pg1/tx')
73 if_tx = self.statistics.get_counter('/if/tx')
75 self.assertEqual(pg1_tx[0]['bytes'],
76 if_tx[0][self.pg1.sw_if_index]['bytes'])
77 for i in self.pg_interfaces:
81 def test_symlink_add_del_interfaces(self):
82 """Test symlinks when adding and deleting interfaces"""
83 # We first create and delete interfaces
84 self.create_loopback_interfaces(1)
85 self.create_pg_interfaces(range(1))
86 self.loop0.remove_vpp_config()
87 self.create_pg_interfaces(range(2))
89 for i in self.pg_interfaces:
97 packet = (Ether(src=self.pg0.remote_mac, dst=self.pg0.local_mac) /
98 IP(src=self.pg0.remote_ip4, dst=self.pg1.remote_ip4))
99 bytes_to_send += len(packet)
102 tx_before_sending = self.statistics.get_counter('/interfaces/pg1/tx')
103 rx_before_sending = self.statistics.get_counter('/interfaces/pg0/rx')
104 self.send_and_expect(self.pg0, p, self.pg1)
105 tx = self.statistics.get_counter('/interfaces/pg1/tx')
106 rx = self.statistics.get_counter('/interfaces/pg0/rx')
108 # We wait for nodes symlinks to update (interfaces created/deleted).
109 # ... and packets to be sent
111 vectors = self.statistics.get_counter('/nodes/pg1-tx/vectors')
113 self.assertEqual(tx[0]['bytes'] - tx_before_sending[0]['bytes'],
115 self.assertEqual(tx[0]['packets'] - tx_before_sending[0]['packets'],
117 self.assertEqual(rx[0]['bytes'] - rx_before_sending[0]['bytes'],
119 self.assertEqual(rx[0]['packets'] - rx_before_sending[0]['packets'],
121 self.assertEqual(vectors[0], rx[0]['packets'])
123 for i in self.pg_interfaces:
127 def test_index_consistency(self):
128 """Test index consistency despite changes in the stats"""
129 d = self.statistics.ls(['/if/names'])
130 self.create_loopback_interfaces(10)
133 s = self.statistics.dump(d)
138 self.assertEqual(len(v), 11)
140 for i in self.lo_interfaces:
141 i.remove_vpp_config()
143 @unittest.skip("Manual only")
144 def test_mem_leak(self):
146 print('Running loop')
148 rv = self.vapi.papi.tap_create_v2(id=i, use_random_mac=1)
149 self.assertEqual(rv.retval, 0)
150 rv = self.vapi.papi.tap_delete_v2(sw_if_index=rv.sw_if_index)
151 self.assertEqual(rv.retval, 0)
153 before = self.statistics.get_counter('/mem/statseg/used')
155 self.vapi.cli("memory-trace on stats-segment")
158 print(self.vapi.cli("show memory stats-segment verbose"))
159 print('AFTER', before,
160 self.statistics.get_counter('/mem/statseg/used'))
163 if __name__ == '__main__':
164 unittest.main(testRunner=VppTestRunner)