diff options
author | 2017-09-08 14:26:22 -0700 | |
---|---|---|
committer | 2017-09-08 14:26:22 -0700 | |
commit | 073a88f4dddf102ecaa46f2d74fd85bdf5be9594 (patch) | |
tree | 6a1ececb9e5539b9142e0d19999299b0c8ec3fa7 /src/core | |
parent | 2e9afc02ac7cf422c0d46d702c72885d6500c115 (diff) |
add some stats
Diffstat (limited to 'src/core')
-rw-r--r-- | src/core/ext/transport/chttp2/transport/chttp2_transport.c | 6 | ||||
-rw-r--r-- | src/core/lib/debug/stats_data.c | 2 | ||||
-rw-r--r-- | src/core/lib/debug/stats_data.h | 6 | ||||
-rw-r--r-- | src/core/lib/debug/stats_data.yaml | 3 |
4 files changed, 16 insertions, 1 deletions
diff --git a/src/core/ext/transport/chttp2/transport/chttp2_transport.c b/src/core/ext/transport/chttp2/transport/chttp2_transport.c index 65c35f0a86..652150a8c1 100644 --- a/src/core/ext/transport/chttp2/transport/chttp2_transport.c +++ b/src/core/ext/transport/chttp2/transport/chttp2_transport.c @@ -938,6 +938,12 @@ static void write_action_begin_locked(grpc_exec_ctx *exec_ctx, void *gt, r = grpc_chttp2_begin_write(exec_ctx, t); } if (r.writing) { + if (r.partial) { + GRPC_STATS_INC_HTTP2_PARTIAL_WRITES(exec_ctx); + } + if (!t->is_first_write_in_batch) { + GRPC_STATS_INC_HTTP2_WRITES_CONTINUED(exec_ctx); + } grpc_closure_scheduler *scheduler = write_scheduler(t, r.early_results_scheduled, r.partial); if (scheduler != grpc_schedule_on_exec_ctx) { diff --git a/src/core/lib/debug/stats_data.c b/src/core/lib/debug/stats_data.c index 490d257d2f..a21bb1ef40 100644 --- a/src/core/lib/debug/stats_data.c +++ b/src/core/lib/debug/stats_data.c @@ -43,6 +43,8 @@ const char *grpc_stats_counter_name[GRPC_STATS_COUNTER_COUNT] = { "http2_pings_sent", "http2_writes_begun", "http2_writes_offloaded", + "http2_writes_continued", + "http2_partial_writes", "combiner_locks_initiated", "combiner_locks_scheduled_items", "combiner_locks_scheduled_final_items", diff --git a/src/core/lib/debug/stats_data.h b/src/core/lib/debug/stats_data.h index b0f5946eb0..bbc78fb341 100644 --- a/src/core/lib/debug/stats_data.h +++ b/src/core/lib/debug/stats_data.h @@ -45,6 +45,8 @@ typedef enum { GRPC_STATS_COUNTER_HTTP2_PINGS_SENT, GRPC_STATS_COUNTER_HTTP2_WRITES_BEGUN, GRPC_STATS_COUNTER_HTTP2_WRITES_OFFLOADED, + GRPC_STATS_COUNTER_HTTP2_WRITES_CONTINUED, + GRPC_STATS_COUNTER_HTTP2_PARTIAL_WRITES, GRPC_STATS_COUNTER_COMBINER_LOCKS_INITIATED, GRPC_STATS_COUNTER_COMBINER_LOCKS_SCHEDULED_ITEMS, GRPC_STATS_COUNTER_COMBINER_LOCKS_SCHEDULED_FINAL_ITEMS, @@ -128,6 +130,10 @@ typedef enum { GRPC_STATS_INC_COUNTER((exec_ctx), GRPC_STATS_COUNTER_HTTP2_WRITES_BEGUN) #define GRPC_STATS_INC_HTTP2_WRITES_OFFLOADED(exec_ctx) \ GRPC_STATS_INC_COUNTER((exec_ctx), GRPC_STATS_COUNTER_HTTP2_WRITES_OFFLOADED) +#define GRPC_STATS_INC_HTTP2_WRITES_CONTINUED(exec_ctx) \ + GRPC_STATS_INC_COUNTER((exec_ctx), GRPC_STATS_COUNTER_HTTP2_WRITES_CONTINUED) +#define GRPC_STATS_INC_HTTP2_PARTIAL_WRITES(exec_ctx) \ + GRPC_STATS_INC_COUNTER((exec_ctx), GRPC_STATS_COUNTER_HTTP2_PARTIAL_WRITES) #define GRPC_STATS_INC_COMBINER_LOCKS_INITIATED(exec_ctx) \ GRPC_STATS_INC_COUNTER((exec_ctx), \ GRPC_STATS_COUNTER_COMBINER_LOCKS_INITIATED) diff --git a/src/core/lib/debug/stats_data.yaml b/src/core/lib/debug/stats_data.yaml index 64eb4df6d1..e74fdc331d 100644 --- a/src/core/lib/debug/stats_data.yaml +++ b/src/core/lib/debug/stats_data.yaml @@ -58,6 +58,8 @@ - counter: http2_pings_sent - counter: http2_writes_begun - counter: http2_writes_offloaded +- counter: http2_writes_continued +- counter: http2_partial_writes # combiner locks - counter: combiner_locks_initiated - counter: combiner_locks_scheduled_items @@ -70,4 +72,3 @@ - counter: executor_wakeup_initiated - counter: executor_queue_drained - counter: executor_push_retries - |