X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=knode.py;h=3e32ce83409aebffe04eec98f17b5dec1533e508;hb=32f5f5669ceb11c4c951ed9bc9cd0f992b15817d;hp=aecf14e4aa753b3e88ab8c64c108426f1772f92e;hpb=36db2c1145e5e21b360d17854bb54248fbd12299;p=quix0rs-apt-p2p.git diff --git a/knode.py b/knode.py index aecf14e..3e32ce8 100644 --- a/knode.py +++ b/knode.py @@ -2,8 +2,10 @@ from node import Node from twisted.internet.defer import Deferred from xmlrpcclient import XMLRPCClientFactory as factory from const import reactor +from xmlrpclib import Binary -class KNode(Node): + +class KNode(Node): def ping(self, sender): df = Deferred() f = factory('ping', (sender,), df.callback, df.errback) @@ -11,16 +13,16 @@ class KNode(Node): return df def findNode(self, target, sender): df = Deferred() - f = factory('find_node', (target, sender), df.callback, df.errback) + f = factory('find_node', (Binary(target), sender), df.callback, df.errback) reactor.connectTCP(self.host, self.port, f) return df def storeValue(self, key, value, sender): df = Deferred() - f = factory('store_value', (key, value, sender), df.callback, df.errback) + f = factory('store_value', (Binary(key), Binary(value), sender), df.callback, df.errback) reactor.connectTCP(self.host, self.port, f) return df def findValue(self, key, sender): df = Deferred() - f = factory('find_value', (key, sender), df.callback, df.errback) + f = factory('find_value', (Binary(key), sender), df.callback, df.errback) reactor.connectTCP(self.host, self.port, f) return df