update profile

python/paddle_serving_server/pyserver.py

@@ -631,7 +631,8 @@ class ThreadChannel(Queue.Queue):
             self._cv.notify_all()
 
         logging.debug(self._log("multi | {} get data succ!".format(op_name)))
-        return copy.deepcopy(resp)  # reference, read only
+        # return resp  # reference, read only
+        return copy.deepcopy(resp)
 
     def stop(self):
         #TODO
@@ -989,7 +990,8 @@ class VirtualOp(Op):
             channel.add_producer(op.name)
         self._outputs.append(channel)
 
-    def _run_with_brpc(self, concurrency_idx, input_channel, output_channels):
+    def _run(self, concurrency_idx, input_channel, output_channels, client_type,
+             use_future):
         op_info_prefix = "[{}|{}]".format(self.name, concurrency_idx)
         log = self._get_log_func(op_info_prefix)
         self._is_run = True

python/paddle_serving_server_gpu/pyserver.py

@@ -631,7 +631,8 @@ class ThreadChannel(Queue.Queue):
             self._cv.notify_all()
 
         logging.debug(self._log("multi | {} get data succ!".format(op_name)))
-        return copy.deepcopy(resp)  # reference, read only
+        # return resp  # reference, read only
+        return copy.deepcopy(resp)
 
     def stop(self):
         #TODO
@@ -989,7 +990,8 @@ class VirtualOp(Op):
             channel.add_producer(op.name)
         self._outputs.append(channel)
 
-    def _run_with_brpc(self, concurrency_idx, input_channel, output_channels):
+    def _run(self, concurrency_idx, input_channel, output_channels, client_type,
+             use_future):
         op_info_prefix = "[{}|{}]".format(self.name, concurrency_idx)
         log = self._get_log_func(op_info_prefix)
         self._is_run = True