knode.py

   1 from node import Node
   2 from twisted.internet.defer import Deferred
   3 from xmlrpcclient import XMLRPCClientFactory as factory
   4 from const import reactor
   5
   6 class KNode(Node):
   7     def ping(self, sender):
   8         df = Deferred()
   9         f = factory('ping', (sender,), df.callback, df.errback)
  10         reactor.connectTCP(self.host, self.port, f)
  11         return df
  12     def findNode(self, target, sender):
  13         df = Deferred()
  14         f = factory('find_node', (target, sender), df.callback, df.errback)
  15         reactor.connectTCP(self.host, self.port, f)
  16         return df
  17     def storeValue(self, key, value, sender):
  18         df = Deferred()
  19         f = factory('store_value', (key, value, sender), df.callback, df.errback)
  20         reactor.connectTCP(self.host, self.port, f)
  21         return df
  22     def findValue(self, key, sender):
  23         df = Deferred()
  24         f = factory('find_value', (key, sender), df.callback, df.errback)
  25         reactor.connectTCP(self.host, self.port, f)
  26         return df