| 114 | } |
| 115 | |
| 116 | Status ControlService::GetProfile(const ReportExecStatusRequestPB& request, |
| 117 | const ClientRequestState& request_state, RpcContext* rpc_context, |
| 118 | TRuntimeProfileForest* thrift_profiles) { |
| 119 | // Debug action to simulate deserialization failure. |
| 120 | RETURN_IF_ERROR(DebugAction(request_state.query_options(), |
| 121 | "REPORT_EXEC_STATUS_PROFILE")); |
| 122 | kudu::Slice thrift_profiles_slice; |
| 123 | KUDU_RETURN_IF_ERROR(rpc_context->GetInboundSidecar( |
| 124 | request.thrift_profiles_sidecar_idx(), &thrift_profiles_slice), |
| 125 | "Failed to get thrift profile sidecar"); |
| 126 | uint32_t len = thrift_profiles_slice.size(); |
| 127 | RETURN_IF_ERROR(DeserializeThriftMsg(thrift_profiles_slice.data(), |
| 128 | &len, true, thrift_profiles)); |
| 129 | return Status::OK(); |
| 130 | } |
| 131 | |
| 132 | void ControlService::ExecQueryFInstances(const ExecQueryFInstancesRequestPB* request, |
| 133 | ExecQueryFInstancesResponsePB* response, RpcContext* rpc_context) { |
nothing calls this directly
no test coverage detected