2 from twisted.internet.defer import Deferred
3 from xmlrpcclient import XMLRPCClientFactory as factory
4 from const import reactor
7 def ping(self, sender):
9 f = factory('ping', (sender,), df.callback, df.errback)
10 reactor.connectTCP(self.host, self.port, f)
12 def findNode(self, target, sender):
14 f = factory('find_node', (target, sender), df.callback, df.errback)
15 reactor.connectTCP(self.host, self.port, f)
17 def storeValue(self, key, value, sender):
19 f = factory('store_value', (key, value, sender), df.callback, df.errback)
20 reactor.connectTCP(self.host, self.port, f)
22 def findValue(self, key, sender):
23 f = factory('find_value', (key, sender), df.callback, df.errback)
24 reactor.connectTCP(self.host, self.port, f)