| # Copyright 2017 gRPC authors. |
| # |
| # Licensed under the Apache License, Version 2.0 (the "License"); |
| # you may not use this file except in compliance with the License. |
| # You may obtain a copy of the License at |
| # |
| # http://www.apache.org/licenses/LICENSE-2.0 |
| # |
| # Unless required by applicable law or agreed to in writing, software |
| # distributed under the License is distributed on an "AS IS" BASIS, |
| # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| # See the License for the specific language governing permissions and |
| # limitations under the License. |
| |
| # Autogenerated by tools/codegen/core/gen_stats_data.py |
| |
| import massage_qps_stats_helpers |
| def massage_qps_stats(scenario_result): |
| for stats in scenario_result["serverStats"] + scenario_result["clientStats"]: |
| if "coreStats" not in stats: return |
| core_stats = stats["coreStats"] |
| del stats["coreStats"] |
| stats["core_client_calls_created"] = massage_qps_stats_helpers.counter(core_stats, "client_calls_created") |
| stats["core_server_calls_created"] = massage_qps_stats_helpers.counter(core_stats, "server_calls_created") |
| stats["core_syscall_poll"] = massage_qps_stats_helpers.counter(core_stats, "syscall_poll") |
| stats["core_syscall_wait"] = massage_qps_stats_helpers.counter(core_stats, "syscall_wait") |
| stats["core_histogram_slow_lookups"] = massage_qps_stats_helpers.counter(core_stats, "histogram_slow_lookups") |
| stats["core_syscall_write"] = massage_qps_stats_helpers.counter(core_stats, "syscall_write") |
| stats["core_syscall_read"] = massage_qps_stats_helpers.counter(core_stats, "syscall_read") |
| stats["core_tcp_backup_pollers_created"] = massage_qps_stats_helpers.counter(core_stats, "tcp_backup_pollers_created") |
| stats["core_tcp_backup_poller_polls"] = massage_qps_stats_helpers.counter(core_stats, "tcp_backup_poller_polls") |
| stats["core_http2_op_batches"] = massage_qps_stats_helpers.counter(core_stats, "http2_op_batches") |
| stats["core_http2_op_cancel"] = massage_qps_stats_helpers.counter(core_stats, "http2_op_cancel") |
| stats["core_http2_op_send_initial_metadata"] = massage_qps_stats_helpers.counter(core_stats, "http2_op_send_initial_metadata") |
| stats["core_http2_op_send_message"] = massage_qps_stats_helpers.counter(core_stats, "http2_op_send_message") |
| stats["core_http2_op_send_trailing_metadata"] = massage_qps_stats_helpers.counter(core_stats, "http2_op_send_trailing_metadata") |
| stats["core_http2_op_recv_initial_metadata"] = massage_qps_stats_helpers.counter(core_stats, "http2_op_recv_initial_metadata") |
| stats["core_http2_op_recv_message"] = massage_qps_stats_helpers.counter(core_stats, "http2_op_recv_message") |
| stats["core_http2_op_recv_trailing_metadata"] = massage_qps_stats_helpers.counter(core_stats, "http2_op_recv_trailing_metadata") |
| stats["core_http2_settings_writes"] = massage_qps_stats_helpers.counter(core_stats, "http2_settings_writes") |
| stats["core_http2_pings_sent"] = massage_qps_stats_helpers.counter(core_stats, "http2_pings_sent") |
| stats["core_http2_writes_begun"] = massage_qps_stats_helpers.counter(core_stats, "http2_writes_begun") |
| stats["core_http2_writes_offloaded"] = massage_qps_stats_helpers.counter(core_stats, "http2_writes_offloaded") |
| stats["core_http2_writes_continued"] = massage_qps_stats_helpers.counter(core_stats, "http2_writes_continued") |
| stats["core_http2_partial_writes"] = massage_qps_stats_helpers.counter(core_stats, "http2_partial_writes") |
| stats["core_combiner_locks_initiated"] = massage_qps_stats_helpers.counter(core_stats, "combiner_locks_initiated") |
| stats["core_combiner_locks_scheduled_items"] = massage_qps_stats_helpers.counter(core_stats, "combiner_locks_scheduled_items") |
| stats["core_combiner_locks_scheduled_final_items"] = massage_qps_stats_helpers.counter(core_stats, "combiner_locks_scheduled_final_items") |
| stats["core_combiner_locks_offloaded"] = massage_qps_stats_helpers.counter(core_stats, "combiner_locks_offloaded") |
| stats["core_executor_scheduled_short_items"] = massage_qps_stats_helpers.counter(core_stats, "executor_scheduled_short_items") |
| stats["core_executor_scheduled_long_items"] = massage_qps_stats_helpers.counter(core_stats, "executor_scheduled_long_items") |
| stats["core_executor_scheduled_to_self"] = massage_qps_stats_helpers.counter(core_stats, "executor_scheduled_to_self") |
| stats["core_executor_wakeup_initiated"] = massage_qps_stats_helpers.counter(core_stats, "executor_wakeup_initiated") |
| stats["core_executor_queue_drained"] = massage_qps_stats_helpers.counter(core_stats, "executor_queue_drained") |
| stats["core_executor_push_retries"] = massage_qps_stats_helpers.counter(core_stats, "executor_push_retries") |
| stats["core_server_requested_calls"] = massage_qps_stats_helpers.counter(core_stats, "server_requested_calls") |
| stats["core_server_slowpath_requests_queued"] = massage_qps_stats_helpers.counter(core_stats, "server_slowpath_requests_queued") |
| h = massage_qps_stats_helpers.histogram(core_stats, "tcp_write_size") |
| stats["core_tcp_write_size"] = ",".join("%f" % x for x in h.buckets) |
| stats["core_tcp_write_size_bkts"] = ",".join("%f" % x for x in h.boundaries) |
| stats["core_tcp_write_size_50p"] = massage_qps_stats_helpers.percentile(h.buckets, 50, h.boundaries) |
| stats["core_tcp_write_size_95p"] = massage_qps_stats_helpers.percentile(h.buckets, 95, h.boundaries) |
| stats["core_tcp_write_size_99p"] = massage_qps_stats_helpers.percentile(h.buckets, 99, h.boundaries) |
| h = massage_qps_stats_helpers.histogram(core_stats, "tcp_write_iov_size") |
| stats["core_tcp_write_iov_size"] = ",".join("%f" % x for x in h.buckets) |
| stats["core_tcp_write_iov_size_bkts"] = ",".join("%f" % x for x in h.boundaries) |
| stats["core_tcp_write_iov_size_50p"] = massage_qps_stats_helpers.percentile(h.buckets, 50, h.boundaries) |
| stats["core_tcp_write_iov_size_95p"] = massage_qps_stats_helpers.percentile(h.buckets, 95, h.boundaries) |
| stats["core_tcp_write_iov_size_99p"] = massage_qps_stats_helpers.percentile(h.buckets, 99, h.boundaries) |
| h = massage_qps_stats_helpers.histogram(core_stats, "tcp_read_size") |
| stats["core_tcp_read_size"] = ",".join("%f" % x for x in h.buckets) |
| stats["core_tcp_read_size_bkts"] = ",".join("%f" % x for x in h.boundaries) |
| stats["core_tcp_read_size_50p"] = massage_qps_stats_helpers.percentile(h.buckets, 50, h.boundaries) |
| stats["core_tcp_read_size_95p"] = massage_qps_stats_helpers.percentile(h.buckets, 95, h.boundaries) |
| stats["core_tcp_read_size_99p"] = massage_qps_stats_helpers.percentile(h.buckets, 99, h.boundaries) |
| h = massage_qps_stats_helpers.histogram(core_stats, "tcp_read_offer") |
| stats["core_tcp_read_offer"] = ",".join("%f" % x for x in h.buckets) |
| stats["core_tcp_read_offer_bkts"] = ",".join("%f" % x for x in h.boundaries) |
| stats["core_tcp_read_offer_50p"] = massage_qps_stats_helpers.percentile(h.buckets, 50, h.boundaries) |
| stats["core_tcp_read_offer_95p"] = massage_qps_stats_helpers.percentile(h.buckets, 95, h.boundaries) |
| stats["core_tcp_read_offer_99p"] = massage_qps_stats_helpers.percentile(h.buckets, 99, h.boundaries) |
| h = massage_qps_stats_helpers.histogram(core_stats, "tcp_read_offer_iov_size") |
| stats["core_tcp_read_offer_iov_size"] = ",".join("%f" % x for x in h.buckets) |
| stats["core_tcp_read_offer_iov_size_bkts"] = ",".join("%f" % x for x in h.boundaries) |
| stats["core_tcp_read_offer_iov_size_50p"] = massage_qps_stats_helpers.percentile(h.buckets, 50, h.boundaries) |
| stats["core_tcp_read_offer_iov_size_95p"] = massage_qps_stats_helpers.percentile(h.buckets, 95, h.boundaries) |
| stats["core_tcp_read_offer_iov_size_99p"] = massage_qps_stats_helpers.percentile(h.buckets, 99, h.boundaries) |
| h = massage_qps_stats_helpers.histogram(core_stats, "http2_send_message_size") |
| stats["core_http2_send_message_size"] = ",".join("%f" % x for x in h.buckets) |
| stats["core_http2_send_message_size_bkts"] = ",".join("%f" % x for x in h.boundaries) |
| stats["core_http2_send_message_size_50p"] = massage_qps_stats_helpers.percentile(h.buckets, 50, h.boundaries) |
| stats["core_http2_send_message_size_95p"] = massage_qps_stats_helpers.percentile(h.buckets, 95, h.boundaries) |
| stats["core_http2_send_message_size_99p"] = massage_qps_stats_helpers.percentile(h.buckets, 99, h.boundaries) |
| h = massage_qps_stats_helpers.histogram(core_stats, "http2_send_initial_metadata_per_write") |
| stats["core_http2_send_initial_metadata_per_write"] = ",".join("%f" % x for x in h.buckets) |
| stats["core_http2_send_initial_metadata_per_write_bkts"] = ",".join("%f" % x for x in h.boundaries) |
| stats["core_http2_send_initial_metadata_per_write_50p"] = massage_qps_stats_helpers.percentile(h.buckets, 50, h.boundaries) |
| stats["core_http2_send_initial_metadata_per_write_95p"] = massage_qps_stats_helpers.percentile(h.buckets, 95, h.boundaries) |
| stats["core_http2_send_initial_metadata_per_write_99p"] = massage_qps_stats_helpers.percentile(h.buckets, 99, h.boundaries) |
| h = massage_qps_stats_helpers.histogram(core_stats, "http2_send_message_per_write") |
| stats["core_http2_send_message_per_write"] = ",".join("%f" % x for x in h.buckets) |
| stats["core_http2_send_message_per_write_bkts"] = ",".join("%f" % x for x in h.boundaries) |
| stats["core_http2_send_message_per_write_50p"] = massage_qps_stats_helpers.percentile(h.buckets, 50, h.boundaries) |
| stats["core_http2_send_message_per_write_95p"] = massage_qps_stats_helpers.percentile(h.buckets, 95, h.boundaries) |
| stats["core_http2_send_message_per_write_99p"] = massage_qps_stats_helpers.percentile(h.buckets, 99, h.boundaries) |
| h = massage_qps_stats_helpers.histogram(core_stats, "http2_send_trailing_metadata_per_write") |
| stats["core_http2_send_trailing_metadata_per_write"] = ",".join("%f" % x for x in h.buckets) |
| stats["core_http2_send_trailing_metadata_per_write_bkts"] = ",".join("%f" % x for x in h.boundaries) |
| stats["core_http2_send_trailing_metadata_per_write_50p"] = massage_qps_stats_helpers.percentile(h.buckets, 50, h.boundaries) |
| stats["core_http2_send_trailing_metadata_per_write_95p"] = massage_qps_stats_helpers.percentile(h.buckets, 95, h.boundaries) |
| stats["core_http2_send_trailing_metadata_per_write_99p"] = massage_qps_stats_helpers.percentile(h.buckets, 99, h.boundaries) |
| h = massage_qps_stats_helpers.histogram(core_stats, "http2_send_flowctl_per_write") |
| stats["core_http2_send_flowctl_per_write"] = ",".join("%f" % x for x in h.buckets) |
| stats["core_http2_send_flowctl_per_write_bkts"] = ",".join("%f" % x for x in h.boundaries) |
| stats["core_http2_send_flowctl_per_write_50p"] = massage_qps_stats_helpers.percentile(h.buckets, 50, h.boundaries) |
| stats["core_http2_send_flowctl_per_write_95p"] = massage_qps_stats_helpers.percentile(h.buckets, 95, h.boundaries) |
| stats["core_http2_send_flowctl_per_write_99p"] = massage_qps_stats_helpers.percentile(h.buckets, 99, h.boundaries) |
| h = massage_qps_stats_helpers.histogram(core_stats, "server_cqs_checked") |
| stats["core_server_cqs_checked"] = ",".join("%f" % x for x in h.buckets) |
| stats["core_server_cqs_checked_bkts"] = ",".join("%f" % x for x in h.boundaries) |
| stats["core_server_cqs_checked_50p"] = massage_qps_stats_helpers.percentile(h.buckets, 50, h.boundaries) |
| stats["core_server_cqs_checked_95p"] = massage_qps_stats_helpers.percentile(h.buckets, 95, h.boundaries) |
| stats["core_server_cqs_checked_99p"] = massage_qps_stats_helpers.percentile(h.buckets, 99, h.boundaries) |