Skip to content

Commit

Permalink
#323: fixed debug statement
Browse files Browse the repository at this point in the history
  • Loading branch information
ppebay committed Jun 10, 2023
1 parent 2c95103 commit 02e4a8c
Showing 1 changed file with 5 additions and 7 deletions.
12 changes: 5 additions & 7 deletions src/lbaf/Execution/lbsInformAndTransferAlgorithm.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 02e4a8c

Please sign in to comment.