def __init__(self):
super(EtcdAgentCommunicator, self).__init__()
self.etcd_client = etcd.Client() # TODO(ijw): give this args
# We need certain directories to exist
self.do_etcd_mkdir(LEADIN + '/state')
self.do_etcd_mkdir(LEADIN + '/nodes')
# TODO(ijw): .../state/<host> lists all known hosts, and they
# heartbeat when they're functioning
# Get the physnets the agents know about. This is updated
# periodically in the return thread below.
self.physical_networks = set()
self._find_physnets()
self.db_q_ev = eventlet.event.Event()
self.return_thread = eventlet.spawn(self._return_worker)
self.forward_thread = eventlet.spawn(self._forward_worker)
评论列表
文章目录