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, "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, "input_source": self.source},
32 def query_vpp_config(self):
33 rs = self._test.vapi.qos_record_dump()
37 self.intf.sw_if_index == r.record.sw_if_index
38 and self.source == r.record.input_source
44 return "qos-record-%s-%d" % (self.intf, self.source)
47 class VppQosStore(VppObject):
48 """QoS Store(ing) configuration"""
50 def __init__(self, test, intf, source, value):
56 def add_vpp_config(self):
57 self._test.vapi.qos_store_enable_disable(
60 "sw_if_index": self.intf.sw_if_index,
61 "input_source": self.source,
65 self._test.registry.register(self, self._test.logger)
68 def remove_vpp_config(self):
69 self._test.vapi.qos_store_enable_disable(
71 store={"sw_if_index": self.intf.sw_if_index, "input_source": self.source},
74 def query_vpp_config(self):
75 rs = self._test.vapi.qos_store_dump()
79 self.intf.sw_if_index == r.store.sw_if_index
80 and self.source == r.store.input_source
81 and self.value == r.store.value
87 return "qos-store-%s-%d" % (self.intf, self.source)
90 class VppQosEgressMap(VppObject):
91 """QoS Egress Map(ping) configuration"""
93 def __init__(self, test, id, rows):
98 def add_vpp_config(self):
99 self._test.vapi.qos_egress_map_update(map={"id": self.id, "rows": self.rows})
100 self._test.registry.register(self, self._test.logger)
103 def remove_vpp_config(self):
104 self._test.vapi.qos_egress_map_delete(id=self.id)
106 def query_vpp_config(self):
107 rs = self._test.vapi.qos_egress_map_dump()
110 if self.id == r.map.id:
115 return "qos-map-%d" % (self.id)
118 class VppQosMark(VppObject):
119 """QoS Mark(ing) configuration"""
121 def __init__(self, test, intf, map, source):
127 def add_vpp_config(self):
128 self._test.vapi.qos_mark_enable_disable(
131 "sw_if_index": self.intf.sw_if_index,
132 "map_id": self.map.id,
133 "output_source": self.source,
136 self._test.registry.register(self, self._test.logger)
139 def remove_vpp_config(self):
140 self._test.vapi.qos_mark_enable_disable(
142 mark={"sw_if_index": self.intf.sw_if_index, "output_source": self.source},
145 def query_vpp_config(self):
146 ms = self._test.vapi.qos_mark_dump()
150 self.intf.sw_if_index == m.mark.sw_if_index
151 and self.source == m.mark.output_source
152 and self.map.id == m.mark.map_id
158 return "qos-mark-%s-%d" % (self.intf, self.source)