fix args for ping()
This commit is contained in:
parent
fe2d6bad1b
commit
a942e6f3eb
1 changed files with 6 additions and 2 deletions
|
@ -382,9 +382,13 @@ class KademliaProtocol(protocol.DatagramProtocol):
|
|||
log.debug("DHT RECV CALL %s %s:%i", method, senderContact.address,
|
||||
senderContact.port)
|
||||
try:
|
||||
kwargs = {'_rpcNodeID': senderContact.id, '_rpcNodeContact': senderContact}
|
||||
result = func(*args, **kwargs)
|
||||
if method != 'ping':
|
||||
kwargs = {'_rpcNodeID': senderContact.id, '_rpcNodeContact': senderContact}
|
||||
result = func(*args, **kwargs)
|
||||
else:
|
||||
result = func()
|
||||
except Exception, e:
|
||||
log.exception("error handling request for %s: %s", senderContact.address, method)
|
||||
df.errback(e)
|
||||
else:
|
||||
df.callback(result)
|
||||
|
|
Loading…
Reference in a new issue