367ee86aeea0dc510f01ce0ef58dc551d1d4d86b,service/server.py,BertSink,run,#BertSink#,148

Before Change

        self.receiver.bind("ipc://*")
        self.address = self.receiver.getsockopt(zmq.LAST_ENDPOINT).decode("ascii")

        client_checksum = {}
        pending_client = {}
        pending_checksum = {}

        while not self.exit_flag.is_set():

After Change

        self.receiver.bind("ipc://*")
        self.address = self.receiver.getsockopt(zmq.LAST_ENDPOINT).decode("ascii")
        pending_checksum = defaultdict(int)
        pending_client = defaultdict(list)

        while not self.exit_flag.is_set():
            msg = self.receiver.recv_multipart()
            client_id = msg[0]

Instances