Vous avez reçu un message "Your GitLab account has been locked ..." ? Pas d'inquiétude : lisez cet article https://docs.gricad-pages.univ-grenoble-alpes.fr/help/unlock/

Commit 41857d87 authored by Thomas Lavocat's avatar Thomas Lavocat
Browse files

Patch, important bug

parent 0762f775
...@@ -130,7 +130,8 @@ class Erebor: ...@@ -130,7 +130,8 @@ class Erebor:
# TODO # TODO
def send_mpi_trans_network_message_to(self, mpi_dnode, dnetowkrId, mpi_snode, def send_mpi_trans_network_message_to(self, mpi_dnode, dnetowkrId, mpi_snode,
snetworkId, m): snetworkId, m):
logger.info("send mpi trans_network") logger.info("send mpi trans_network, from {}@{} to {}@{}".format(
mpi_snode, snetworkId, mpi_dnode, dnetowkrId));
gateway_network = None gateway_network = None
neighbour_gateway = None neighbour_gateway = None
# if we have a gateway to send the message # if we have a gateway to send the message
...@@ -157,13 +158,14 @@ class Erebor: ...@@ -157,13 +158,14 @@ class Erebor:
if neighbour_gateway.networkId == dnetowkrId : if neighbour_gateway.networkId == dnetowkrId :
# get the corresponding network to find the node to send # get the corresponding network to find the node to send
network = self.networks.get(dnetowkrId) network = self.networks.get(dnetowkrId)
# find the taktuk_dnode corresponding to mpi_dnode logger.debug("{}, {}".format(dnetowkrId, network))
logger.debug(self.mpi_routing_table[network].keys())
# if i'm the root of this network i can take a decision about # if i'm the root of this network i can take a decision about
# where to send the message. Otherwise I need to send it to the # where to send the message. Otherwise I need to send it to the
# root of the group, he'll know what to do. # root of the group, he'll know what to do.
if network.rank == "0" : if network.rank == "0" :
logger.debug("i'm rank 0 i can take a decision") logger.debug("i'm rank 0 i can take a decision")
# find the taktuk_dnode corresponding to mpi_dnode
logger.debug(self.mpi_routing_table[network].keys())
if mpi_dnode in self.mpi_routing_table[network] : if mpi_dnode in self.mpi_routing_table[network] :
dnode = self.mpi_routing_table[network][mpi_dnode] dnode = self.mpi_routing_table[network][mpi_dnode]
logger.debug("MPI TRANS-NETWORK for mpi{}@{}, gateway {}@{}".format( logger.debug("MPI TRANS-NETWORK for mpi{}@{}, gateway {}@{}".format(
......
...@@ -34,6 +34,7 @@ class MPIHook(Thread) : ...@@ -34,6 +34,7 @@ class MPIHook(Thread) :
# A context per thread # A context per thread
context = zmq.Context() context = zmq.Context()
rep_socket = context.socket(zmq.PULL) rep_socket = context.socket(zmq.PULL)
logger.debug(consts.bold("mpi -> Deploying, ussing port {} is IPC ? {}".format(self.port, self.is_ipc)))
if self.is_ipc : if self.is_ipc :
rep_socket.bind("ipc:///tmp/{}".format(self.port)) rep_socket.bind("ipc:///tmp/{}".format(self.port))
else : else :
......
Markdown is supported
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