diff options
author | 2016-06-27 13:16:22 -0700 | |
---|---|---|
committer | 2016-06-27 13:16:22 -0700 | |
commit | bfc9adc81f39316a3ee62e19901614eb6eebba4d (patch) | |
tree | 471181fd18f66268254e43cd43df4d0a199f4462 /src/core/ext/census | |
parent | a9df5d1029b303a305481c4bb765c6bed2e8ebbb (diff) |
Annotate more things
Diffstat (limited to 'src/core/ext/census')
-rw-r--r-- | src/core/ext/census/grpc_filter.c | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/core/ext/census/grpc_filter.c b/src/core/ext/census/grpc_filter.c index 72e4e5427e..f51d850e01 100644 --- a/src/core/ext/census/grpc_filter.c +++ b/src/core/ext/census/grpc_filter.c @@ -45,6 +45,7 @@ #include "src/core/ext/census/census_interface.h" #include "src/core/ext/census/census_rpc_stats.h" #include "src/core/lib/channel/channel_stack.h" +#include "src/core/lib/profiling/timers.h" #include "src/core/lib/transport/static_metadata.h" typedef struct call_data { @@ -92,6 +93,7 @@ static void client_start_transport_op(grpc_exec_ctx *exec_ctx, static void server_on_done_recv(grpc_exec_ctx *exec_ctx, void *ptr, grpc_error *error) { + GPR_TIMER_BEGIN("census-server:server_on_done_recv", 0); grpc_call_element *elem = ptr; call_data *calld = elem->call_data; channel_data *chand = elem->channel_data; @@ -99,6 +101,7 @@ static void server_on_done_recv(grpc_exec_ctx *exec_ctx, void *ptr, extract_and_annotate_method_tag(calld->recv_initial_metadata, calld, chand); } calld->on_done_recv->cb(exec_ctx, calld->on_done_recv->cb_arg, error); + GPR_TIMER_END("census-server:server_on_done_recv", 0); } static void server_mutate_op(grpc_call_element *elem, |