diff options
| author |  ncteisen <ncteisen@gmail.com> | 2017-07-06 16:23:14 -0700 |
|---|---|---|
| committer | ncteisen <ncteisen@gmail.com> | 2017-07-18 17:06:57 -0700 |
| commit | 268a82398c0b71a0ed9cb4f5168098f1de8945da (patch) | |
| tree | 6abbea6f3842f82668ac12272162d00f2c79cc78 /test/cpp/microbenchmarks/bm_fullstack_trickle.cc | |
| parent | 10bed24e8b6a93d9017927371e607f85619fb59b (diff) | |
Pull flow control into one module
Diffstat (limited to 'test/cpp/microbenchmarks/bm_fullstack_trickle.cc')
| -rw-r--r-- | test/cpp/microbenchmarks/bm_fullstack_trickle.cc | 28 |
1 files changed, 15 insertions, 13 deletions
diff --git a/test/cpp/microbenchmarks/bm_fullstack_trickle.cc b/test/cpp/microbenchmarks/bm_fullstack_trickle.cc index aeec7d831b..3464999bf0 100644 --- a/test/cpp/microbenchmarks/bm_fullstack_trickle.cc +++ b/test/cpp/microbenchmarks/bm_fullstack_trickle.cc @@ -73,11 +73,12 @@ class TrickledCHTTP2 : public EndpointPairFixture { log_.reset(new std::ofstream(fn.str().c_str())); write_csv(log_.get(), "t", "iteration", "client_backlog", "server_backlog", "client_t_stall", "client_s_stall", - "server_t_stall", "server_s_stall", "client_t_outgoing", - "server_t_outgoing", "client_t_incoming", "server_t_incoming", - "client_s_outgoing_delta", "server_s_outgoing_delta", - "client_s_incoming_delta", "server_s_incoming_delta", - "client_s_announce_window", "server_s_announce_window", + "server_t_stall", "server_s_stall", "client_t_remote", + "server_t_remote", "client_t_local", "server_t_local", + "client_t_announced", "server_t_announced", + "client_s_remote_delta", "server_s_remote_delta", + "client_s_local_delta", "server_s_local_delta", + "client_s_announced_delta", "server_s_announced_delta", "client_peer_iws", "client_local_iws", "client_sent_iws", "client_acked_iws", "server_peer_iws", "server_local_iws", "server_sent_iws", "server_acked_iws", "client_queued_bytes", @@ -127,14 +128,15 @@ class TrickledCHTTP2 : public EndpointPairFixture { client->lists[GRPC_CHTTP2_LIST_STALLED_BY_STREAM].head != nullptr, server->lists[GRPC_CHTTP2_LIST_STALLED_BY_TRANSPORT].head != nullptr, server->lists[GRPC_CHTTP2_LIST_STALLED_BY_STREAM].head != nullptr, - client->outgoing_window, server->outgoing_window, - client->incoming_window, server->incoming_window, - client_stream ? client_stream->outgoing_window_delta : -1, - server_stream ? server_stream->outgoing_window_delta : -1, - client_stream ? client_stream->incoming_window_delta : -1, - server_stream ? server_stream->incoming_window_delta : -1, - client_stream ? client_stream->announce_window : -1, - server_stream ? server_stream->announce_window : -1, + client->remote_window, server->remote_window, client->local_window, + server->local_window, client->announced_window, + server->announced_window, + client_stream ? client_stream->remote_window_delta : -1, + server_stream ? server_stream->remote_window_delta : -1, + client_stream ? client_stream->local_window_delta : -1, + server_stream ? server_stream->local_window_delta : -1, + client_stream ? client_stream->announced_window_delta : -1, + server_stream ? server_stream->announced_window_delta : -1, client->settings[GRPC_PEER_SETTINGS] [GRPC_CHTTP2_SETTINGS_INITIAL_WINDOW_SIZE], client->settings[GRPC_LOCAL_SETTINGS] |