from twisted.internet.defer import Deferred
from xmlrpcclient import XMLRPCClientFactory as factory
from const import reactor
+from xmlrpclib import Binary
class KNode(Node):
def ping(self, sender):
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