| 212 | |
| 213 | template<typename ResponsePBType> |
| 214 | void DataStreamService::RespondRpc(const Status& status, |
| 215 | ResponsePBType* response, kudu::rpc::RpcContext* ctx) { |
| 216 | MonoDelta duration(MonoTime::Now() - ctx->GetTimeReceived()); |
| 217 | StatusToProto(status, response->mutable_status()); |
| 218 | response->set_receiver_latency_ns(duration.ToNanoseconds()); |
| 219 | ctx->RespondSuccess(); |
| 220 | } |
| 221 | |
| 222 | template<typename ResponsePBType> |
| 223 | void DataStreamService::RespondAndReleaseRpc(const Status& status, |
nothing calls this directly
no test coverage detected