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
评论列表
文章目录