Unhandled missing peer

7 years ago · c979481564
parent ba130e03e5
commit c979481564
1 changed files with 1 additions and 1 deletions
--- a/src/inventory.py
+++ b/src/inventory.py
@ -184,7 +184,7 @@ class PendingDownload(object):
                self.pending[current_thread().peer]['received'] = time.time()
        for thread in self.pending.keys():
            with self.lock:
-                if objectHash in self.pending[thread]['objects']:
+                if thread in self.pending and objectHash in self.pending[thread]['objects']:
                    self.pending[thread]['objects'].remove(objectHash)

    def stop(self):