| Craig Tiller | f11a40d | 2017-09-12 10:54:20 -0700 | [diff] [blame] | 1 | # Copyright 2017 gRPC authors. |
| 2 | # |
| 3 | # Licensed under the Apache License, Version 2.0 (the "License"); |
| 4 | # you may not use this file except in compliance with the License. |
| 5 | # You may obtain a copy of the License at |
| 6 | # |
| 7 | # http://www.apache.org/licenses/LICENSE-2.0 |
| 8 | # |
| 9 | # Unless required by applicable law or agreed to in writing, software |
| 10 | # distributed under the License is distributed on an "AS IS" BASIS, |
| 11 | # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 12 | # See the License for the specific language governing permissions and |
| 13 | # limitations under the License. |
| 14 | |
| 15 | # Autogenerated by tools/codegen/core/gen_stats_data.py |
| 16 | |
| 17 | import massage_qps_stats_helpers |
| ncteisen | eb12815 | 2017-12-11 17:48:24 -0800 | [diff] [blame] | 18 | |
| 19 | |
| Craig Tiller | f11a40d | 2017-09-12 10:54:20 -0700 | [diff] [blame] | 20 | def massage_qps_stats(scenario_result): |
| Mehrdad Afshari | 87cd994 | 2018-01-02 14:40:00 -0800 | [diff] [blame] | 21 | for stats in scenario_result["serverStats"] + scenario_result["clientStats"]: |
| ncteisen | eb12815 | 2017-12-11 17:48:24 -0800 | [diff] [blame] | 22 | if "coreStats" not in stats: return |
| 23 | core_stats = stats["coreStats"] |
| 24 | del stats["coreStats"] |
| 25 | stats["core_client_calls_created"] = massage_qps_stats_helpers.counter( |
| 26 | core_stats, "client_calls_created") |
| 27 | stats["core_server_calls_created"] = massage_qps_stats_helpers.counter( |
| 28 | core_stats, "server_calls_created") |
| 29 | stats["core_cqs_created"] = massage_qps_stats_helpers.counter( |
| 30 | core_stats, "cqs_created") |
| 31 | stats[ |
| 32 | "core_client_channels_created"] = massage_qps_stats_helpers.counter( |
| 33 | core_stats, "client_channels_created") |
| 34 | stats[ |
| 35 | "core_client_subchannels_created"] = massage_qps_stats_helpers.counter( |
| 36 | core_stats, "client_subchannels_created") |
| 37 | stats[ |
| 38 | "core_server_channels_created"] = massage_qps_stats_helpers.counter( |
| 39 | core_stats, "server_channels_created") |
| 40 | stats["core_syscall_poll"] = massage_qps_stats_helpers.counter( |
| 41 | core_stats, "syscall_poll") |
| 42 | stats["core_syscall_wait"] = massage_qps_stats_helpers.counter( |
| 43 | core_stats, "syscall_wait") |
| 44 | stats["core_pollset_kick"] = massage_qps_stats_helpers.counter( |
| 45 | core_stats, "pollset_kick") |
| 46 | stats[ |
| 47 | "core_pollset_kicked_without_poller"] = massage_qps_stats_helpers.counter( |
| 48 | core_stats, "pollset_kicked_without_poller") |
| 49 | stats["core_pollset_kicked_again"] = massage_qps_stats_helpers.counter( |
| 50 | core_stats, "pollset_kicked_again") |
| 51 | stats[ |
| 52 | "core_pollset_kick_wakeup_fd"] = massage_qps_stats_helpers.counter( |
| 53 | core_stats, "pollset_kick_wakeup_fd") |
| 54 | stats[ |
| 55 | "core_pollset_kick_wakeup_cv"] = massage_qps_stats_helpers.counter( |
| 56 | core_stats, "pollset_kick_wakeup_cv") |
| 57 | stats[ |
| 58 | "core_pollset_kick_own_thread"] = massage_qps_stats_helpers.counter( |
| 59 | core_stats, "pollset_kick_own_thread") |
| 60 | stats[ |
| 61 | "core_histogram_slow_lookups"] = massage_qps_stats_helpers.counter( |
| 62 | core_stats, "histogram_slow_lookups") |
| 63 | stats["core_syscall_write"] = massage_qps_stats_helpers.counter( |
| 64 | core_stats, "syscall_write") |
| 65 | stats["core_syscall_read"] = massage_qps_stats_helpers.counter( |
| 66 | core_stats, "syscall_read") |
| 67 | stats[ |
| 68 | "core_tcp_backup_pollers_created"] = massage_qps_stats_helpers.counter( |
| 69 | core_stats, "tcp_backup_pollers_created") |
| 70 | stats[ |
| 71 | "core_tcp_backup_poller_polls"] = massage_qps_stats_helpers.counter( |
| 72 | core_stats, "tcp_backup_poller_polls") |
| 73 | stats["core_http2_op_batches"] = massage_qps_stats_helpers.counter( |
| 74 | core_stats, "http2_op_batches") |
| 75 | stats["core_http2_op_cancel"] = massage_qps_stats_helpers.counter( |
| 76 | core_stats, "http2_op_cancel") |
| 77 | stats[ |
| 78 | "core_http2_op_send_initial_metadata"] = massage_qps_stats_helpers.counter( |
| 79 | core_stats, "http2_op_send_initial_metadata") |
| 80 | stats["core_http2_op_send_message"] = massage_qps_stats_helpers.counter( |
| 81 | core_stats, "http2_op_send_message") |
| 82 | stats[ |
| 83 | "core_http2_op_send_trailing_metadata"] = massage_qps_stats_helpers.counter( |
| 84 | core_stats, "http2_op_send_trailing_metadata") |
| 85 | stats[ |
| 86 | "core_http2_op_recv_initial_metadata"] = massage_qps_stats_helpers.counter( |
| 87 | core_stats, "http2_op_recv_initial_metadata") |
| 88 | stats["core_http2_op_recv_message"] = massage_qps_stats_helpers.counter( |
| 89 | core_stats, "http2_op_recv_message") |
| 90 | stats[ |
| 91 | "core_http2_op_recv_trailing_metadata"] = massage_qps_stats_helpers.counter( |
| 92 | core_stats, "http2_op_recv_trailing_metadata") |
| 93 | stats["core_http2_settings_writes"] = massage_qps_stats_helpers.counter( |
| 94 | core_stats, "http2_settings_writes") |
| 95 | stats["core_http2_pings_sent"] = massage_qps_stats_helpers.counter( |
| 96 | core_stats, "http2_pings_sent") |
| 97 | stats["core_http2_writes_begun"] = massage_qps_stats_helpers.counter( |
| 98 | core_stats, "http2_writes_begun") |
| 99 | stats[ |
| 100 | "core_http2_writes_offloaded"] = massage_qps_stats_helpers.counter( |
| 101 | core_stats, "http2_writes_offloaded") |
| 102 | stats[ |
| 103 | "core_http2_writes_continued"] = massage_qps_stats_helpers.counter( |
| 104 | core_stats, "http2_writes_continued") |
| 105 | stats["core_http2_partial_writes"] = massage_qps_stats_helpers.counter( |
| 106 | core_stats, "http2_partial_writes") |
| 107 | stats[ |
| 108 | "core_http2_initiate_write_due_to_initial_write"] = massage_qps_stats_helpers.counter( |
| 109 | core_stats, "http2_initiate_write_due_to_initial_write") |
| 110 | stats[ |
| 111 | "core_http2_initiate_write_due_to_start_new_stream"] = massage_qps_stats_helpers.counter( |
| 112 | core_stats, "http2_initiate_write_due_to_start_new_stream") |
| 113 | stats[ |
| 114 | "core_http2_initiate_write_due_to_send_message"] = massage_qps_stats_helpers.counter( |
| 115 | core_stats, "http2_initiate_write_due_to_send_message") |
| 116 | stats[ |
| 117 | "core_http2_initiate_write_due_to_send_initial_metadata"] = massage_qps_stats_helpers.counter( |
| 118 | core_stats, "http2_initiate_write_due_to_send_initial_metadata") |
| 119 | stats[ |
| 120 | "core_http2_initiate_write_due_to_send_trailing_metadata"] = massage_qps_stats_helpers.counter( |
| 121 | core_stats, |
| 122 | "http2_initiate_write_due_to_send_trailing_metadata") |
| 123 | stats[ |
| 124 | "core_http2_initiate_write_due_to_retry_send_ping"] = massage_qps_stats_helpers.counter( |
| 125 | core_stats, "http2_initiate_write_due_to_retry_send_ping") |
| 126 | stats[ |
| 127 | "core_http2_initiate_write_due_to_continue_pings"] = massage_qps_stats_helpers.counter( |
| 128 | core_stats, "http2_initiate_write_due_to_continue_pings") |
| 129 | stats[ |
| 130 | "core_http2_initiate_write_due_to_goaway_sent"] = massage_qps_stats_helpers.counter( |
| 131 | core_stats, "http2_initiate_write_due_to_goaway_sent") |
| 132 | stats[ |
| 133 | "core_http2_initiate_write_due_to_rst_stream"] = massage_qps_stats_helpers.counter( |
| 134 | core_stats, "http2_initiate_write_due_to_rst_stream") |
| 135 | stats[ |
| 136 | "core_http2_initiate_write_due_to_close_from_api"] = massage_qps_stats_helpers.counter( |
| 137 | core_stats, "http2_initiate_write_due_to_close_from_api") |
| 138 | stats[ |
| 139 | "core_http2_initiate_write_due_to_stream_flow_control"] = massage_qps_stats_helpers.counter( |
| 140 | core_stats, "http2_initiate_write_due_to_stream_flow_control") |
| 141 | stats[ |
| 142 | "core_http2_initiate_write_due_to_transport_flow_control"] = massage_qps_stats_helpers.counter( |
| 143 | core_stats, |
| 144 | "http2_initiate_write_due_to_transport_flow_control") |
| 145 | stats[ |
| 146 | "core_http2_initiate_write_due_to_send_settings"] = massage_qps_stats_helpers.counter( |
| 147 | core_stats, "http2_initiate_write_due_to_send_settings") |
| 148 | stats[ |
| 149 | "core_http2_initiate_write_due_to_bdp_estimator_ping"] = massage_qps_stats_helpers.counter( |
| 150 | core_stats, "http2_initiate_write_due_to_bdp_estimator_ping") |
| 151 | stats[ |
| 152 | "core_http2_initiate_write_due_to_flow_control_unstalled_by_setting"] = massage_qps_stats_helpers.counter( |
| 153 | core_stats, |
| 154 | "http2_initiate_write_due_to_flow_control_unstalled_by_setting") |
| 155 | stats[ |
| 156 | "core_http2_initiate_write_due_to_flow_control_unstalled_by_update"] = massage_qps_stats_helpers.counter( |
| 157 | core_stats, |
| 158 | "http2_initiate_write_due_to_flow_control_unstalled_by_update") |
| 159 | stats[ |
| 160 | "core_http2_initiate_write_due_to_application_ping"] = massage_qps_stats_helpers.counter( |
| 161 | core_stats, "http2_initiate_write_due_to_application_ping") |
| 162 | stats[ |
| 163 | "core_http2_initiate_write_due_to_keepalive_ping"] = massage_qps_stats_helpers.counter( |
| 164 | core_stats, "http2_initiate_write_due_to_keepalive_ping") |
| 165 | stats[ |
| 166 | "core_http2_initiate_write_due_to_transport_flow_control_unstalled"] = massage_qps_stats_helpers.counter( |
| 167 | core_stats, |
| 168 | "http2_initiate_write_due_to_transport_flow_control_unstalled") |
| 169 | stats[ |
| 170 | "core_http2_initiate_write_due_to_ping_response"] = massage_qps_stats_helpers.counter( |
| 171 | core_stats, "http2_initiate_write_due_to_ping_response") |
| 172 | stats[ |
| 173 | "core_http2_initiate_write_due_to_force_rst_stream"] = massage_qps_stats_helpers.counter( |
| 174 | core_stats, "http2_initiate_write_due_to_force_rst_stream") |
| 175 | stats[ |
| 176 | "core_http2_spurious_writes_begun"] = massage_qps_stats_helpers.counter( |
| 177 | core_stats, "http2_spurious_writes_begun") |
| 178 | stats["core_hpack_recv_indexed"] = massage_qps_stats_helpers.counter( |
| 179 | core_stats, "hpack_recv_indexed") |
| 180 | stats[ |
| 181 | "core_hpack_recv_lithdr_incidx"] = massage_qps_stats_helpers.counter( |
| 182 | core_stats, "hpack_recv_lithdr_incidx") |
| 183 | stats[ |
| 184 | "core_hpack_recv_lithdr_incidx_v"] = massage_qps_stats_helpers.counter( |
| 185 | core_stats, "hpack_recv_lithdr_incidx_v") |
| 186 | stats[ |
| 187 | "core_hpack_recv_lithdr_notidx"] = massage_qps_stats_helpers.counter( |
| 188 | core_stats, "hpack_recv_lithdr_notidx") |
| 189 | stats[ |
| 190 | "core_hpack_recv_lithdr_notidx_v"] = massage_qps_stats_helpers.counter( |
| 191 | core_stats, "hpack_recv_lithdr_notidx_v") |
| 192 | stats[ |
| 193 | "core_hpack_recv_lithdr_nvridx"] = massage_qps_stats_helpers.counter( |
| 194 | core_stats, "hpack_recv_lithdr_nvridx") |
| 195 | stats[ |
| 196 | "core_hpack_recv_lithdr_nvridx_v"] = massage_qps_stats_helpers.counter( |
| 197 | core_stats, "hpack_recv_lithdr_nvridx_v") |
| 198 | stats[ |
| 199 | "core_hpack_recv_uncompressed"] = massage_qps_stats_helpers.counter( |
| 200 | core_stats, "hpack_recv_uncompressed") |
| 201 | stats["core_hpack_recv_huffman"] = massage_qps_stats_helpers.counter( |
| 202 | core_stats, "hpack_recv_huffman") |
| 203 | stats["core_hpack_recv_binary"] = massage_qps_stats_helpers.counter( |
| 204 | core_stats, "hpack_recv_binary") |
| 205 | stats[ |
| 206 | "core_hpack_recv_binary_base64"] = massage_qps_stats_helpers.counter( |
| 207 | core_stats, "hpack_recv_binary_base64") |
| 208 | stats["core_hpack_send_indexed"] = massage_qps_stats_helpers.counter( |
| 209 | core_stats, "hpack_send_indexed") |
| 210 | stats[ |
| 211 | "core_hpack_send_lithdr_incidx"] = massage_qps_stats_helpers.counter( |
| 212 | core_stats, "hpack_send_lithdr_incidx") |
| 213 | stats[ |
| 214 | "core_hpack_send_lithdr_incidx_v"] = massage_qps_stats_helpers.counter( |
| 215 | core_stats, "hpack_send_lithdr_incidx_v") |
| 216 | stats[ |
| 217 | "core_hpack_send_lithdr_notidx"] = massage_qps_stats_helpers.counter( |
| 218 | core_stats, "hpack_send_lithdr_notidx") |
| 219 | stats[ |
| 220 | "core_hpack_send_lithdr_notidx_v"] = massage_qps_stats_helpers.counter( |
| 221 | core_stats, "hpack_send_lithdr_notidx_v") |
| 222 | stats[ |
| 223 | "core_hpack_send_lithdr_nvridx"] = massage_qps_stats_helpers.counter( |
| 224 | core_stats, "hpack_send_lithdr_nvridx") |
| 225 | stats[ |
| 226 | "core_hpack_send_lithdr_nvridx_v"] = massage_qps_stats_helpers.counter( |
| 227 | core_stats, "hpack_send_lithdr_nvridx_v") |
| 228 | stats[ |
| 229 | "core_hpack_send_uncompressed"] = massage_qps_stats_helpers.counter( |
| 230 | core_stats, "hpack_send_uncompressed") |
| 231 | stats["core_hpack_send_huffman"] = massage_qps_stats_helpers.counter( |
| 232 | core_stats, "hpack_send_huffman") |
| 233 | stats["core_hpack_send_binary"] = massage_qps_stats_helpers.counter( |
| 234 | core_stats, "hpack_send_binary") |
| 235 | stats[ |
| 236 | "core_hpack_send_binary_base64"] = massage_qps_stats_helpers.counter( |
| 237 | core_stats, "hpack_send_binary_base64") |
| 238 | stats[ |
| 239 | "core_combiner_locks_initiated"] = massage_qps_stats_helpers.counter( |
| 240 | core_stats, "combiner_locks_initiated") |
| 241 | stats[ |
| 242 | "core_combiner_locks_scheduled_items"] = massage_qps_stats_helpers.counter( |
| 243 | core_stats, "combiner_locks_scheduled_items") |
| 244 | stats[ |
| 245 | "core_combiner_locks_scheduled_final_items"] = massage_qps_stats_helpers.counter( |
| 246 | core_stats, "combiner_locks_scheduled_final_items") |
| 247 | stats[ |
| 248 | "core_combiner_locks_offloaded"] = massage_qps_stats_helpers.counter( |
| 249 | core_stats, "combiner_locks_offloaded") |
| 250 | stats[ |
| 251 | "core_call_combiner_locks_initiated"] = massage_qps_stats_helpers.counter( |
| 252 | core_stats, "call_combiner_locks_initiated") |
| 253 | stats[ |
| 254 | "core_call_combiner_locks_scheduled_items"] = massage_qps_stats_helpers.counter( |
| 255 | core_stats, "call_combiner_locks_scheduled_items") |
| 256 | stats[ |
| 257 | "core_call_combiner_set_notify_on_cancel"] = massage_qps_stats_helpers.counter( |
| 258 | core_stats, "call_combiner_set_notify_on_cancel") |
| 259 | stats[ |
| 260 | "core_call_combiner_cancelled"] = massage_qps_stats_helpers.counter( |
| 261 | core_stats, "call_combiner_cancelled") |
| 262 | stats[ |
| 263 | "core_executor_scheduled_short_items"] = massage_qps_stats_helpers.counter( |
| 264 | core_stats, "executor_scheduled_short_items") |
| 265 | stats[ |
| 266 | "core_executor_scheduled_long_items"] = massage_qps_stats_helpers.counter( |
| 267 | core_stats, "executor_scheduled_long_items") |
| 268 | stats[ |
| 269 | "core_executor_scheduled_to_self"] = massage_qps_stats_helpers.counter( |
| 270 | core_stats, "executor_scheduled_to_self") |
| 271 | stats[ |
| 272 | "core_executor_wakeup_initiated"] = massage_qps_stats_helpers.counter( |
| 273 | core_stats, "executor_wakeup_initiated") |
| 274 | stats[ |
| 275 | "core_executor_queue_drained"] = massage_qps_stats_helpers.counter( |
| 276 | core_stats, "executor_queue_drained") |
| 277 | stats["core_executor_push_retries"] = massage_qps_stats_helpers.counter( |
| 278 | core_stats, "executor_push_retries") |
| 279 | stats[ |
| 280 | "core_server_requested_calls"] = massage_qps_stats_helpers.counter( |
| 281 | core_stats, "server_requested_calls") |
| 282 | stats[ |
| 283 | "core_server_slowpath_requests_queued"] = massage_qps_stats_helpers.counter( |
| 284 | core_stats, "server_slowpath_requests_queued") |
| 285 | stats[ |
| 286 | "core_cq_ev_queue_trylock_failures"] = massage_qps_stats_helpers.counter( |
| 287 | core_stats, "cq_ev_queue_trylock_failures") |
| 288 | stats[ |
| 289 | "core_cq_ev_queue_trylock_successes"] = massage_qps_stats_helpers.counter( |
| 290 | core_stats, "cq_ev_queue_trylock_successes") |
| 291 | stats[ |
| 292 | "core_cq_ev_queue_transient_pop_failures"] = massage_qps_stats_helpers.counter( |
| 293 | core_stats, "cq_ev_queue_transient_pop_failures") |
| 294 | h = massage_qps_stats_helpers.histogram(core_stats, "call_initial_size") |
| 295 | stats["core_call_initial_size"] = ",".join("%f" % x for x in h.buckets) |
| Mehrdad Afshari | 87cd994 | 2018-01-02 14:40:00 -0800 | [diff] [blame] | 296 | stats["core_call_initial_size_bkts"] = ",".join( |
| 297 | "%f" % x for x in h.boundaries) |
| ncteisen | eb12815 | 2017-12-11 17:48:24 -0800 | [diff] [blame] | 298 | stats[ |
| 299 | "core_call_initial_size_50p"] = massage_qps_stats_helpers.percentile( |
| 300 | h.buckets, 50, h.boundaries) |
| 301 | stats[ |
| 302 | "core_call_initial_size_95p"] = massage_qps_stats_helpers.percentile( |
| 303 | h.buckets, 95, h.boundaries) |
| 304 | stats[ |
| 305 | "core_call_initial_size_99p"] = massage_qps_stats_helpers.percentile( |
| 306 | h.buckets, 99, h.boundaries) |
| 307 | h = massage_qps_stats_helpers.histogram(core_stats, |
| 308 | "poll_events_returned") |
| Mehrdad Afshari | 87cd994 | 2018-01-02 14:40:00 -0800 | [diff] [blame] | 309 | stats["core_poll_events_returned"] = ",".join( |
| 310 | "%f" % x for x in h.buckets) |
| ncteisen | eb12815 | 2017-12-11 17:48:24 -0800 | [diff] [blame] | 311 | stats["core_poll_events_returned_bkts"] = ",".join( |
| 312 | "%f" % x for x in h.boundaries) |
| 313 | stats[ |
| 314 | "core_poll_events_returned_50p"] = massage_qps_stats_helpers.percentile( |
| 315 | h.buckets, 50, h.boundaries) |
| 316 | stats[ |
| 317 | "core_poll_events_returned_95p"] = massage_qps_stats_helpers.percentile( |
| 318 | h.buckets, 95, h.boundaries) |
| 319 | stats[ |
| 320 | "core_poll_events_returned_99p"] = massage_qps_stats_helpers.percentile( |
| 321 | h.buckets, 99, h.boundaries) |
| 322 | h = massage_qps_stats_helpers.histogram(core_stats, "tcp_write_size") |
| 323 | stats["core_tcp_write_size"] = ",".join("%f" % x for x in h.buckets) |
| Mehrdad Afshari | 87cd994 | 2018-01-02 14:40:00 -0800 | [diff] [blame] | 324 | stats["core_tcp_write_size_bkts"] = ",".join( |
| 325 | "%f" % x for x in h.boundaries) |
| ncteisen | eb12815 | 2017-12-11 17:48:24 -0800 | [diff] [blame] | 326 | stats["core_tcp_write_size_50p"] = massage_qps_stats_helpers.percentile( |
| 327 | h.buckets, 50, h.boundaries) |
| 328 | stats["core_tcp_write_size_95p"] = massage_qps_stats_helpers.percentile( |
| 329 | h.buckets, 95, h.boundaries) |
| 330 | stats["core_tcp_write_size_99p"] = massage_qps_stats_helpers.percentile( |
| 331 | h.buckets, 99, h.boundaries) |
| 332 | h = massage_qps_stats_helpers.histogram(core_stats, |
| 333 | "tcp_write_iov_size") |
| 334 | stats["core_tcp_write_iov_size"] = ",".join("%f" % x for x in h.buckets) |
| Mehrdad Afshari | 87cd994 | 2018-01-02 14:40:00 -0800 | [diff] [blame] | 335 | stats["core_tcp_write_iov_size_bkts"] = ",".join( |
| 336 | "%f" % x for x in h.boundaries) |
| ncteisen | eb12815 | 2017-12-11 17:48:24 -0800 | [diff] [blame] | 337 | stats[ |
| 338 | "core_tcp_write_iov_size_50p"] = massage_qps_stats_helpers.percentile( |
| 339 | h.buckets, 50, h.boundaries) |
| 340 | stats[ |
| 341 | "core_tcp_write_iov_size_95p"] = massage_qps_stats_helpers.percentile( |
| 342 | h.buckets, 95, h.boundaries) |
| 343 | stats[ |
| 344 | "core_tcp_write_iov_size_99p"] = massage_qps_stats_helpers.percentile( |
| 345 | h.buckets, 99, h.boundaries) |
| 346 | h = massage_qps_stats_helpers.histogram(core_stats, "tcp_read_size") |
| 347 | stats["core_tcp_read_size"] = ",".join("%f" % x for x in h.buckets) |
| Mehrdad Afshari | 87cd994 | 2018-01-02 14:40:00 -0800 | [diff] [blame] | 348 | stats["core_tcp_read_size_bkts"] = ",".join( |
| 349 | "%f" % x for x in h.boundaries) |
| ncteisen | eb12815 | 2017-12-11 17:48:24 -0800 | [diff] [blame] | 350 | stats["core_tcp_read_size_50p"] = massage_qps_stats_helpers.percentile( |
| 351 | h.buckets, 50, h.boundaries) |
| 352 | stats["core_tcp_read_size_95p"] = massage_qps_stats_helpers.percentile( |
| 353 | h.buckets, 95, h.boundaries) |
| 354 | stats["core_tcp_read_size_99p"] = massage_qps_stats_helpers.percentile( |
| 355 | h.buckets, 99, h.boundaries) |
| 356 | h = massage_qps_stats_helpers.histogram(core_stats, "tcp_read_offer") |
| 357 | stats["core_tcp_read_offer"] = ",".join("%f" % x for x in h.buckets) |
| Mehrdad Afshari | 87cd994 | 2018-01-02 14:40:00 -0800 | [diff] [blame] | 358 | stats["core_tcp_read_offer_bkts"] = ",".join( |
| 359 | "%f" % x for x in h.boundaries) |
| ncteisen | eb12815 | 2017-12-11 17:48:24 -0800 | [diff] [blame] | 360 | stats["core_tcp_read_offer_50p"] = massage_qps_stats_helpers.percentile( |
| 361 | h.buckets, 50, h.boundaries) |
| 362 | stats["core_tcp_read_offer_95p"] = massage_qps_stats_helpers.percentile( |
| 363 | h.buckets, 95, h.boundaries) |
| 364 | stats["core_tcp_read_offer_99p"] = massage_qps_stats_helpers.percentile( |
| 365 | h.buckets, 99, h.boundaries) |
| 366 | h = massage_qps_stats_helpers.histogram(core_stats, |
| 367 | "tcp_read_offer_iov_size") |
| Mehrdad Afshari | 87cd994 | 2018-01-02 14:40:00 -0800 | [diff] [blame] | 368 | stats["core_tcp_read_offer_iov_size"] = ",".join( |
| 369 | "%f" % x for x in h.buckets) |
| ncteisen | eb12815 | 2017-12-11 17:48:24 -0800 | [diff] [blame] | 370 | stats["core_tcp_read_offer_iov_size_bkts"] = ",".join( |
| 371 | "%f" % x for x in h.boundaries) |
| 372 | stats[ |
| 373 | "core_tcp_read_offer_iov_size_50p"] = massage_qps_stats_helpers.percentile( |
| 374 | h.buckets, 50, h.boundaries) |
| 375 | stats[ |
| 376 | "core_tcp_read_offer_iov_size_95p"] = massage_qps_stats_helpers.percentile( |
| 377 | h.buckets, 95, h.boundaries) |
| 378 | stats[ |
| 379 | "core_tcp_read_offer_iov_size_99p"] = massage_qps_stats_helpers.percentile( |
| 380 | h.buckets, 99, h.boundaries) |
| 381 | h = massage_qps_stats_helpers.histogram(core_stats, |
| 382 | "http2_send_message_size") |
| Mehrdad Afshari | 87cd994 | 2018-01-02 14:40:00 -0800 | [diff] [blame] | 383 | stats["core_http2_send_message_size"] = ",".join( |
| 384 | "%f" % x for x in h.buckets) |
| ncteisen | eb12815 | 2017-12-11 17:48:24 -0800 | [diff] [blame] | 385 | stats["core_http2_send_message_size_bkts"] = ",".join( |
| 386 | "%f" % x for x in h.boundaries) |
| 387 | stats[ |
| 388 | "core_http2_send_message_size_50p"] = massage_qps_stats_helpers.percentile( |
| 389 | h.buckets, 50, h.boundaries) |
| 390 | stats[ |
| 391 | "core_http2_send_message_size_95p"] = massage_qps_stats_helpers.percentile( |
| 392 | h.buckets, 95, h.boundaries) |
| 393 | stats[ |
| 394 | "core_http2_send_message_size_99p"] = massage_qps_stats_helpers.percentile( |
| 395 | h.buckets, 99, h.boundaries) |
| 396 | h = massage_qps_stats_helpers.histogram( |
| 397 | core_stats, "http2_send_initial_metadata_per_write") |
| 398 | stats["core_http2_send_initial_metadata_per_write"] = ",".join( |
| 399 | "%f" % x for x in h.buckets) |
| 400 | stats["core_http2_send_initial_metadata_per_write_bkts"] = ",".join( |
| 401 | "%f" % x for x in h.boundaries) |
| 402 | stats[ |
| 403 | "core_http2_send_initial_metadata_per_write_50p"] = massage_qps_stats_helpers.percentile( |
| 404 | h.buckets, 50, h.boundaries) |
| 405 | stats[ |
| 406 | "core_http2_send_initial_metadata_per_write_95p"] = massage_qps_stats_helpers.percentile( |
| 407 | h.buckets, 95, h.boundaries) |
| 408 | stats[ |
| 409 | "core_http2_send_initial_metadata_per_write_99p"] = massage_qps_stats_helpers.percentile( |
| 410 | h.buckets, 99, h.boundaries) |
| 411 | h = massage_qps_stats_helpers.histogram(core_stats, |
| 412 | "http2_send_message_per_write") |
| 413 | stats["core_http2_send_message_per_write"] = ",".join( |
| 414 | "%f" % x for x in h.buckets) |
| 415 | stats["core_http2_send_message_per_write_bkts"] = ",".join( |
| 416 | "%f" % x for x in h.boundaries) |
| 417 | stats[ |
| 418 | "core_http2_send_message_per_write_50p"] = massage_qps_stats_helpers.percentile( |
| 419 | h.buckets, 50, h.boundaries) |
| 420 | stats[ |
| 421 | "core_http2_send_message_per_write_95p"] = massage_qps_stats_helpers.percentile( |
| 422 | h.buckets, 95, h.boundaries) |
| 423 | stats[ |
| 424 | "core_http2_send_message_per_write_99p"] = massage_qps_stats_helpers.percentile( |
| 425 | h.buckets, 99, h.boundaries) |
| 426 | h = massage_qps_stats_helpers.histogram( |
| 427 | core_stats, "http2_send_trailing_metadata_per_write") |
| 428 | stats["core_http2_send_trailing_metadata_per_write"] = ",".join( |
| 429 | "%f" % x for x in h.buckets) |
| 430 | stats["core_http2_send_trailing_metadata_per_write_bkts"] = ",".join( |
| 431 | "%f" % x for x in h.boundaries) |
| 432 | stats[ |
| 433 | "core_http2_send_trailing_metadata_per_write_50p"] = massage_qps_stats_helpers.percentile( |
| 434 | h.buckets, 50, h.boundaries) |
| 435 | stats[ |
| 436 | "core_http2_send_trailing_metadata_per_write_95p"] = massage_qps_stats_helpers.percentile( |
| 437 | h.buckets, 95, h.boundaries) |
| 438 | stats[ |
| 439 | "core_http2_send_trailing_metadata_per_write_99p"] = massage_qps_stats_helpers.percentile( |
| 440 | h.buckets, 99, h.boundaries) |
| 441 | h = massage_qps_stats_helpers.histogram(core_stats, |
| 442 | "http2_send_flowctl_per_write") |
| 443 | stats["core_http2_send_flowctl_per_write"] = ",".join( |
| 444 | "%f" % x for x in h.buckets) |
| 445 | stats["core_http2_send_flowctl_per_write_bkts"] = ",".join( |
| 446 | "%f" % x for x in h.boundaries) |
| 447 | stats[ |
| 448 | "core_http2_send_flowctl_per_write_50p"] = massage_qps_stats_helpers.percentile( |
| 449 | h.buckets, 50, h.boundaries) |
| 450 | stats[ |
| 451 | "core_http2_send_flowctl_per_write_95p"] = massage_qps_stats_helpers.percentile( |
| 452 | h.buckets, 95, h.boundaries) |
| 453 | stats[ |
| 454 | "core_http2_send_flowctl_per_write_99p"] = massage_qps_stats_helpers.percentile( |
| 455 | h.buckets, 99, h.boundaries) |
| 456 | h = massage_qps_stats_helpers.histogram(core_stats, |
| 457 | "server_cqs_checked") |
| 458 | stats["core_server_cqs_checked"] = ",".join("%f" % x for x in h.buckets) |
| Mehrdad Afshari | 87cd994 | 2018-01-02 14:40:00 -0800 | [diff] [blame] | 459 | stats["core_server_cqs_checked_bkts"] = ",".join( |
| 460 | "%f" % x for x in h.boundaries) |
| ncteisen | eb12815 | 2017-12-11 17:48:24 -0800 | [diff] [blame] | 461 | stats[ |
| 462 | "core_server_cqs_checked_50p"] = massage_qps_stats_helpers.percentile( |
| 463 | h.buckets, 50, h.boundaries) |
| 464 | stats[ |
| 465 | "core_server_cqs_checked_95p"] = massage_qps_stats_helpers.percentile( |
| 466 | h.buckets, 95, h.boundaries) |
| 467 | stats[ |
| 468 | "core_server_cqs_checked_99p"] = massage_qps_stats_helpers.percentile( |
| 469 | h.buckets, 99, h.boundaries) |