367ee86aeea0dc510f01ce0ef58dc551d1d4d86b,service/server.py,BertServer,run,#BertServer#,63

Before Change

            process.start()

        // connect to sink
        self.sink = self.context.socket(zmq.PUSH)
        self.sink.connect(sink_thread.address)

        while not self.exit_flag.is_set():
            client, _, msg = self.frontend.recv_multipart()
            if msg == b"SHOW_CONFIG":

After Change

            seqs = pickle.loads(msg)
            num_seqs = len(seqs)
            self.client_checksum[client] = num_seqs

            if num_seqs > self.max_batch_size:
                // divide the large batch into small batches
                s_idx = 0

Instances