misc: classifier-based packet trace filter - vpp

diff options

author	Dave Barach <dave@barachs.net>	2019-09-13 17:47:50 -0400
committer	Florin Coras <florin.coras@gmail.com>	2019-09-20 15:55:25 +0000
commit	9137e5400699bed9f7c0095187839a8b38273100 (patch)
tree	b4f0b34583c8e4add09b34e8a4c52a5606b2dc55 /src/vnet/interface.h
parent	864d857c6c223be8ec11c588d65e8c5c2e211814 (diff)

misc: classifier-based packet trace filter

See .../src/vnet/classify/trace_classify.h for the business end of the scheme. It would be best to hash pkts, prefetch buckets, and do the primary table lookups two at a time. The inline as given works, but perf tuning will be required. "At least it works..." Add "classify filter" debug cli, for example: classify filter mask l3 ip4 src dst \ match l3 ip4 dst 192.168.2.10 src 192.168.1.10 Add "pcap rx | tx trace ... filter" to use the current classify filter chain Patch includes sphinx documentation and doxygen tags. Next step: device-driver integration Type: feature Signed-off-by: Dave Barach <dave@barachs.net> Change-Id: I05b1358a769f61e6d32470e0c87058f640486b26

Diffstat (limited to 'src/vnet/interface.h')

-rw-r--r--

src/vnet/interface.h

1 files changed, 1 insertions, 0 deletions

""" QoS object abstractions for representing QoS config VPP """ from vpp_object import VppObject class VppQosRecord(VppObject): """ QoS Record(ing) configuration """ def __init__(self, test, intf, source): self._test = test self.intf = intf self.source = source def add_vpp_config(self): self._test.vapi.qos_record_enable_disable( enable=1, record={'sw_if_index': self.intf.sw_if_index, 'input_source': self.source}) self._test.registry.register(self, self._test.logger) return self def remove_vpp_config(self): self._test.vapi.qos_record_enable_disable( enable=0, record={'sw_if_index': self.intf.sw_if_index, 'input_source': self.source}) def query_vpp_config(self): rs = self._test.vapi.qos_record_dump() for r in rs: if self.intf.sw_if_index == r.record.sw_if_index and \ self.source == r.record.input_source: return True return False def object_id(self): return ("qos-record-%s-%d" % (self.intf, self.source)) class VppQosStore(VppObject): """ QoS Store(ing) configuration """ def __init__(self, test, intf, source, value): self._test = test self.intf = intf self.source = source self.value = value def add_vpp_config(self): self._test.vapi.qos_store_enable_disable( enable=1, store={'sw_if_index': self.intf.sw_if_index, 'input_source': self.source, 'value': self.value}) self._test.registry.register(self, self._test.logger) return self def remove_vpp_config(self): self._test.vapi.qos_store_enable_disable( enable=0, store={'sw_if_index': self.intf.sw_if_index, 'input_source': self.source}) def query_vpp_config(self): rs = self._test.vapi.qos_store_dump() for r in rs: if self.intf.sw_if_index == r.store.sw_if_index and \ self.source == r.store.input_source and \ self.value == r.store.value: return True return False def object_id(self): return ("qos-store-%s-%d" % (self.intf, self.source)) class VppQosEgressMap(VppObject): """ QoS Egress Map(ping) configuration """ def __init__(self, test, id, rows): self._test = test self.id = id self.rows = rows def add_vpp_config(self): self._test.vapi.qos_egress_map_update( map={'id': self.id, 'rows': self.rows}) self._test.registry.register(self, self._test.logger) return self def remove_vpp_config(self): self._test.vapi.qos_egress_map_delete(id=self.id) def query_vpp_config(self): rs = self._test.vapi.qos_egress_map_dump() for r in rs: if self.id == r.map.id: return True return False def object_id(self): return ("qos-map-%d" % (self.id)) class VppQosMark(VppObject): """ QoS Mark(ing) configuration """ def __init__(self, test, intf, map, source): self._test = test self.intf = intf self.source = source self.map = map def add_vpp_config(self): self._test.vapi.qos_mark_enable_disable( enable=1, mark={'sw_if_index': self.intf.sw_if_index, 'map_id': self.map.id, 'output_source': self.source}) self._test.registry.register(self, self._test.logger) return self def remove_vpp_config(self): self._test.vapi.qos_mark_enable_disable( enable=0, mark={'sw_if_index': self.intf.sw_if_index, 'output_source': self.source}) def query_vpp_config(self): ms = self._test.vapi.qos_mark_dump() for m in ms: if self.intf.sw_if_index == m.mark.sw_if_index and \ self.source == m.mark.output_source and \ self.map.id == m.mark.map_id: return True return False def object_id(self): return ("qos-mark-%s-%d" % (self.intf, self.source))


context:
space:
mode: