From 02e4a8c7ffb3dbcd4f5232c94b49a0caed43ac1b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philippe=20P=2E=20Pe=CC=81bay=CC=88?= Date: Sat, 10 Jun 2023 17:42:31 -0400 Subject: [PATCH] #323: fixed debug statement --- src/lbaf/Execution/lbsInformAndTransferAlgorithm.py | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/src/lbaf/Execution/lbsInformAndTransferAlgorithm.py b/src/lbaf/Execution/lbsInformAndTransferAlgorithm.py index 05f7c9179..82cb0c1c7 100644 --- a/src/lbaf/Execution/lbsInformAndTransferAlgorithm.py +++ b/src/lbaf/Execution/lbsInformAndTransferAlgorithm.py @@ -123,19 +123,17 @@ def __information_stage(self): messages.setdefault(r_rcv, []).append(msg) # Process all messages of first round - print(self.__known_peers) for r_rcv, m_rcv in messages.items(): - print(r_rcv, ":") for m in m_rcv: # Process message by recipient self.__known_peers[r_rcv].update(m.get_support()) # Report on gossiping status when requested - for p in rank_set: - self._logger.debug( - f"information known to rank {p.get_id()}: " - f"{[p_u.get_id() for p_u in p.get_known_loads()]}") - + for r in rank_set: + self._logger.info( + f"peers known to rank {r.get_id()}: " + f"{[r_k.get_id() for r_k in self.__known_peers.get(r, {})]}") + sys.exit(1) # Forward messages for as long as necessary and requested for i in range(1, self.__n_rounds): # Initiate next information round