def __init__(self, cfg, target=None, args=[]):
(self.target,self.args) = (target,args)
# Set up server socket
self.context = zmq.Context()
self.socket = self.context.socket(zmq.ROUTER)
self.port = self.socket.bind_to_random_port('tcp://*', min_port=cfg["port_min"], max_port=cfg["port_max"], max_tries=100)
self.uri = "tcp://127.0.0.1:%d"%(self.port)
print "Controller listening on %s"%(self.uri)
self.start()
评论列表
文章目录