postRead callback occurs after RPC read completes
| 273 | |
| 274 | // postRead callback occurs after RPC read completes |
| 275 | void RpcEventHandler::postRead(void* ctx, const char* fn_name, uint32_t bytes) { |
| 276 | InvocationContext* rpc_ctx = reinterpret_cast<InvocationContext*>(ctx); |
| 277 | rpc_ctx->read_end_us = GetMonoTimeMicros(); |
| 278 | int64_t elapsed_time = rpc_ctx->read_end_us - rpc_ctx->start_time_us; |
| 279 | rpc_ctx->method_descriptor->read_time_distribution->Update(elapsed_time); |
| 280 | } |
| 281 | |
| 282 | // preWrite callback occurs before RPC read starts |
| 283 | void RpcEventHandler::preWrite(void* ctx, const char* fn_name) { |
nothing calls this directly
no test coverage detected