X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=knode.py;h=8a38462e46430bdb20ee96c02212c73312475334;hb=7a5f05a857fe056bd4bd2cfe39a98ac19cd611ba;hp=66b8b5318d9c25e2425a0e0306e2c525e418708f;hpb=b142a7b2b4b8a8ddb037377b90b4fe3be9f79a47;p=quix0rs-apt-p2p.git

diff --git a/knode.py b/knode.py
index 66b8b53..8a38462 100644
--- a/knode.py
+++ b/knode.py
@@ -2,6 +2,7 @@ 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):
     def ping(self, sender):
@@ -16,11 +17,11 @@ class KNode(Node):
 	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):
-	f = factory('find_value', (key, sender), df.callback, df.errback)
-	reactor.connectTCP(self.host, self.port, f)
 	df = Deferred()
+	f = factory('find_value', (Binary(key), sender), df.callback, df.errback)
+	reactor.connectTCP(self.host, self.port, f)
 	return df