[debug dump util] portchannel module added

dump/plugins/portchannel.py

@@ -0,0 +1,131 @@
+from dump.match_infra import MatchRequest
+from dump.helper import create_template_dict
+from .executor import Executor
+
+
+class PortChannel(Executor):
+    """
+    Debug Dump Plugin for PortChannel/LAG Module
+    """
+    ARG_NAME = "portchannel_name"
+
+    def __init__(self, match_engine=None):
+        super().__init__(match_engine)
+        self.ret_temp = {}
+        self.ns = ''
+        self.lag_members = set()
+
+    def get_all_args(self, ns=""):
+        req = MatchRequest(db="CONFIG_DB", table="PORTCHANNEL", key_pattern="*", ns=ns)
+        ret = self.match_engine.fetch(req)
+        all_lags = ret["keys"]
+        return [key.split("|")[-1] for key in all_lags]
+
+    def execute(self, params_dict):
+        self.ret_temp = create_template_dict(dbs=["CONFIG_DB", "APPL_DB", "ASIC_DB", "STATE_DB"])
+        self.lag_name = params_dict[PortChannel.ARG_NAME]
+        self.ns = params_dict["namespace"]
+        # CONFIG_DB
+        lag_found = self.init_lag_config_info()
+        if lag_found:
+            self.init_lag_member_config_info()
+        # APPL_DB
+        lag_found_appl = self.init_lag_appl_info()
+        if lag_found or lag_found_appl:
+            self.init_lag_member_appl_info()
+        # STATE_DB
+        lag_found_state = self.init_lag_state_info()
+        if lag_found or lag_found_appl or lag_found_state:
+            self.init_lag_member_state_info()
+        # ASIC_DB
+        lag_type_objs_asic = self.init_lag_member_type_obj_asic_info()
+        self.init_lag_asic_info(lag_type_objs_asic)
+        return self.ret_temp
+
+    def add_to_ret_template(self, table, db, keys, err):
+        if not err and keys:
+            self.ret_temp[db]["keys"].extend(keys)
+            return True
+        else:
+            self.ret_temp[db]["tables_not_found"].extend([table])
+            return False
+
+    def init_lag_config_info(self):
+        req = MatchRequest(db="CONFIG_DB", table="PORTCHANNEL", key_pattern=self.lag_name, ns=self.ns)
+        ret = self.match_engine.fetch(req)
+        return self.add_to_ret_template(req.table, req.db, ret["keys"], ret["error"])
+
+    def init_lag_member_config_info(self):
+        req = MatchRequest(db="CONFIG_DB", table="PORTCHANNEL_MEMBER", key_pattern=self.lag_name + "|*", ns=self.ns)
+        ret = self.match_engine.fetch(req)
+        for key in ret["keys"]:
+            self.lag_members.add(key.split("|")[-1])
+        self.add_to_ret_template(req.table, req.db, ret["keys"], ret["error"])
+
+    def init_lag_appl_info(self):
+        req = MatchRequest(db="APPL_DB", table="LAG_TABLE", key_pattern=self.lag_name, ns=self.ns)
+        ret = self.match_engine.fetch(req)
+        return self.add_to_ret_template(req.table, req.db, ret["keys"], ret["error"])
+
+    def init_lag_member_appl_info(self):
+        req = MatchRequest(db="APPL_DB", table="LAG_MEMBER_TABLE", key_pattern=self.lag_name + ":*", ns=self.ns)
+        ret = self.match_engine.fetch(req)
+        for key in ret["keys"]:
+            self.lag_members.add(key.split(":")[-1])
+        self.add_to_ret_template(req.table, req.db, ret["keys"], ret["error"])
+
+    def init_lag_state_info(self):
+        req = MatchRequest(db="STATE_DB", table="LAG_TABLE", key_pattern=self.lag_name, ns=self.ns)
+        ret = self.match_engine.fetch(req)
+        return self.add_to_ret_template(req.table, req.db, ret["keys"], ret["error"])
+
+    def init_lag_member_state_info(self):
+        req = MatchRequest(db="STATE_DB", table="LAG_MEMBER_TABLE", key_pattern=self.lag_name + "|*", ns=self.ns)
+        ret = self.match_engine.fetch(req)
+        for key in ret["keys"]:
+            self.lag_members.add(key.split("|")[-1])
+        self.add_to_ret_template(req.table, req.db, ret["keys"], ret["error"])
+
+    def init_lag_asic_info(self, lag_type_objs_asic):
+        if len(lag_type_objs_asic) == 0:
+            self.ret_temp["ASIC_DB"]["tables_not_found"].extend(["ASIC_STATE:SAI_OBJECT_TYPE_LAG"])
+            return
+        for lag_asic_obj in lag_type_objs_asic:
+            req = MatchRequest(db="ASIC_DB", table="ASIC_STATE:SAI_OBJECT_TYPE_LAG", key_pattern=lag_asic_obj, ns=self.ns)
+            ret = self.match_engine.fetch(req)
+            self.add_to_ret_template(req.table, req.db, ret["keys"], ret["error"])
+
+    def init_lag_member_type_obj_asic_info(self):
+        lag_type_objs_asic = set()
+        for port_name in self.lag_members:
+            port_asic_obj = self.get_port_asic_obj(port_name)
+            if port_asic_obj:
+                lag_member_key, lag_oid = self.get_lag_and_member_obj(port_asic_obj)
+                self.add_to_ret_template("ASIC_STATE:SAI_OBJECT_TYPE_LAG_MEMBER", "ASIC_DB", [lag_member_key], "")
+                lag_type_objs_asic.add(lag_oid)
+        if not lag_type_objs_asic:
+            self.ret_temp["ASIC_DB"]["tables_not_found"].extend(["ASIC_STATE:SAI_OBJECT_TYPE_LAG_MEMBER"])
+        return lag_type_objs_asic
+
+    def get_port_asic_obj(self, port_name):
+        req = MatchRequest(db="ASIC_DB", table="ASIC_STATE:SAI_OBJECT_TYPE_HOSTIF", key_pattern="*", field="SAI_HOSTIF_ATTR_NAME",
+                           value=port_name, return_fields=["SAI_HOSTIF_ATTR_OBJ_ID"], ns=self.ns)
+        ret = self.match_engine.fetch(req)
+        asic_port_obj_id = ""
+        if not ret["error"] and ret["keys"]:
+            sai_hostif_obj_key = ret["keys"][-1]
+            if sai_hostif_obj_key in ret["return_values"] and "SAI_HOSTIF_ATTR_OBJ_ID" in ret["return_values"][sai_hostif_obj_key]:
+                asic_port_obj_id = ret["return_values"][sai_hostif_obj_key]["SAI_HOSTIF_ATTR_OBJ_ID"]
+        return asic_port_obj_id
+
+    def get_lag_and_member_obj(self, port_asic_obj):
+        req = MatchRequest(db="ASIC_DB", table="ASIC_STATE:SAI_OBJECT_TYPE_LAG_MEMBER", key_pattern="*", field="SAI_LAG_MEMBER_ATTR_PORT_ID",
+                           value=port_asic_obj, return_fields=["SAI_LAG_MEMBER_ATTR_LAG_ID"], ns=self.ns)
+        ret = self.match_engine.fetch(req)
+        lag_member_key = ""
+        lag_oid = ""
+        if not ret["error"] and ret["keys"]:
+            lag_member_key = ret["keys"][-1]
+            if lag_member_key in ret["return_values"] and "SAI_LAG_MEMBER_ATTR_LAG_ID" in ret["return_values"][lag_member_key]:
+                lag_oid = ret["return_values"][lag_member_key]["SAI_LAG_MEMBER_ATTR_LAG_ID"]
+        return lag_member_key, lag_oid

tests/dump_input/portchannel/appl_db.json

@@ -0,0 +1,18 @@
+{	
+	"LAG_TABLE:PortChannel002": {
+        	"oper_status": "up",
+        	"mtu": "9100",
+        	"admin_status": "up"
+	},
+	"LAG_TABLE:PortChannel001": {
+        	"oper_status": "up",
+        	"mtu": "9100",
+        	"admin_status": "up"
+	},
+	"LAG_MEMBER_TABLE:PortChannel001:Ethernet4": {
+                "status": "enabled"
+        },
+	"LAG_MEMBER_TABLE:PortChannel001:Ethernet0": {
+                "status": "enabled"
+        }
+}

tests/dump_input/portchannel/asic_db.json

@@ -0,0 +1,34 @@
+{
+	"ASIC_STATE:SAI_OBJECT_TYPE_LAG:oid:0x2000000000d17":{
+		"SAI_LAG_ATTR_PORT_VLAN_ID": "1"
+	},
+	"ASIC_STATE:SAI_OBJECT_TYPE_LAG:oid:0x20000000004d3": { 
+		"NULL": "NULL"
+	},
+	"ASIC_STATE:SAI_OBJECT_TYPE_LAG_MEMBER:oid:0x1b000000000d18": {
+	    "SAI_LAG_MEMBER_ATTR_EGRESS_DISABLE": "false", 
+	    "SAI_LAG_MEMBER_ATTR_INGRESS_DISABLE": "false", 
+	    "SAI_LAG_MEMBER_ATTR_LAG_ID": "oid:0x2000000000d17", 
+	    "SAI_LAG_MEMBER_ATTR_PORT_ID": "oid:0x10000000002cc"
+	},
+	"ASIC_STATE:SAI_OBJECT_TYPE_LAG_MEMBER:oid:0x1b000000000d1a": {
+	    "SAI_LAG_MEMBER_ATTR_EGRESS_DISABLE": "false", 
+	    "SAI_LAG_MEMBER_ATTR_INGRESS_DISABLE": "false", 
+	    "SAI_LAG_MEMBER_ATTR_LAG_ID": "oid:0x2000000000d17", 
+	    "SAI_LAG_MEMBER_ATTR_PORT_ID": "oid:0x100000000093e"
+	},
+	"ASIC_STATE:SAI_OBJECT_TYPE_HOSTIF:oid:0xd000000000cdf": {
+	      "SAI_HOSTIF_ATTR_NAME": "Ethernet0", 
+	      "SAI_HOSTIF_ATTR_OBJ_ID": "oid:0x10000000002cc", 
+	      "SAI_HOSTIF_ATTR_OPER_STATUS": "true", 
+	      "SAI_HOSTIF_ATTR_TYPE": "SAI_HOSTIF_TYPE_NETDEV", 
+	      "SAI_HOSTIF_ATTR_VLAN_TAG": "SAI_HOSTIF_VLAN_TAG_STRIP"
+	},
+	"ASIC_STATE:SAI_OBJECT_TYPE_HOSTIF:oid:0xd000000000acd": {
+	      "SAI_HOSTIF_ATTR_NAME": "Ethernet4", 
+	      "SAI_HOSTIF_ATTR_OBJ_ID": "oid:0x100000000093e", 
+	      "SAI_HOSTIF_ATTR_OPER_STATUS": "true", 
+	      "SAI_HOSTIF_ATTR_TYPE": "SAI_HOSTIF_TYPE_NETDEV", 
+	      "SAI_HOSTIF_ATTR_VLAN_TAG": "SAI_HOSTIF_VLAN_TAG_STRIP"
+	}
+}

tests/dump_input/portchannel/config_db.json

@@ -0,0 +1,26 @@
+{
+        "PORTCHANNEL|PortChannel001": {
+	  "admin_status": "up",
+	  "lacp_key": "auto",
+	  "min_links": "1",
+	  "mtu": "9100"
+	},
+	"PORTCHANNEL|PortChannel002": {
+	  "admin_status": "up",
+	  "lacp_key": "auto",
+	  "min_links": "1",
+	  "mtu": "9100"
+	},
+	"PORTCHANNEL|PortChannel003": {
+	  "admin_status": "up",
+	  "lacp_key": "auto",
+	  "min_links": "1",
+	  "mtu": "9100"
+	},
+	"PORTCHANNEL_MEMBER|PortChannel001|Ethernet0": {
+		"NULL" : "NULL"
+	},
+	"PORTCHANNEL_MEMBER|PortChannel001|Ethernet4": {
+		"NULL" : "NULL"
+	}
+}

tests/dump_input/portchannel/state_db.json

@@ -0,0 +1,54 @@
+{
+	"LAG_TABLE|PortChannel001":{
+	    "runner.active": "true",
+	    "runner.fallback": "false",
+	    "runner.fast_rate": "false",
+	    "setup.kernel_team_mode_name": "loadbalance",
+	    "setup.pid": "27",
+	    "state": "ok",
+	    "team_device.ifinfo.dev_addr": "1c:34:da:1c:9f:00",
+	    "team_device.ifinfo.ifindex": "137"
+	},
+	"LAG_TABLE|PortChannel002":{
+	    "runner.active": "true",
+	    "runner.fallback": "false",
+	    "runner.fast_rate": "false",
+	    "setup.kernel_team_mode_name": "loadbalance",
+	    "setup.pid": "35",
+	    "state": "ok",
+	    "team_device.ifinfo.dev_addr": "1c:34:da:1c:9f:00",
+	    "team_device.ifinfo.ifindex": "138"
+	},
+	"LAG_MEMBER_TABLE|PortChannel001|Ethernet4":{
+	      "ifinfo.dev_addr": "1c:34:da:1c:9f:00",
+	      "ifinfo.ifindex": "203",
+	      "link.up": "true",
+	      "link_watches.list.link_watch_0.up": "true",
+	      "runner.actor_lacpdu_info.port": "5",
+	      "runner.actor_lacpdu_info.state": "69",
+	      "runner.actor_lacpdu_info.system": "1c:34:da:1c:9f:00",
+	      "runner.aggregator.id": "0",
+	      "runner.aggregator.selected": "false",
+	      "runner.partner_lacpdu_info.port": "0",
+	      "runner.partner_lacpdu_info.state": "2",
+	      "runner.partner_lacpdu_info.system": "00:00:00:00:00:00",
+	      "runner.selected": "false",
+	      "runner.state": "defaulted"
+	},
+	"LAG_MEMBER_TABLE|PortChannel001|Ethernet0":{
+	      "ifinfo.dev_addr": "1c:34:da:1c:9f:00",
+	      "ifinfo.ifindex": "202",
+	      "link.up": "true",
+	      "link_watches.list.link_watch_0.up": "true",
+	      "runner.actor_lacpdu_info.port": "0",
+	      "runner.actor_lacpdu_info.state": "69",
+	      "runner.actor_lacpdu_info.system": "1c:34:da:1c:9f:00",
+	      "runner.aggregator.id": "0",
+	      "runner.aggregator.selected": "false",
+	      "runner.partner_lacpdu_info.port": "0",
+	      "runner.partner_lacpdu_info.state": "2",
+	      "runner.partner_lacpdu_info.system": "00:00:00:00:00:00",
+	      "runner.selected": "false",
+	      "runner.state": "defaulted"
+	}
+}