X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=apt_p2p_Khashmir%2Fkhashmir.py;h=13bfb5a23352f91d603168945d54d614c351fe3f;hb=8115337306f4d45abaf92719f05adab4d011851a;hp=f711a6a62a315964a339b03085d809079b0a2b6d;hpb=c14ca771c67c88699e7b4eb065d834976e4711ba;p=quix0rs-apt-p2p.git

diff --git a/apt_p2p_Khashmir/khashmir.py b/apt_p2p_Khashmir/khashmir.py
index f711a6a..13bfb5a 100644
--- a/apt_p2p_Khashmir/khashmir.py
+++ b/apt_p2p_Khashmir/khashmir.py
@@ -288,7 +288,11 @@ class KhashmirBase(protocol.Factory):
         """Error occurred, fail node."""
         log.msg("action ping failed on %s/%s: %s" % (node.host, node.port, err.getErrorMessage()))
         self.stats.completedAction('ping', start)
+        
+        # Consume unhandled errors
+        self.pinging[node.id].addErrback(lambda ping_err: None)
         del self.pinging[node.id]
+        
         self.nodeFailed(node)
         return err