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

Before Change

            if len(msg) == 3:
                // register a new client
                client_checksum[client_id] = int(msg[2])
                pending_checksum[client_id] = 0
                pending_client[client_id] = []
            elif len(msg) == 5:
                arr_info, arr_val = jsonapi.loads(msg[2]), msg[4]

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