]> git.mxchange.org Git - quix0rs-apt-p2p.git/blobdiff - knode.py
fix bug in pong handler
[quix0rs-apt-p2p.git] / knode.py
index aecf14e4aa753b3e88ab8c64c108426f1772f92e..8a38462e46430bdb20ee96c02212c73312475334 100644 (file)
--- 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):
        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