6f325b9135a729a403840866fcb5248d71f54645,service/server.py,BertServer,run,#BertServer#,47

Before Change

                worker, _, client = request[:3]
                if client == b"READY":
                    poller.register(self.frontend, zmq.POLLIN)
                    logger.info("registered!")
                    continue

                // parsing data size
                md = jsonapi.loads(request[-1])

After Change

                request = self.backend.recv_multipart()
                worker, _, client = request[:3]
                free_a_worker(worker)
                if client != b"READY" and len(request) > 3:
                    _, reply = request[3:]
                    X = np.frombuffer(memoryview(reply), dtype=md["dtype"])
                    finish_jobs[client].append(X.reshape(md["shape"]))

Instances