slave_driver.py 文件源码

def __init__(self, config):
        super().__init__(config)
        self.paused = False
        slave_queue = self.ctx.socket(zmq.ROUTER)
        slave_queue.ipv6 = True
        slave_queue.bind(config.slave_queue)
        self.register(slave_queue, self.handle_slave)
        self.status_queue = self.ctx.socket(zmq.PUSH)
        self.status_queue.hwm = 10
        self.status_queue.connect(const.INT_STATUS_QUEUE)
        SlaveState.status_queue = self.status_queue
        self.builds_queue = self.ctx.socket(zmq.REQ)
        self.builds_queue.hwm = 1
        self.builds_queue.connect(config.builds_queue)
        self.index_queue = self.ctx.socket(zmq.PUSH)
        self.index_queue.hwm = 10
        self.index_queue.connect(config.index_queue)
        self.db = DbClient(config)
        self.fs = FsClient(config)
        self.slaves = {}
        self.pypi_simple = config.pypi_simple