2 from twisted.internet.defer import Deferred
3 from xmlrpcclient import XMLRPCClientFactory as factory
4 from const import reactor
5 from xmlrpclib import Binary
9 def ping(self, sender):
11 f = factory('ping', (sender,), df.callback, df.errback)
12 reactor.connectTCP(self.host, self.port, f)
14 def findNode(self, target, sender):
16 f = factory('find_node', (Binary(target), sender), df.callback, df.errback)
17 reactor.connectTCP(self.host, self.port, f)
19 def storeValue(self, key, value, sender):
21 f = factory('store_value', (Binary(key), Binary(value), sender), df.callback, df.errback)
22 reactor.connectTCP(self.host, self.port, f)
24 def findValue(self, key, sender):
26 f = factory('find_value', (Binary(key), sender), df.callback, df.errback)
27 reactor.connectTCP(self.host, self.port, f)