72ba607dc22f1cf0f071acf90756bfb0c4a2c068,service/server.py,BertServer,run,#BertServer#,47

Before Change

                    md = jsonapi.loads(res_head[-1])
                    // receiving actual data
                    res_body = self.backend.recv_multipart()
                    worker, _, client = res_body[:3]
                    free_a_worker(res_body)
                    _, reply = res_body[3:]
                    X = np.frombuffer(memoryview(reply), dtype=md["dtype"])
                    finish_jobs[client].append(X.reshape(md["shape"]))

After Change

                free_a_worker(worker)
                if client != b"READY" and len(request) > 3:
                    _, reply = request[3:]
                    finish_jobs[client].append(pickle.loads(reply))
                else:
                    poller.register(self.frontend, zmq.POLLIN)

Instances