4 object abstractions for representing QoS config VPP
7 from vpp_object import VppObject
10 class VppQosRecord(VppObject):
11 """ QoS Record(ing) configuration """
13 def __init__(self, test, intf, source):
18 def add_vpp_config(self):
19 self._test.vapi.qos_record_enable_disable(
21 record={'sw_if_index': self.intf.sw_if_index,
22 'input_source': self.source})
23 self._test.registry.register(self, self._test.logger)
26 def remove_vpp_config(self):
27 self._test.vapi.qos_record_enable_disable(
29 record={'sw_if_index': self.intf.sw_if_index,
30 'input_source': self.source})
32 def query_vpp_config(self):
33 rs = self._test.vapi.qos_record_dump()
36 if self.intf.sw_if_index == r.record.sw_if_index and \
37 self.source == r.record.input_source:
42 return ("qos-record-%s-%d" % (self.intf, self.source))
45 class VppQosEgressMap(VppObject):
46 """ QoS Egress Map(ping) configuration """
48 def __init__(self, test, id, rows):
53 def add_vpp_config(self):
54 self._test.vapi.qos_egress_map_update(
57 self._test.registry.register(self, self._test.logger)
60 def remove_vpp_config(self):
61 self._test.vapi.qos_egress_map_delete(id=self.id)
63 def query_vpp_config(self):
64 rs = self._test.vapi.qos_egress_map_dump()
67 if self.id == r.map.id:
72 return ("qos-map-%d" % (self.id))
75 class VppQosMark(VppObject):
76 """ QoS Mark(ing) configuration """
78 def __init__(self, test, intf, map, source):
84 def add_vpp_config(self):
85 self._test.vapi.qos_mark_enable_disable(
87 mark={'sw_if_index': self.intf.sw_if_index,
88 'map_id': self.map.id,
89 'output_source': self.source})
90 self._test.registry.register(self, self._test.logger)
93 def remove_vpp_config(self):
94 self._test.vapi.qos_mark_enable_disable(
96 mark={'sw_if_index': self.intf.sw_if_index,
97 'output_source': self.source})
99 def query_vpp_config(self):
100 ms = self._test.vapi.qos_mark_dump()
103 if self.intf.sw_if_index == m.mark.sw_if_index and \
104 self.source == m.mark.output_source and \
105 self.map.id == m.mark.map_id:
110 return ("qos-mark-%s-%d" % (self.intf, self.source))