timeout_manager.py 文件源码

def __init__(self, tf_flags):
    self.tf_flags = tf_flags
    self.worker_id = self.tf_flags.task_id
    hosts = self.tf_flags.worker_hosts.split(",")
    hosts = [x.split(":")[0] for x in hosts]
    self.hosts = hosts
    self.self_perspective = None
    self.perspectives = []
    self.ready = False
    self.servers_ready = set([])

    for i, host in enumerate(hosts):
      #factory = pb.PBClientFactory()
      factory = TimeoutReconnectClientFactory()
      tf.logging.info("Connecting to %s:%d" % (host, self.tf_flags.rpc_port))
      reactor.connectTCP(host, self.tf_flags.rpc_port, factory)
      if i == self.worker_id:
        factory.getRootObject().addCallback(self.connected_self)
        #factory.getRootObject().addCallbacks(self.connected_self, self.connect_failure, errbackArgs=[host], errbackKeywords=[])
      else:
        factory.getRootObject().addCallback(self.connected)
        #factory.getRootObject().addCallbacks(self.connected, self.connect_failure, errbackArgs=[host], errbackKeywords=[])