X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=apt_p2p_Khashmir%2Factions.py;h=bd1cd2f6f1905672717b1b90e0358040afbdf8e9;hb=ebdcf9bd3a4caeb295c3b4f0776af5d16a21982b;hp=fd5e1c1ade8d2122cfe6f6de0bcbae66e027a8c0;hpb=aa0f99580b06354d1affbef134d5763b534026b6;p=quix0rs-apt-p2p.git diff --git a/apt_p2p_Khashmir/actions.py b/apt_p2p_Khashmir/actions.py index fd5e1c1..bd1cd2f 100644 --- a/apt_p2p_Khashmir/actions.py +++ b/apt_p2p_Khashmir/actions.py @@ -186,7 +186,7 @@ class ActionBase: def gotResponse(self, dict, node, expected_results, df): """Receive a response from a remote node.""" - self.caller.insertNode(node) + reactor.callLater(0, self.caller.insertNode, node) if self.finished or self.answered.has_key(node.id): # a day late and a dollar short return @@ -198,8 +198,7 @@ class ActionBase: def actionFailed(self, err, node, expected_results, df): """Receive an error from a remote node.""" - log.msg("action %s failed (%s) %s/%s" % (self.action, self.config['PORT'], node.host, node.port)) - log.err(err) + log.msg("action %s failed on %s/%s: %s" % (self.action, node.host, node.port, err.getErrorMessage())) self.caller.table.nodeFailed(node) self.outstanding -= 1 self.outstanding_results -= expected_results