X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=krpc.py;h=8a6009250e619f88606629d21c1d142ce61bad31;hb=51dba6a701591889484c97e978f609551dc58dd4;hp=1cf33d5478fe52df203c53e246521e2f44836ffe;hpb=3a8164f9c878f1c8af2958bc932ddfdb9f799a09;p=quix0rs-apt-p2p.git

diff --git a/krpc.py b/krpc.py
index 1cf33d5..8a60092 100644
--- a/krpc.py
+++ b/krpc.py
@@ -1,21 +1,16 @@
 ## Copyright 2002-2003 Andrew Loewenstern, All Rights Reserved
 # see LICENSE.txt for license information
 
-import airhook
-from twisted.internet.defer import Deferred
-from twisted.protocols import basic
 from bencode import bencode, bdecode
-from twisted.internet import protocol
-
-from twisted.internet import reactor
-import time
-
+from time import asctime
 import sys
 from traceback import format_exception
 
-import khash as hash
+from twisted.internet.defer import Deferred
+from twisted.internet import protocol
+from twisted.internet import reactor
 
-KRPC_TIMEOUT = 60
+KRPC_TIMEOUT = 20
 
 KRPC_ERROR = 1
 KRPC_ERROR_METHOD_UNKNOWN = 2
@@ -76,7 +71,6 @@ class KRPC:
         except Exception, e:
             if self.noisy:
                 print "response decode error: " + `e`
-            self.d.errback()
         else:
             #if self.noisy:
             #    print msg
@@ -113,7 +107,7 @@ class KRPC:
                     olen = len(out)
                     self.transport.write(out, addr)
                 if self.noisy:
-                    print "%s %s >>> %s - %s %s %s" % (time.asctime(), addr, self.factory.node.port, 
+                    print "%s %s >>> %s - %s %s %s" % (asctime(), addr, self.factory.node.port, 
                                                     ilen, msg[REQ], olen)
             elif msg[TYP] == RSP:
                 # if response