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 from xmlrpclib import Binary
   6
   7
   8 class KNode(Node):
   9     def ping(self, sender):
  10         df = Deferred()
  11         f = factory('ping', (sender,), df.callback, df.errback)
  12         reactor.connectTCP(self.host, self.port, f)
  13         return df
  14     def findNode(self, target, sender):
  15         df = Deferred()
  16         f = factory('find_node', (Binary(target), sender), df.callback, df.errback)
  17         reactor.connectTCP(self.host, self.port, f)
  18         return df
  19     def storeValue(self, key, value, sender):
  20         df = Deferred()
  21         f = factory('store_value', (Binary(key), Binary(value), sender), df.callback, df.errback)
  22         reactor.connectTCP(self.host, self.port, f)
  23         return df
  24     def findValue(self, key, sender):
  25         df = Deferred()
  26         f = factory('find_value', (Binary(key), sender), df.callback, df.errback)
  27         reactor.connectTCP(self.host, self.port, f)
  28         return df