Commit 988153f8 authored by Thomas Lavocat's avatar Thomas Lavocat
Browse files

Correct bug on waiting messages

parent 247e73a0
......@@ -178,9 +178,9 @@ class Erebor:
else :
logger.warning("need to buffer the message for later")
if mpi_dnode not in self.mpi_wait_route_msg :
self.mpi_wait_route_msg[mpi_dnode] = list()
self.mpi_wait_route_msg["{}@{}".format(mpi_dnode, dnetowkrId)] = list()
# buffer the message for later
self.mpi_wait_route_msg["{}@{}".format(mpi_dnode, dnetowkrId)].append([
mpi_dnode, dnetowkrId, mpi_snode,
snetworkId, m])
else :
......@@ -551,10 +551,10 @@ class Erebor:
rank = decoded_message[consts.RANK]
self.mpi_routing_table[network][rank] = local_from
if rank in self.mpi_wait_route_msg :
for message in self.mpi_wait_route_msg[rank] :
for message in self.mpi_wait_route_msg["{}@{}".format(rank, network)] :
message[1], message[2], message[3], message[4])
del self.mpi_wait_route_msg[rank]
del self.mpi_wait_route_msg["{}@{}".format(rank, network)]
# clean all registered mpi ranks associated with this network.
elif decoded_message[consts.ACTION] == consts.MPICLN :
on_network = self.networks.get(decoded_message[consts.NETWORK])
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment