X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=khashmir.py;h=390d8a9dcb0a458c47e40a66af7c4c286572a3fb;hb=7d427317cab577b54ab377100fdce5dc7d5366dc;hp=03c67abba0db736ac2b9f26a8989a43c1f63c384;hpb=8af8fd84094b75c0a37a3b17a2b63d6db2c42563;p=quix0rs-apt-p2p.git diff --git a/khashmir.py b/khashmir.py index 03c67ab..390d8a9 100644 --- a/khashmir.py +++ b/khashmir.py @@ -130,7 +130,7 @@ class Khashmir(xmlrpc.XMLRPC): def default(err, node=node, table=table): table.nodeFailed(node) df = node.storeValue(key, value, self.node.senderDict()) - df.addCallback(cb) + df.addCallbacks(cb, lambda x: None) # this call is asynch self.findNode(key, _storeValueForKey) @@ -155,9 +155,6 @@ class Khashmir(xmlrpc.XMLRPC): def _notStaleNodeHandler(sender, old=old): """ called when we get a pong from the old node """ - sender, conn = sender - if conn['host']: - sender['host'] = conn['host'] sender = Node().initWithDict(sender) if sender.id == old.id: self.table.justSeenNode(old)