agent.py 文件源码

def remote_setup(self, z):
                if(z == self.zonenum):
                        return

                else:
                        try:
                                Log.info("Connecting to Zone: " + str(z))
                                VIP = self.Config["modelnode_z"+str(z)] + "?serverkey=" + \
                    self.Config["serverkey_z"+str(z)] + "&publickey=" + \
                    ks.public + "&secretkey=" + ks.secret
                                event = gevent.event.Event()
                                node = Agent(address=VIP, enable_store=False, identity=self.Config["identity"])
                                node.core.onstart.connect(lambda *a, **kw: event.set(),event)
                                gevent.spawn(node.core.run)
                                event.wait(timeout=5)
                                self.platforms[z-1] = node
                self.platform_status[z-1] = 1

                        except gevent.Timeout:
                                Log.exception("Platform Connection Timeout")
                self.platform_status[z-1] = 0 #note that platform is down


    #Assert alive for leadership