Commit 01d2e533 authored by EXT tlavocat's avatar EXT tlavocat
Browse files

Log improvement

parent 95d03393
......@@ -366,7 +366,7 @@ class Isengard:
def _connector_error(self, txt):
self.spawned_lock.acquire()
arguments = txt.split("connector:")[1].split(";")
#self.flushprint(arguments)
#self.flushprint(consts.bold("connector error "+arguments))
if "Possible precedence issue with control " not in arguments[2] :
sp_node, index = self.get_wait_spawned(arguments[PEER])
if index > -1 :
......@@ -410,7 +410,9 @@ class Isengard:
return list(self.error_nodes_s)
def get_wait_spawned(self, name) :
#self.flushprint("get wait spawn {}".format(name))
for i in range(0, len(self.wait_spawn)) :
#self.flushprint("spawn {}".format(name))
if self.wait_spawn[i].name == name :
return self.wait_spawn[i], i
return None, -1
......@@ -616,18 +618,20 @@ class Isengard:
def spawn_nodes(self, dest, nodes, synch, taktuk=True):
self.spawned_lock.acquire()
#self.log_time("spawn request received")
#self.flushprint("spawn request received")
# parse the asked nodes following those rules :
for node in self.helper.build_list(nodes) :
# create an object to follow the updates of the node
sp_node = Spawned(node)
self.wait_spawn.append(sp_node)
# self.flushprint("add node {}".format(node))
# add the nodes to the wait_start_list, this list will be used to
# propagate the state information.
self.to_wait_start = len(self.wait_spawn)
#self.flushprint("lock release {}".format(len(self.wait_spawn)))
self.spawned_lock.release()
self.final_spawn_nodes(dest, nodes, synch, taktuk)
#self.log_time("spawn request send to taktuk")
#self.flushprint("spawn request send to taktuk")
def final_spawn_nodes(self, dest, nodes, synch, taktuk=True):
if taktuk :
......
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