273be0d5affb7d9f3367b1e01dc3abc3b790a73e,service/server.py,BertServer,__init__,#BertServer#Any#,26

Before Change

        self.logger = set_logger("VENTILATOR")

        self.pending_client = {}
        self.pending_checksum = {}

    def close(self):
        self.logger.info("shutting down...")
        for p in self.processes:

After Change

        self.frontend.bind("tcp://*:%d" % self.port)

        // pair connection between frontend and sink
        self.sink = self.context.socket(zmq.PAIR)
        self.sink.bind("ipc://*")

        // backend facing workers
        self.backend = self.context.socket(zmq.PUSH)

Instances