file_juggler.py 文件源码

def __init__(self, config):
        super().__init__(config)
        self.output_path = Path(config.output_path)
        TransferState.output_path = self.output_path
        file_queue = self.ctx.socket(zmq.ROUTER)
        file_queue.ipv6 = True
        file_queue.hwm = TransferState.pipeline_size * 50
        file_queue.bind(config.file_queue)
        fs_queue = self.ctx.socket(zmq.REP)
        fs_queue.hwm = 1
        fs_queue.bind(config.fs_queue)
        self.register(file_queue, self.handle_file)
        self.register(fs_queue, self.handle_fs_request)
        self.pending = {}   # keyed by slave_id
        self.active = {}    # keyed by slave address
        self.complete = {}  # keyed by slave_id