|
|
@ -31,6 +31,12 @@ const char *grpc_stats_counter_name[GRPC_STATS_COUNTER_COUNT] = { |
|
|
|
"server_channels_created", |
|
|
|
"server_channels_created", |
|
|
|
"syscall_poll", |
|
|
|
"syscall_poll", |
|
|
|
"syscall_wait", |
|
|
|
"syscall_wait", |
|
|
|
|
|
|
|
"pollset_kick", |
|
|
|
|
|
|
|
"pollset_kicked_without_poller", |
|
|
|
|
|
|
|
"pollset_kicked_again", |
|
|
|
|
|
|
|
"pollset_kick_wakeup_fd", |
|
|
|
|
|
|
|
"pollset_kick_wakeup_cv", |
|
|
|
|
|
|
|
"pollset_kick_own_thread", |
|
|
|
"histogram_slow_lookups", |
|
|
|
"histogram_slow_lookups", |
|
|
|
"syscall_write", |
|
|
|
"syscall_write", |
|
|
|
"syscall_read", |
|
|
|
"syscall_read", |
|
|
@ -50,6 +56,27 @@ const char *grpc_stats_counter_name[GRPC_STATS_COUNTER_COUNT] = { |
|
|
|
"http2_writes_offloaded", |
|
|
|
"http2_writes_offloaded", |
|
|
|
"http2_writes_continued", |
|
|
|
"http2_writes_continued", |
|
|
|
"http2_partial_writes", |
|
|
|
"http2_partial_writes", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_initial_write", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_start_new_stream", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_send_message", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_send_initial_metadata", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_send_trailing_metadata", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_retry_send_ping", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_continue_pings", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_goaway_sent", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_rst_stream", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_close_from_api", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_stream_flow_control", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_transport_flow_control", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_send_settings", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_bdp_estimator_ping", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_flow_control_unstalled_by_setting", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_flow_control_unstalled_by_update", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_application_ping", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_keepalive_ping", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_transport_flow_control_unstalled", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_ping_response", |
|
|
|
|
|
|
|
"http2_initiate_write_due_to_force_rst_stream", |
|
|
|
"combiner_locks_initiated", |
|
|
|
"combiner_locks_initiated", |
|
|
|
"combiner_locks_scheduled_items", |
|
|
|
"combiner_locks_scheduled_items", |
|
|
|
"combiner_locks_scheduled_final_items", |
|
|
|
"combiner_locks_scheduled_final_items", |
|
|
@ -60,6 +87,8 @@ const char *grpc_stats_counter_name[GRPC_STATS_COUNTER_COUNT] = { |
|
|
|
"executor_wakeup_initiated", |
|
|
|
"executor_wakeup_initiated", |
|
|
|
"executor_queue_drained", |
|
|
|
"executor_queue_drained", |
|
|
|
"executor_push_retries", |
|
|
|
"executor_push_retries", |
|
|
|
|
|
|
|
"executor_threads_created", |
|
|
|
|
|
|
|
"executor_threads_used", |
|
|
|
"server_requested_calls", |
|
|
|
"server_requested_calls", |
|
|
|
"server_slowpath_requests_queued", |
|
|
|
"server_slowpath_requests_queued", |
|
|
|
}; |
|
|
|
}; |
|
|
@ -70,6 +99,18 @@ const char *grpc_stats_counter_doc[GRPC_STATS_COUNTER_COUNT] = { |
|
|
|
"Number of client subchannels created", "Number of server channels created", |
|
|
|
"Number of client subchannels created", "Number of server channels created", |
|
|
|
"Number of polling syscalls (epoll_wait, poll, etc) made by this process", |
|
|
|
"Number of polling syscalls (epoll_wait, poll, etc) made by this process", |
|
|
|
"Number of sleeping syscalls made by this process", |
|
|
|
"Number of sleeping syscalls made by this process", |
|
|
|
|
|
|
|
"How many polling wakeups were performed by the process (only valid for " |
|
|
|
|
|
|
|
"epoll1 right now)", |
|
|
|
|
|
|
|
"How many times was a polling wakeup requested without an active poller " |
|
|
|
|
|
|
|
"(only valid for epoll1 right now)", |
|
|
|
|
|
|
|
"How many times was the same polling worker awoken repeatedly before " |
|
|
|
|
|
|
|
"waking up (only valid for epoll1 right now)", |
|
|
|
|
|
|
|
"How many times was an eventfd used as the wakeup vector for a polling " |
|
|
|
|
|
|
|
"wakeup (only valid for epoll1 right now)", |
|
|
|
|
|
|
|
"How many times was a condition variable used as the wakeup vector for a " |
|
|
|
|
|
|
|
"polling wakeup (only valid for epoll1 right now)", |
|
|
|
|
|
|
|
"How many times could a polling wakeup be satisfied by keeping the waking " |
|
|
|
|
|
|
|
"thread awake? (only valid for epoll1 right now)", |
|
|
|
"Number of times histogram increments went through the slow (binary " |
|
|
|
"Number of times histogram increments went through the slow (binary " |
|
|
|
"search) path", |
|
|
|
"search) path", |
|
|
|
"Number of write syscalls (or equivalent - eg sendmsg) made by this " |
|
|
|
"Number of write syscalls (or equivalent - eg sendmsg) made by this " |
|
|
@ -92,6 +133,30 @@ const char *grpc_stats_counter_doc[GRPC_STATS_COUNTER_COUNT] = { |
|
|
|
"written", |
|
|
|
"written", |
|
|
|
"Number of HTTP2 writes that were made knowing there was still more data " |
|
|
|
"Number of HTTP2 writes that were made knowing there was still more data " |
|
|
|
"to be written (we cap maximum write size to syscall_write)", |
|
|
|
"to be written (we cap maximum write size to syscall_write)", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'initial_write'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'start_new_stream'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'send_message'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'send_initial_metadata'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'send_trailing_metadata'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'retry_send_ping'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'continue_pings'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'goaway_sent'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'rst_stream'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'close_from_api'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'stream_flow_control'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'transport_flow_control'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'send_settings'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'bdp_estimator_ping'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to " |
|
|
|
|
|
|
|
"'flow_control_unstalled_by_setting'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to " |
|
|
|
|
|
|
|
"'flow_control_unstalled_by_update'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'application_ping'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'keepalive_ping'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to " |
|
|
|
|
|
|
|
"'transport_flow_control_unstalled'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'ping_response'", |
|
|
|
|
|
|
|
"Number of HTTP2 writes initiated due to 'force_rst_stream'", |
|
|
|
"Number of combiner lock entries by process (first items queued to a " |
|
|
|
"Number of combiner lock entries by process (first items queued to a " |
|
|
|
"combiner)", |
|
|
|
"combiner)", |
|
|
|
"Number of items scheduled against combiner locks", |
|
|
|
"Number of items scheduled against combiner locks", |
|
|
@ -106,11 +171,15 @@ const char *grpc_stats_counter_doc[GRPC_STATS_COUNTER_COUNT] = { |
|
|
|
"Number of times an executor queue was drained", |
|
|
|
"Number of times an executor queue was drained", |
|
|
|
"Number of times we raced and were forced to retry pushing a closure to " |
|
|
|
"Number of times we raced and were forced to retry pushing a closure to " |
|
|
|
"the executor", |
|
|
|
"the executor", |
|
|
|
|
|
|
|
"Size of the backing thread pool for overflow gRPC Core work", |
|
|
|
|
|
|
|
"How many executor threads actually got used", |
|
|
|
"How many calls were requested (not necessarily received) by the server", |
|
|
|
"How many calls were requested (not necessarily received) by the server", |
|
|
|
"How many times was the server slow path taken (indicates too few " |
|
|
|
"How many times was the server slow path taken (indicates too few " |
|
|
|
"outstanding requests)", |
|
|
|
"outstanding requests)", |
|
|
|
}; |
|
|
|
}; |
|
|
|
const char *grpc_stats_histogram_name[GRPC_STATS_HISTOGRAM_COUNT] = { |
|
|
|
const char *grpc_stats_histogram_name[GRPC_STATS_HISTOGRAM_COUNT] = { |
|
|
|
|
|
|
|
"call_initial_size", |
|
|
|
|
|
|
|
"poll_events_returned", |
|
|
|
"tcp_write_size", |
|
|
|
"tcp_write_size", |
|
|
|
"tcp_write_iov_size", |
|
|
|
"tcp_write_iov_size", |
|
|
|
"tcp_read_size", |
|
|
|
"tcp_read_size", |
|
|
@ -121,9 +190,12 @@ const char *grpc_stats_histogram_name[GRPC_STATS_HISTOGRAM_COUNT] = { |
|
|
|
"http2_send_message_per_write", |
|
|
|
"http2_send_message_per_write", |
|
|
|
"http2_send_trailing_metadata_per_write", |
|
|
|
"http2_send_trailing_metadata_per_write", |
|
|
|
"http2_send_flowctl_per_write", |
|
|
|
"http2_send_flowctl_per_write", |
|
|
|
|
|
|
|
"executor_closures_per_wakeup", |
|
|
|
"server_cqs_checked", |
|
|
|
"server_cqs_checked", |
|
|
|
}; |
|
|
|
}; |
|
|
|
const char *grpc_stats_histogram_doc[GRPC_STATS_HISTOGRAM_COUNT] = { |
|
|
|
const char *grpc_stats_histogram_doc[GRPC_STATS_HISTOGRAM_COUNT] = { |
|
|
|
|
|
|
|
"Initial size of the grpc_call arena created at call start", |
|
|
|
|
|
|
|
"How many events are called for each syscall_poll", |
|
|
|
"Number of bytes offered to each syscall_write", |
|
|
|
"Number of bytes offered to each syscall_write", |
|
|
|
"Number of byte segments offered to each syscall_write", |
|
|
|
"Number of byte segments offered to each syscall_write", |
|
|
|
"Number of bytes received by each syscall_read", |
|
|
|
"Number of bytes received by each syscall_read", |
|
|
@ -134,10 +206,47 @@ const char *grpc_stats_histogram_doc[GRPC_STATS_HISTOGRAM_COUNT] = { |
|
|
|
"Number of streams whose payload was written per TCP write", |
|
|
|
"Number of streams whose payload was written per TCP write", |
|
|
|
"Number of streams terminated per TCP write", |
|
|
|
"Number of streams terminated per TCP write", |
|
|
|
"Number of flow control updates written per TCP write", |
|
|
|
"Number of flow control updates written per TCP write", |
|
|
|
|
|
|
|
"Number of closures executed each time an executor wakes up", |
|
|
|
"How many completion queues were checked looking for a CQ that had " |
|
|
|
"How many completion queues were checked looking for a CQ that had " |
|
|
|
"requested the incoming call", |
|
|
|
"requested the incoming call", |
|
|
|
}; |
|
|
|
}; |
|
|
|
const int grpc_stats_table_0[65] = { |
|
|
|
const int grpc_stats_table_0[65] = { |
|
|
|
|
|
|
|
0, 1, 2, 3, 4, 5, 7, 9, 11, 14, |
|
|
|
|
|
|
|
17, 21, 26, 32, 39, 47, 57, 68, 82, 98, |
|
|
|
|
|
|
|
117, 140, 167, 199, 238, 284, 339, 404, 482, 575, |
|
|
|
|
|
|
|
685, 816, 972, 1158, 1380, 1644, 1959, 2334, 2780, 3312, |
|
|
|
|
|
|
|
3945, 4699, 5597, 6667, 7941, 9459, 11267, 13420, 15984, 19038, |
|
|
|
|
|
|
|
22676, 27009, 32169, 38315, 45635, 54353, 64737, 77104, 91834, 109378, |
|
|
|
|
|
|
|
130273, 155159, 184799, 220100, 262144}; |
|
|
|
|
|
|
|
const uint8_t grpc_stats_table_1[124] = { |
|
|
|
|
|
|
|
0, 0, 0, 1, 1, 1, 2, 2, 3, 3, 3, 4, 4, 5, 5, 6, 6, 6, |
|
|
|
|
|
|
|
7, 7, 7, 8, 9, 9, 10, 10, 10, 11, 11, 12, 12, 13, 13, 14, 14, 15, |
|
|
|
|
|
|
|
15, 16, 16, 17, 17, 18, 18, 19, 19, 20, 20, 21, 21, 22, 22, 22, 23, 24, |
|
|
|
|
|
|
|
24, 25, 25, 26, 26, 26, 27, 27, 28, 29, 29, 30, 30, 30, 31, 31, 32, 33, |
|
|
|
|
|
|
|
33, 34, 34, 34, 35, 35, 36, 37, 37, 37, 38, 38, 39, 39, 40, 40, 41, 41, |
|
|
|
|
|
|
|
42, 42, 43, 43, 44, 44, 45, 45, 46, 46, 47, 47, 48, 48, 49, 49, 50, 50, |
|
|
|
|
|
|
|
51, 51, 52, 52, 53, 53, 54, 54, 55, 55, 56, 56, 57, 57, 58, 58}; |
|
|
|
|
|
|
|
const int grpc_stats_table_2[129] = { |
|
|
|
|
|
|
|
0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, |
|
|
|
|
|
|
|
15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 30, |
|
|
|
|
|
|
|
32, 34, 36, 38, 40, 42, 44, 46, 48, 50, 52, 54, 56, 58, 60, |
|
|
|
|
|
|
|
63, 66, 69, 72, 75, 78, 81, 84, 87, 90, 94, 98, 102, 106, 110, |
|
|
|
|
|
|
|
114, 118, 122, 126, 131, 136, 141, 146, 151, 156, 162, 168, 174, 180, 186, |
|
|
|
|
|
|
|
192, 199, 206, 213, 220, 228, 236, 244, 252, 260, 269, 278, 287, 297, 307, |
|
|
|
|
|
|
|
317, 327, 338, 349, 360, 372, 384, 396, 409, 422, 436, 450, 464, 479, 494, |
|
|
|
|
|
|
|
510, 526, 543, 560, 578, 596, 615, 634, 654, 674, 695, 717, 739, 762, 785, |
|
|
|
|
|
|
|
809, 834, 859, 885, 912, 939, 967, 996, 1024}; |
|
|
|
|
|
|
|
const uint8_t grpc_stats_table_3[166] = { |
|
|
|
|
|
|
|
0, 0, 0, 1, 1, 1, 1, 2, 2, 3, 3, 4, 4, 5, 5, 6, 6, 7, 7, |
|
|
|
|
|
|
|
8, 8, 9, 9, 10, 10, 11, 11, 12, 12, 13, 13, 14, 14, 15, 15, 16, 16, 16, |
|
|
|
|
|
|
|
17, 17, 18, 19, 19, 20, 21, 21, 22, 23, 23, 24, 25, 25, 26, 26, 27, 27, 28, |
|
|
|
|
|
|
|
28, 29, 29, 30, 30, 31, 31, 32, 32, 33, 33, 34, 34, 35, 36, 36, 37, 38, 39, |
|
|
|
|
|
|
|
40, 40, 41, 42, 42, 43, 44, 44, 45, 46, 46, 47, 48, 48, 49, 49, 50, 50, 51, |
|
|
|
|
|
|
|
51, 52, 52, 53, 53, 54, 54, 55, 56, 57, 58, 59, 59, 60, 61, 62, 63, 63, 64, |
|
|
|
|
|
|
|
65, 65, 66, 67, 67, 68, 69, 69, 70, 71, 71, 72, 72, 73, 73, 74, 75, 75, 76, |
|
|
|
|
|
|
|
76, 77, 78, 79, 79, 80, 81, 82, 83, 84, 85, 85, 86, 87, 88, 88, 89, 90, 90, |
|
|
|
|
|
|
|
91, 92, 92, 93, 94, 94, 95, 95, 96, 97, 97, 98, 98, 99}; |
|
|
|
|
|
|
|
const int grpc_stats_table_4[65] = { |
|
|
|
0, 1, 2, 3, 4, 6, 8, 11, |
|
|
|
0, 1, 2, 3, 4, 6, 8, 11, |
|
|
|
15, 20, 26, 34, 44, 57, 73, 94, |
|
|
|
15, 20, 26, 34, 44, 57, 73, 94, |
|
|
|
121, 155, 199, 255, 327, 419, 537, 688, |
|
|
|
121, 155, 199, 255, 327, 419, 537, 688, |
|
|
@ -147,28 +256,82 @@ const int grpc_stats_table_0[65] = { |
|
|
|
326126, 417200, 533707, 682750, 873414, 1117323, 1429345, 1828502, |
|
|
|
326126, 417200, 533707, 682750, 873414, 1117323, 1429345, 1828502, |
|
|
|
2339127, 2992348, 3827987, 4896985, 6264509, 8013925, 10251880, 13114801, |
|
|
|
2339127, 2992348, 3827987, 4896985, 6264509, 8013925, 10251880, 13114801, |
|
|
|
16777216}; |
|
|
|
16777216}; |
|
|
|
const uint8_t grpc_stats_table_1[87] = { |
|
|
|
const uint8_t grpc_stats_table_5[87] = { |
|
|
|
0, 0, 1, 1, 2, 3, 3, 4, 4, 5, 6, 6, 7, 8, 8, 9, 10, 11, |
|
|
|
0, 0, 1, 1, 2, 3, 3, 4, 4, 5, 6, 6, 7, 8, 8, 9, 10, 11, |
|
|
|
11, 12, 13, 13, 14, 15, 15, 16, 17, 17, 18, 19, 20, 20, 21, 22, 22, 23, |
|
|
|
11, 12, 13, 13, 14, 15, 15, 16, 17, 17, 18, 19, 20, 20, 21, 22, 22, 23, |
|
|
|
24, 25, 25, 26, 27, 27, 28, 29, 29, 30, 31, 31, 32, 33, 34, 34, 35, 36, |
|
|
|
24, 25, 25, 26, 27, 27, 28, 29, 29, 30, 31, 31, 32, 33, 34, 34, 35, 36, |
|
|
|
36, 37, 38, 39, 39, 40, 41, 41, 42, 43, 44, 44, 45, 45, 46, 47, 48, 48, |
|
|
|
36, 37, 38, 39, 39, 40, 41, 41, 42, 43, 44, 44, 45, 45, 46, 47, 48, 48, |
|
|
|
49, 50, 51, 51, 52, 53, 53, 54, 55, 56, 56, 57, 58, 58, 59}; |
|
|
|
49, 50, 51, 51, 52, 53, 53, 54, 55, 56, 56, 57, 58, 58, 59}; |
|
|
|
const int grpc_stats_table_2[65] = { |
|
|
|
const int grpc_stats_table_6[65] = { |
|
|
|
0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, |
|
|
|
0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, |
|
|
|
14, 16, 18, 20, 22, 24, 27, 30, 33, 36, 39, 43, 47, |
|
|
|
14, 16, 18, 20, 22, 24, 27, 30, 33, 36, 39, 43, 47, |
|
|
|
51, 56, 61, 66, 72, 78, 85, 92, 100, 109, 118, 128, 139, |
|
|
|
51, 56, 61, 66, 72, 78, 85, 92, 100, 109, 118, 128, 139, |
|
|
|
151, 164, 178, 193, 209, 226, 244, 264, 285, 308, 333, 359, 387, |
|
|
|
151, 164, 178, 193, 209, 226, 244, 264, 285, 308, 333, 359, 387, |
|
|
|
418, 451, 486, 524, 565, 609, 656, 707, 762, 821, 884, 952, 1024}; |
|
|
|
418, 451, 486, 524, 565, 609, 656, 707, 762, 821, 884, 952, 1024}; |
|
|
|
const uint8_t grpc_stats_table_3[102] = { |
|
|
|
const uint8_t grpc_stats_table_7[102] = { |
|
|
|
0, 0, 0, 1, 1, 1, 1, 2, 2, 3, 3, 4, 4, 5, 5, 6, 6, |
|
|
|
0, 0, 0, 1, 1, 1, 1, 2, 2, 3, 3, 4, 4, 5, 5, 6, 6, |
|
|
|
6, 7, 7, 7, 8, 8, 9, 9, 10, 11, 11, 12, 12, 13, 13, 14, 14, |
|
|
|
6, 7, 7, 7, 8, 8, 9, 9, 10, 11, 11, 12, 12, 13, 13, 14, 14, |
|
|
|
14, 15, 15, 16, 16, 17, 17, 18, 19, 19, 20, 20, 21, 21, 22, 22, 23, |
|
|
|
14, 15, 15, 16, 16, 17, 17, 18, 19, 19, 20, 20, 21, 21, 22, 22, 23, |
|
|
|
23, 24, 24, 24, 25, 26, 27, 27, 28, 28, 29, 29, 30, 30, 31, 31, 32, |
|
|
|
23, 24, 24, 24, 25, 26, 27, 27, 28, 28, 29, 29, 30, 30, 31, 31, 32, |
|
|
|
32, 33, 33, 34, 35, 35, 36, 37, 37, 38, 38, 39, 39, 40, 40, 41, 41, |
|
|
|
32, 33, 33, 34, 35, 35, 36, 37, 37, 38, 38, 39, 39, 40, 40, 41, 41, |
|
|
|
42, 42, 43, 44, 44, 45, 46, 46, 47, 48, 48, 49, 49, 50, 50, 51, 51}; |
|
|
|
42, 42, 43, 44, 44, 45, 46, 46, 47, 48, 48, 49, 49, 50, 50, 51, 51}; |
|
|
|
const int grpc_stats_table_4[9] = {0, 1, 2, 4, 7, 13, 23, 39, 64}; |
|
|
|
const int grpc_stats_table_8[9] = {0, 1, 2, 4, 7, 13, 23, 39, 64}; |
|
|
|
const uint8_t grpc_stats_table_5[9] = {0, 0, 1, 2, 2, 3, 4, 4, 5}; |
|
|
|
const uint8_t grpc_stats_table_9[9] = {0, 0, 1, 2, 2, 3, 4, 4, 5}; |
|
|
|
|
|
|
|
void grpc_stats_inc_call_initial_size(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
|
|
|
|
/* Automatically generated by tools/codegen/core/gen_stats_data.py */ |
|
|
|
|
|
|
|
value = GPR_CLAMP(value, 0, 262144); |
|
|
|
|
|
|
|
if (value < 6) { |
|
|
|
|
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_CALL_INITIAL_SIZE, |
|
|
|
|
|
|
|
value); |
|
|
|
|
|
|
|
return; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
union { |
|
|
|
|
|
|
|
double dbl; |
|
|
|
|
|
|
|
uint64_t uint; |
|
|
|
|
|
|
|
} _val, _bkt; |
|
|
|
|
|
|
|
_val.dbl = value; |
|
|
|
|
|
|
|
if (_val.uint < 4651092515166879744ull) { |
|
|
|
|
|
|
|
int bucket = |
|
|
|
|
|
|
|
grpc_stats_table_1[((_val.uint - 4618441417868443648ull) >> 49)] + 6; |
|
|
|
|
|
|
|
_bkt.dbl = grpc_stats_table_0[bucket]; |
|
|
|
|
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
|
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_CALL_INITIAL_SIZE, |
|
|
|
|
|
|
|
bucket); |
|
|
|
|
|
|
|
return; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_CALL_INITIAL_SIZE, |
|
|
|
|
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
|
|
|
|
(exec_ctx), value, grpc_stats_table_0, 64)); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
void grpc_stats_inc_poll_events_returned(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
|
|
|
|
/* Automatically generated by tools/codegen/core/gen_stats_data.py */ |
|
|
|
|
|
|
|
value = GPR_CLAMP(value, 0, 1024); |
|
|
|
|
|
|
|
if (value < 29) { |
|
|
|
|
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
|
|
|
|
GRPC_STATS_HISTOGRAM_POLL_EVENTS_RETURNED, value); |
|
|
|
|
|
|
|
return; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
union { |
|
|
|
|
|
|
|
double dbl; |
|
|
|
|
|
|
|
uint64_t uint; |
|
|
|
|
|
|
|
} _val, _bkt; |
|
|
|
|
|
|
|
_val.dbl = value; |
|
|
|
|
|
|
|
if (_val.uint < 4642789003353915392ull) { |
|
|
|
|
|
|
|
int bucket = |
|
|
|
|
|
|
|
grpc_stats_table_3[((_val.uint - 4628855992006737920ull) >> 47)] + 29; |
|
|
|
|
|
|
|
_bkt.dbl = grpc_stats_table_2[bucket]; |
|
|
|
|
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
|
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
|
|
|
|
GRPC_STATS_HISTOGRAM_POLL_EVENTS_RETURNED, bucket); |
|
|
|
|
|
|
|
return; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
|
|
|
|
GRPC_STATS_HISTOGRAM_POLL_EVENTS_RETURNED, |
|
|
|
|
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
|
|
|
|
(exec_ctx), value, grpc_stats_table_2, 128)); |
|
|
|
|
|
|
|
} |
|
|
|
void grpc_stats_inc_tcp_write_size(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
void grpc_stats_inc_tcp_write_size(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
|
|
|
|
/* Automatically generated by tools/codegen/core/gen_stats_data.py */ |
|
|
|
value = GPR_CLAMP(value, 0, 16777216); |
|
|
|
value = GPR_CLAMP(value, 0, 16777216); |
|
|
|
if (value < 5) { |
|
|
|
if (value < 5) { |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_WRITE_SIZE, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_WRITE_SIZE, |
|
|
@ -182,8 +345,8 @@ void grpc_stats_inc_tcp_write_size(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
_val.dbl = value; |
|
|
|
_val.dbl = value; |
|
|
|
if (_val.uint < 4683743612465315840ull) { |
|
|
|
if (_val.uint < 4683743612465315840ull) { |
|
|
|
int bucket = |
|
|
|
int bucket = |
|
|
|
grpc_stats_table_1[((_val.uint - 4617315517961601024ull) >> 50)] + 5; |
|
|
|
grpc_stats_table_5[((_val.uint - 4617315517961601024ull) >> 50)] + 5; |
|
|
|
_bkt.dbl = grpc_stats_table_0[bucket]; |
|
|
|
_bkt.dbl = grpc_stats_table_4[bucket]; |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_WRITE_SIZE, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_WRITE_SIZE, |
|
|
|
bucket); |
|
|
|
bucket); |
|
|
@ -191,9 +354,10 @@ void grpc_stats_inc_tcp_write_size(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
} |
|
|
|
} |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_WRITE_SIZE, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_WRITE_SIZE, |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
(exec_ctx), value, grpc_stats_table_0, 64)); |
|
|
|
(exec_ctx), value, grpc_stats_table_4, 64)); |
|
|
|
} |
|
|
|
} |
|
|
|
void grpc_stats_inc_tcp_write_iov_size(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
void grpc_stats_inc_tcp_write_iov_size(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
|
|
|
|
/* Automatically generated by tools/codegen/core/gen_stats_data.py */ |
|
|
|
value = GPR_CLAMP(value, 0, 1024); |
|
|
|
value = GPR_CLAMP(value, 0, 1024); |
|
|
|
if (value < 13) { |
|
|
|
if (value < 13) { |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
@ -207,8 +371,8 @@ void grpc_stats_inc_tcp_write_iov_size(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
_val.dbl = value; |
|
|
|
_val.dbl = value; |
|
|
|
if (_val.uint < 4637863191261478912ull) { |
|
|
|
if (_val.uint < 4637863191261478912ull) { |
|
|
|
int bucket = |
|
|
|
int bucket = |
|
|
|
grpc_stats_table_3[((_val.uint - 4623507967449235456ull) >> 48)] + 13; |
|
|
|
grpc_stats_table_7[((_val.uint - 4623507967449235456ull) >> 48)] + 13; |
|
|
|
_bkt.dbl = grpc_stats_table_2[bucket]; |
|
|
|
_bkt.dbl = grpc_stats_table_6[bucket]; |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
GRPC_STATS_HISTOGRAM_TCP_WRITE_IOV_SIZE, bucket); |
|
|
|
GRPC_STATS_HISTOGRAM_TCP_WRITE_IOV_SIZE, bucket); |
|
|
@ -216,9 +380,10 @@ void grpc_stats_inc_tcp_write_iov_size(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
} |
|
|
|
} |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_WRITE_IOV_SIZE, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_WRITE_IOV_SIZE, |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
(exec_ctx), value, grpc_stats_table_2, 64)); |
|
|
|
(exec_ctx), value, grpc_stats_table_6, 64)); |
|
|
|
} |
|
|
|
} |
|
|
|
void grpc_stats_inc_tcp_read_size(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
void grpc_stats_inc_tcp_read_size(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
|
|
|
|
/* Automatically generated by tools/codegen/core/gen_stats_data.py */ |
|
|
|
value = GPR_CLAMP(value, 0, 16777216); |
|
|
|
value = GPR_CLAMP(value, 0, 16777216); |
|
|
|
if (value < 5) { |
|
|
|
if (value < 5) { |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_READ_SIZE, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_READ_SIZE, |
|
|
@ -232,8 +397,8 @@ void grpc_stats_inc_tcp_read_size(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
_val.dbl = value; |
|
|
|
_val.dbl = value; |
|
|
|
if (_val.uint < 4683743612465315840ull) { |
|
|
|
if (_val.uint < 4683743612465315840ull) { |
|
|
|
int bucket = |
|
|
|
int bucket = |
|
|
|
grpc_stats_table_1[((_val.uint - 4617315517961601024ull) >> 50)] + 5; |
|
|
|
grpc_stats_table_5[((_val.uint - 4617315517961601024ull) >> 50)] + 5; |
|
|
|
_bkt.dbl = grpc_stats_table_0[bucket]; |
|
|
|
_bkt.dbl = grpc_stats_table_4[bucket]; |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_READ_SIZE, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_READ_SIZE, |
|
|
|
bucket); |
|
|
|
bucket); |
|
|
@ -241,9 +406,10 @@ void grpc_stats_inc_tcp_read_size(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
} |
|
|
|
} |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_READ_SIZE, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_READ_SIZE, |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
(exec_ctx), value, grpc_stats_table_0, 64)); |
|
|
|
(exec_ctx), value, grpc_stats_table_4, 64)); |
|
|
|
} |
|
|
|
} |
|
|
|
void grpc_stats_inc_tcp_read_offer(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
void grpc_stats_inc_tcp_read_offer(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
|
|
|
|
/* Automatically generated by tools/codegen/core/gen_stats_data.py */ |
|
|
|
value = GPR_CLAMP(value, 0, 16777216); |
|
|
|
value = GPR_CLAMP(value, 0, 16777216); |
|
|
|
if (value < 5) { |
|
|
|
if (value < 5) { |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_READ_OFFER, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_READ_OFFER, |
|
|
@ -257,8 +423,8 @@ void grpc_stats_inc_tcp_read_offer(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
_val.dbl = value; |
|
|
|
_val.dbl = value; |
|
|
|
if (_val.uint < 4683743612465315840ull) { |
|
|
|
if (_val.uint < 4683743612465315840ull) { |
|
|
|
int bucket = |
|
|
|
int bucket = |
|
|
|
grpc_stats_table_1[((_val.uint - 4617315517961601024ull) >> 50)] + 5; |
|
|
|
grpc_stats_table_5[((_val.uint - 4617315517961601024ull) >> 50)] + 5; |
|
|
|
_bkt.dbl = grpc_stats_table_0[bucket]; |
|
|
|
_bkt.dbl = grpc_stats_table_4[bucket]; |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_READ_OFFER, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_READ_OFFER, |
|
|
|
bucket); |
|
|
|
bucket); |
|
|
@ -266,10 +432,11 @@ void grpc_stats_inc_tcp_read_offer(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
} |
|
|
|
} |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_READ_OFFER, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_TCP_READ_OFFER, |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
(exec_ctx), value, grpc_stats_table_0, 64)); |
|
|
|
(exec_ctx), value, grpc_stats_table_4, 64)); |
|
|
|
} |
|
|
|
} |
|
|
|
void grpc_stats_inc_tcp_read_offer_iov_size(grpc_exec_ctx *exec_ctx, |
|
|
|
void grpc_stats_inc_tcp_read_offer_iov_size(grpc_exec_ctx *exec_ctx, |
|
|
|
int value) { |
|
|
|
int value) { |
|
|
|
|
|
|
|
/* Automatically generated by tools/codegen/core/gen_stats_data.py */ |
|
|
|
value = GPR_CLAMP(value, 0, 1024); |
|
|
|
value = GPR_CLAMP(value, 0, 1024); |
|
|
|
if (value < 13) { |
|
|
|
if (value < 13) { |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
@ -283,8 +450,8 @@ void grpc_stats_inc_tcp_read_offer_iov_size(grpc_exec_ctx *exec_ctx, |
|
|
|
_val.dbl = value; |
|
|
|
_val.dbl = value; |
|
|
|
if (_val.uint < 4637863191261478912ull) { |
|
|
|
if (_val.uint < 4637863191261478912ull) { |
|
|
|
int bucket = |
|
|
|
int bucket = |
|
|
|
grpc_stats_table_3[((_val.uint - 4623507967449235456ull) >> 48)] + 13; |
|
|
|
grpc_stats_table_7[((_val.uint - 4623507967449235456ull) >> 48)] + 13; |
|
|
|
_bkt.dbl = grpc_stats_table_2[bucket]; |
|
|
|
_bkt.dbl = grpc_stats_table_6[bucket]; |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_TCP_READ_OFFER_IOV_SIZE, bucket); |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_TCP_READ_OFFER_IOV_SIZE, bucket); |
|
|
@ -293,10 +460,11 @@ void grpc_stats_inc_tcp_read_offer_iov_size(grpc_exec_ctx *exec_ctx, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
GRPC_STATS_HISTOGRAM_TCP_READ_OFFER_IOV_SIZE, |
|
|
|
GRPC_STATS_HISTOGRAM_TCP_READ_OFFER_IOV_SIZE, |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
(exec_ctx), value, grpc_stats_table_2, 64)); |
|
|
|
(exec_ctx), value, grpc_stats_table_6, 64)); |
|
|
|
} |
|
|
|
} |
|
|
|
void grpc_stats_inc_http2_send_message_size(grpc_exec_ctx *exec_ctx, |
|
|
|
void grpc_stats_inc_http2_send_message_size(grpc_exec_ctx *exec_ctx, |
|
|
|
int value) { |
|
|
|
int value) { |
|
|
|
|
|
|
|
/* Automatically generated by tools/codegen/core/gen_stats_data.py */ |
|
|
|
value = GPR_CLAMP(value, 0, 16777216); |
|
|
|
value = GPR_CLAMP(value, 0, 16777216); |
|
|
|
if (value < 5) { |
|
|
|
if (value < 5) { |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
@ -310,8 +478,8 @@ void grpc_stats_inc_http2_send_message_size(grpc_exec_ctx *exec_ctx, |
|
|
|
_val.dbl = value; |
|
|
|
_val.dbl = value; |
|
|
|
if (_val.uint < 4683743612465315840ull) { |
|
|
|
if (_val.uint < 4683743612465315840ull) { |
|
|
|
int bucket = |
|
|
|
int bucket = |
|
|
|
grpc_stats_table_1[((_val.uint - 4617315517961601024ull) >> 50)] + 5; |
|
|
|
grpc_stats_table_5[((_val.uint - 4617315517961601024ull) >> 50)] + 5; |
|
|
|
_bkt.dbl = grpc_stats_table_0[bucket]; |
|
|
|
_bkt.dbl = grpc_stats_table_4[bucket]; |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_HTTP2_SEND_MESSAGE_SIZE, bucket); |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_HTTP2_SEND_MESSAGE_SIZE, bucket); |
|
|
@ -320,10 +488,11 @@ void grpc_stats_inc_http2_send_message_size(grpc_exec_ctx *exec_ctx, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
GRPC_STATS_HISTOGRAM_HTTP2_SEND_MESSAGE_SIZE, |
|
|
|
GRPC_STATS_HISTOGRAM_HTTP2_SEND_MESSAGE_SIZE, |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
(exec_ctx), value, grpc_stats_table_0, 64)); |
|
|
|
(exec_ctx), value, grpc_stats_table_4, 64)); |
|
|
|
} |
|
|
|
} |
|
|
|
void grpc_stats_inc_http2_send_initial_metadata_per_write( |
|
|
|
void grpc_stats_inc_http2_send_initial_metadata_per_write( |
|
|
|
grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
|
|
|
|
/* Automatically generated by tools/codegen/core/gen_stats_data.py */ |
|
|
|
value = GPR_CLAMP(value, 0, 1024); |
|
|
|
value = GPR_CLAMP(value, 0, 1024); |
|
|
|
if (value < 13) { |
|
|
|
if (value < 13) { |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
@ -338,8 +507,8 @@ void grpc_stats_inc_http2_send_initial_metadata_per_write( |
|
|
|
_val.dbl = value; |
|
|
|
_val.dbl = value; |
|
|
|
if (_val.uint < 4637863191261478912ull) { |
|
|
|
if (_val.uint < 4637863191261478912ull) { |
|
|
|
int bucket = |
|
|
|
int bucket = |
|
|
|
grpc_stats_table_3[((_val.uint - 4623507967449235456ull) >> 48)] + 13; |
|
|
|
grpc_stats_table_7[((_val.uint - 4623507967449235456ull) >> 48)] + 13; |
|
|
|
_bkt.dbl = grpc_stats_table_2[bucket]; |
|
|
|
_bkt.dbl = grpc_stats_table_6[bucket]; |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_HTTP2_SEND_INITIAL_METADATA_PER_WRITE, |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_HTTP2_SEND_INITIAL_METADATA_PER_WRITE, |
|
|
@ -348,11 +517,12 @@ void grpc_stats_inc_http2_send_initial_metadata_per_write( |
|
|
|
} |
|
|
|
} |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_HTTP2_SEND_INITIAL_METADATA_PER_WRITE, |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_HTTP2_SEND_INITIAL_METADATA_PER_WRITE, |
|
|
|
grpc_stats_histo_find_bucket_slow((exec_ctx), value, grpc_stats_table_2, |
|
|
|
grpc_stats_histo_find_bucket_slow((exec_ctx), value, grpc_stats_table_6, |
|
|
|
64)); |
|
|
|
64)); |
|
|
|
} |
|
|
|
} |
|
|
|
void grpc_stats_inc_http2_send_message_per_write(grpc_exec_ctx *exec_ctx, |
|
|
|
void grpc_stats_inc_http2_send_message_per_write(grpc_exec_ctx *exec_ctx, |
|
|
|
int value) { |
|
|
|
int value) { |
|
|
|
|
|
|
|
/* Automatically generated by tools/codegen/core/gen_stats_data.py */ |
|
|
|
value = GPR_CLAMP(value, 0, 1024); |
|
|
|
value = GPR_CLAMP(value, 0, 1024); |
|
|
|
if (value < 13) { |
|
|
|
if (value < 13) { |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
@ -366,8 +536,8 @@ void grpc_stats_inc_http2_send_message_per_write(grpc_exec_ctx *exec_ctx, |
|
|
|
_val.dbl = value; |
|
|
|
_val.dbl = value; |
|
|
|
if (_val.uint < 4637863191261478912ull) { |
|
|
|
if (_val.uint < 4637863191261478912ull) { |
|
|
|
int bucket = |
|
|
|
int bucket = |
|
|
|
grpc_stats_table_3[((_val.uint - 4623507967449235456ull) >> 48)] + 13; |
|
|
|
grpc_stats_table_7[((_val.uint - 4623507967449235456ull) >> 48)] + 13; |
|
|
|
_bkt.dbl = grpc_stats_table_2[bucket]; |
|
|
|
_bkt.dbl = grpc_stats_table_6[bucket]; |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_HTTP2_SEND_MESSAGE_PER_WRITE, bucket); |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_HTTP2_SEND_MESSAGE_PER_WRITE, bucket); |
|
|
@ -376,10 +546,11 @@ void grpc_stats_inc_http2_send_message_per_write(grpc_exec_ctx *exec_ctx, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
GRPC_STATS_HISTOGRAM_HTTP2_SEND_MESSAGE_PER_WRITE, |
|
|
|
GRPC_STATS_HISTOGRAM_HTTP2_SEND_MESSAGE_PER_WRITE, |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
(exec_ctx), value, grpc_stats_table_2, 64)); |
|
|
|
(exec_ctx), value, grpc_stats_table_6, 64)); |
|
|
|
} |
|
|
|
} |
|
|
|
void grpc_stats_inc_http2_send_trailing_metadata_per_write( |
|
|
|
void grpc_stats_inc_http2_send_trailing_metadata_per_write( |
|
|
|
grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
|
|
|
|
/* Automatically generated by tools/codegen/core/gen_stats_data.py */ |
|
|
|
value = GPR_CLAMP(value, 0, 1024); |
|
|
|
value = GPR_CLAMP(value, 0, 1024); |
|
|
|
if (value < 13) { |
|
|
|
if (value < 13) { |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
@ -394,8 +565,8 @@ void grpc_stats_inc_http2_send_trailing_metadata_per_write( |
|
|
|
_val.dbl = value; |
|
|
|
_val.dbl = value; |
|
|
|
if (_val.uint < 4637863191261478912ull) { |
|
|
|
if (_val.uint < 4637863191261478912ull) { |
|
|
|
int bucket = |
|
|
|
int bucket = |
|
|
|
grpc_stats_table_3[((_val.uint - 4623507967449235456ull) >> 48)] + 13; |
|
|
|
grpc_stats_table_7[((_val.uint - 4623507967449235456ull) >> 48)] + 13; |
|
|
|
_bkt.dbl = grpc_stats_table_2[bucket]; |
|
|
|
_bkt.dbl = grpc_stats_table_6[bucket]; |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_HTTP2_SEND_TRAILING_METADATA_PER_WRITE, |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_HTTP2_SEND_TRAILING_METADATA_PER_WRITE, |
|
|
@ -404,11 +575,12 @@ void grpc_stats_inc_http2_send_trailing_metadata_per_write( |
|
|
|
} |
|
|
|
} |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_HTTP2_SEND_TRAILING_METADATA_PER_WRITE, |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_HTTP2_SEND_TRAILING_METADATA_PER_WRITE, |
|
|
|
grpc_stats_histo_find_bucket_slow((exec_ctx), value, grpc_stats_table_2, |
|
|
|
grpc_stats_histo_find_bucket_slow((exec_ctx), value, grpc_stats_table_6, |
|
|
|
64)); |
|
|
|
64)); |
|
|
|
} |
|
|
|
} |
|
|
|
void grpc_stats_inc_http2_send_flowctl_per_write(grpc_exec_ctx *exec_ctx, |
|
|
|
void grpc_stats_inc_http2_send_flowctl_per_write(grpc_exec_ctx *exec_ctx, |
|
|
|
int value) { |
|
|
|
int value) { |
|
|
|
|
|
|
|
/* Automatically generated by tools/codegen/core/gen_stats_data.py */ |
|
|
|
value = GPR_CLAMP(value, 0, 1024); |
|
|
|
value = GPR_CLAMP(value, 0, 1024); |
|
|
|
if (value < 13) { |
|
|
|
if (value < 13) { |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
@ -422,8 +594,8 @@ void grpc_stats_inc_http2_send_flowctl_per_write(grpc_exec_ctx *exec_ctx, |
|
|
|
_val.dbl = value; |
|
|
|
_val.dbl = value; |
|
|
|
if (_val.uint < 4637863191261478912ull) { |
|
|
|
if (_val.uint < 4637863191261478912ull) { |
|
|
|
int bucket = |
|
|
|
int bucket = |
|
|
|
grpc_stats_table_3[((_val.uint - 4623507967449235456ull) >> 48)] + 13; |
|
|
|
grpc_stats_table_7[((_val.uint - 4623507967449235456ull) >> 48)] + 13; |
|
|
|
_bkt.dbl = grpc_stats_table_2[bucket]; |
|
|
|
_bkt.dbl = grpc_stats_table_6[bucket]; |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_HTTP2_SEND_FLOWCTL_PER_WRITE, bucket); |
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_HTTP2_SEND_FLOWCTL_PER_WRITE, bucket); |
|
|
@ -432,9 +604,38 @@ void grpc_stats_inc_http2_send_flowctl_per_write(grpc_exec_ctx *exec_ctx, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
GRPC_STATS_HISTOGRAM_HTTP2_SEND_FLOWCTL_PER_WRITE, |
|
|
|
GRPC_STATS_HISTOGRAM_HTTP2_SEND_FLOWCTL_PER_WRITE, |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
(exec_ctx), value, grpc_stats_table_2, 64)); |
|
|
|
(exec_ctx), value, grpc_stats_table_6, 64)); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
void grpc_stats_inc_executor_closures_per_wakeup(grpc_exec_ctx *exec_ctx, |
|
|
|
|
|
|
|
int value) { |
|
|
|
|
|
|
|
/* Automatically generated by tools/codegen/core/gen_stats_data.py */ |
|
|
|
|
|
|
|
value = GPR_CLAMP(value, 0, 1024); |
|
|
|
|
|
|
|
if (value < 13) { |
|
|
|
|
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
|
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_EXECUTOR_CLOSURES_PER_WAKEUP, value); |
|
|
|
|
|
|
|
return; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
union { |
|
|
|
|
|
|
|
double dbl; |
|
|
|
|
|
|
|
uint64_t uint; |
|
|
|
|
|
|
|
} _val, _bkt; |
|
|
|
|
|
|
|
_val.dbl = value; |
|
|
|
|
|
|
|
if (_val.uint < 4637863191261478912ull) { |
|
|
|
|
|
|
|
int bucket = |
|
|
|
|
|
|
|
grpc_stats_table_7[((_val.uint - 4623507967449235456ull) >> 48)] + 13; |
|
|
|
|
|
|
|
_bkt.dbl = grpc_stats_table_6[bucket]; |
|
|
|
|
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
|
|
|
|
GRPC_STATS_INC_HISTOGRAM( |
|
|
|
|
|
|
|
(exec_ctx), GRPC_STATS_HISTOGRAM_EXECUTOR_CLOSURES_PER_WAKEUP, bucket); |
|
|
|
|
|
|
|
return; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
|
|
|
|
GRPC_STATS_HISTOGRAM_EXECUTOR_CLOSURES_PER_WAKEUP, |
|
|
|
|
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
|
|
|
|
(exec_ctx), value, grpc_stats_table_6, 64)); |
|
|
|
} |
|
|
|
} |
|
|
|
void grpc_stats_inc_server_cqs_checked(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
void grpc_stats_inc_server_cqs_checked(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
|
|
|
|
/* Automatically generated by tools/codegen/core/gen_stats_data.py */ |
|
|
|
value = GPR_CLAMP(value, 0, 64); |
|
|
|
value = GPR_CLAMP(value, 0, 64); |
|
|
|
if (value < 3) { |
|
|
|
if (value < 3) { |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
@ -448,8 +649,8 @@ void grpc_stats_inc_server_cqs_checked(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
_val.dbl = value; |
|
|
|
_val.dbl = value; |
|
|
|
if (_val.uint < 4625196817309499392ull) { |
|
|
|
if (_val.uint < 4625196817309499392ull) { |
|
|
|
int bucket = |
|
|
|
int bucket = |
|
|
|
grpc_stats_table_5[((_val.uint - 4613937818241073152ull) >> 51)] + 3; |
|
|
|
grpc_stats_table_9[((_val.uint - 4613937818241073152ull) >> 51)] + 3; |
|
|
|
_bkt.dbl = grpc_stats_table_4[bucket]; |
|
|
|
_bkt.dbl = grpc_stats_table_8[bucket]; |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
bucket -= (_val.uint < _bkt.uint); |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), |
|
|
|
GRPC_STATS_HISTOGRAM_SERVER_CQS_CHECKED, bucket); |
|
|
|
GRPC_STATS_HISTOGRAM_SERVER_CQS_CHECKED, bucket); |
|
|
@ -457,18 +658,21 @@ void grpc_stats_inc_server_cqs_checked(grpc_exec_ctx *exec_ctx, int value) { |
|
|
|
} |
|
|
|
} |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_SERVER_CQS_CHECKED, |
|
|
|
GRPC_STATS_INC_HISTOGRAM((exec_ctx), GRPC_STATS_HISTOGRAM_SERVER_CQS_CHECKED, |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
grpc_stats_histo_find_bucket_slow( |
|
|
|
(exec_ctx), value, grpc_stats_table_4, 8)); |
|
|
|
(exec_ctx), value, grpc_stats_table_8, 8)); |
|
|
|
} |
|
|
|
} |
|
|
|
const int grpc_stats_histo_buckets[11] = {64, 64, 64, 64, 64, 64, |
|
|
|
const int grpc_stats_histo_buckets[14] = {64, 128, 64, 64, 64, 64, 64, |
|
|
|
64, 64, 64, 64, 8}; |
|
|
|
64, 64, 64, 64, 64, 64, 8}; |
|
|
|
const int grpc_stats_histo_start[11] = {0, 64, 128, 192, 256, 320, |
|
|
|
const int grpc_stats_histo_start[14] = {0, 64, 192, 256, 320, 384, 448, |
|
|
|
384, 448, 512, 576, 640}; |
|
|
|
512, 576, 640, 704, 768, 832, 896}; |
|
|
|
const int *const grpc_stats_histo_bucket_boundaries[11] = { |
|
|
|
const int *const grpc_stats_histo_bucket_boundaries[14] = { |
|
|
|
grpc_stats_table_0, grpc_stats_table_2, grpc_stats_table_0, |
|
|
|
grpc_stats_table_0, grpc_stats_table_2, grpc_stats_table_4, |
|
|
|
grpc_stats_table_0, grpc_stats_table_2, grpc_stats_table_0, |
|
|
|
grpc_stats_table_6, grpc_stats_table_4, grpc_stats_table_4, |
|
|
|
grpc_stats_table_2, grpc_stats_table_2, grpc_stats_table_2, |
|
|
|
grpc_stats_table_6, grpc_stats_table_4, grpc_stats_table_6, |
|
|
|
grpc_stats_table_2, grpc_stats_table_4}; |
|
|
|
grpc_stats_table_6, grpc_stats_table_6, grpc_stats_table_6, |
|
|
|
void (*const grpc_stats_inc_histogram[11])(grpc_exec_ctx *exec_ctx, int x) = { |
|
|
|
grpc_stats_table_6, grpc_stats_table_8}; |
|
|
|
|
|
|
|
void (*const grpc_stats_inc_histogram[14])(grpc_exec_ctx *exec_ctx, int x) = { |
|
|
|
|
|
|
|
grpc_stats_inc_call_initial_size, |
|
|
|
|
|
|
|
grpc_stats_inc_poll_events_returned, |
|
|
|
grpc_stats_inc_tcp_write_size, |
|
|
|
grpc_stats_inc_tcp_write_size, |
|
|
|
grpc_stats_inc_tcp_write_iov_size, |
|
|
|
grpc_stats_inc_tcp_write_iov_size, |
|
|
|
grpc_stats_inc_tcp_read_size, |
|
|
|
grpc_stats_inc_tcp_read_size, |
|
|
@ -479,4 +683,5 @@ void (*const grpc_stats_inc_histogram[11])(grpc_exec_ctx *exec_ctx, int x) = { |
|
|
|
grpc_stats_inc_http2_send_message_per_write, |
|
|
|
grpc_stats_inc_http2_send_message_per_write, |
|
|
|
grpc_stats_inc_http2_send_trailing_metadata_per_write, |
|
|
|
grpc_stats_inc_http2_send_trailing_metadata_per_write, |
|
|
|
grpc_stats_inc_http2_send_flowctl_per_write, |
|
|
|
grpc_stats_inc_http2_send_flowctl_per_write, |
|
|
|
|
|
|
|
grpc_stats_inc_executor_closures_per_wakeup, |
|
|
|
grpc_stats_inc_server_cqs_checked}; |
|
|
|
grpc_stats_inc_server_cqs_checked}; |
|
|
|