Skip to content

Commit

Permalink
Merge pull request #1002 from leonidc/debug_update_state
Browse files Browse the repository at this point in the history
debug update state
  • Loading branch information
leonidc authored Jan 2, 2025
2 parents 0db728a + f09a67e commit 985e750
Showing 1 changed file with 7 additions and 6 deletions.
13 changes: 7 additions & 6 deletions control/state.py
Original file line number Diff line number Diff line change
Expand Up @@ -595,7 +595,7 @@ def _add_key(self, key: str, val: str):
(str(version_update),))
self.ioctx.operate_write_op(write_op, self.omap_name)
self.version = version_update
self.logger.debug(f"omap_key generated: {key}")
self.logger.info(f"omap_key generated: {key}, OMAP version: {version_update}")
except Exception:
self.logger.exception("Unable to add key to OMAP, exiting!")
raise
Expand Down Expand Up @@ -1047,9 +1047,11 @@ def update(self) -> bool:
omap_version = int(omap_state_dict[self.omap.OMAP_VERSION_KEY])
local_version = self.omap.get_local_version()

self.logger.info(f"Check local version {local_version} against OMAP version "
f"{omap_version}")
if local_version < omap_version:
self.logger.debug(f"Start update from {local_version} to "
f"{omap_version} ({self.id_text}).")
self.logger.info(f"Start update from {local_version} to {omap_version} "
f"({self.id_text}).")
local_state_dict = self.local.get_state()
local_state_keys = local_state_dict.keys()
omap_state_keys = omap_state_dict.keys()
Expand Down Expand Up @@ -1242,9 +1244,8 @@ def update(self) -> bool:
# Update local state and version
self.local.reset(omap_state_dict)
self.omap.set_local_version(omap_version)
self.logger.debug(f"Update complete ({local_version} -> "
f"{omap_version}) ({self.id_text}).")

self.logger.info(f"Update complete ({local_version} -> {omap_version}) "
f"({self.id_text}).")
return True

def _group_by_prefix(self, state_update, prefix_list):
Expand Down

0 comments on commit 985e750

Please sign in to comment.