fix in self.ana_grp_subs_load

 dump ana_grp_subs load post mortem
Signed-off-by: Leonid Chernin <[email protected]>

Author: leonidc

control/grpc.py

@@ -2219,13 +2219,14 @@ def create_namespace(self, subsystem_nqn, bdev_name, nsid, anagrpid, uuid,
                                                             location)
             self.logger.debug(f"subsystem_add_ns: {nsid}")
             self.ana_grp_ns_load[anagrpid] += 1
-            if anagrpid in self.ana_grp_subs_load:
-                if subsystem_nqn in self.ana_grp_subs_load[anagrpid]:
-                    self.ana_grp_subs_load[anagrpid][subsystem_nqn] += 1
-                else:
-                    self.ana_grp_subs_load[anagrpid][subsystem_nqn] = 1
+            if anagrpid not in self.ana_grp_subs_load:
+                self.ana_grp_subs_load[anagrpid] = {}
+
+            if subsystem_nqn in self.ana_grp_subs_load[anagrpid]:
+                self.ana_grp_subs_load[anagrpid][subsystem_nqn] += 1
             else:
                 self.ana_grp_subs_load[anagrpid][subsystem_nqn] = 1
+            self.logger.info(f"dump self.ana_grp_subs:  {self.ana_grp_subs_load}")
         except Exception as ex:
             self.logger.exception(add_namespace_error_prefix)
             errmsg = f"{add_namespace_error_prefix}:\n{ex}"
@@ -2641,14 +2642,21 @@ def namespace_change_load_balancing_group_safe(self, request, context):
                                       error_message=change_lb_group_failure_prefix)
             # change LB success - need to update the data structures
             self.ana_grp_ns_load[anagrpid] -= 1   # decrease loading of previous "old" ana group
-            self.ana_grp_subs_load[anagrpid][request.subsystem_nqn] -= 1
+            try:
+                self.ana_grp_subs_load[anagrpid][request.subsystem_nqn] -= 1
+            except Exception as ex:
+                self.logger.error(f"entry does not exist in ana_grp_subs_load array: ANA grp:"
+                                  f" {anagrpid} nqn: {request.subsystem_nqn} {ex} ")
+                # Dump all entries
+                self.logger.info(f"dump self.ana_grp_subs:  {self.ana_grp_subs_load}")
+                assert False, "ana_grp_subs_load dictionary should be initialized"
+
             self.logger.debug(f"updated load in grp {anagrpid} = {self.ana_grp_ns_load[anagrpid]} ")
             self.ana_grp_ns_load[request.anagrpid] += 1
-            if request.anagrpid in self.ana_grp_subs_load:
-                if request.subsystem_nqn in self.ana_grp_subs_load[request.anagrpid]:
-                    self.ana_grp_subs_load[request.anagrpid][request.subsystem_nqn] += 1
-                else:
-                    self.ana_grp_subs_load[request.anagrpid][request.subsystem_nqn] = 1
+            if request.anagrpid not in self.ana_grp_subs_load:
+                self.ana_grp_subs_load[request.anagrpid] = {}
+            if request.subsystem_nqn in self.ana_grp_subs_load[request.anagrpid]:
+                self.ana_grp_subs_load[request.anagrpid][request.subsystem_nqn] += 1
             else:
                 self.ana_grp_subs_load[request.anagrpid][request.subsystem_nqn] = 1
             self.logger.debug(f"updated load in grp {request.anagrpid} = "