Used by other protocols as well.
| 479 | |
| 480 | // Used by other protocols as well. |
| 481 | void EndRunningCallMethodInPool( |
| 482 | ::google::protobuf::Service* service, |
| 483 | const ::google::protobuf::MethodDescriptor* method, |
| 484 | ::google::protobuf::RpcController* controller, |
| 485 | const ::google::protobuf::Message* request, |
| 486 | ::google::protobuf::Message* response, |
| 487 | ::google::protobuf::Closure* done) { |
| 488 | CallMethodInBackupThreadArgs* args = new CallMethodInBackupThreadArgs; |
| 489 | args->service = service; |
| 490 | args->method = method; |
| 491 | args->controller = controller; |
| 492 | args->request = request; |
| 493 | args->response = response; |
| 494 | args->done = done; |
| 495 | return EndRunningUserCodeInPool(CallMethodInBackupThread, args); |
| 496 | }; |
| 497 | |
| 498 | bool DeserializeRpcMessage(const butil::IOBuf& data, Controller& cntl, |
| 499 | ContentType content_type, CompressType compress_type, |
no test coverage detected