Skip to content

Commit

Permalink
Update flow control settings names to reflect that these are indeed flow
Browse files Browse the repository at this point in the history
Summary: Update flow control settings names to reflect that these are indeed flow control

Reviewed By: jbeshay

Differential Revision: D48137685

fbshipit-source-id: a48372e21cdd529480e25785a9bd5de456427ef3
  • Loading branch information
kvtsoy authored and facebook-github-bot committed Aug 18, 2023
1 parent f1a0712 commit db6d58c
Show file tree
Hide file tree
Showing 3 changed files with 14 additions and 11 deletions.
8 changes: 4 additions & 4 deletions proxygen/httpclient/samples/httperf2/Client.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -189,16 +189,16 @@ static quic::TransportSettings createTransportSettings() {
transportSettings.maxRecvPacketSize = FLAGS_max_receive_packet_size;
transportSettings.canIgnorePathMTU = FLAGS_can_ignore_pmtu;
if (FLAGS_conn_flow_control != 0) {
transportSettings.advertisedInitialConnectionWindowSize =
transportSettings.advertisedInitialConnectionFlowControlWindow =
FLAGS_conn_flow_control;
}
// TODO FLAGS_stream_*
if (FLAGS_stream_flow_control != 0) {
transportSettings.advertisedInitialBidiLocalStreamWindowSize =
transportSettings.advertisedInitialBidiLocalStreamFlowControlWindow =
FLAGS_stream_flow_control;
transportSettings.advertisedInitialBidiRemoteStreamWindowSize =
transportSettings.advertisedInitialBidiRemoteStreamFlowControlWindow =
FLAGS_stream_flow_control;
transportSettings.advertisedInitialUniStreamWindowSize =
transportSettings.advertisedInitialUniStreamFlowControlWindow =
FLAGS_stream_flow_control;
}

Expand Down
8 changes: 5 additions & 3 deletions proxygen/httpserver/samples/hq/H2Server.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -44,11 +44,13 @@ std::unique_ptr<proxygen::HTTPServerOptions> H2Server::createServerOptions(
serverOptions->enableContentCompression =
params.httpServerEnableContentCompression;
serverOptions->initialReceiveWindow =
params.transportSettings.advertisedInitialBidiLocalStreamWindowSize;
params.transportSettings
.advertisedInitialBidiLocalStreamFlowControlWindow;
serverOptions->receiveStreamWindowSize =
params.transportSettings.advertisedInitialBidiLocalStreamWindowSize;
params.transportSettings
.advertisedInitialBidiLocalStreamFlowControlWindow;
serverOptions->receiveSessionWindowSize =
params.transportSettings.advertisedInitialConnectionWindowSize;
params.transportSettings.advertisedInitialConnectionFlowControlWindow;
serverOptions->handlerFactories =
proxygen::RequestHandlerChain()
.addThen<SampleHandlerFactory>(
Expand Down
9 changes: 5 additions & 4 deletions proxygen/httpserver/samples/hq/HQCommandLine.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -211,13 +211,14 @@ void initializeTransportSettings(HQToolParams& hqUberParams) {
proxygen::kHQCurrentDraft};
}

hqParams.transportSettings.advertisedInitialConnectionWindowSize =
hqParams.transportSettings.advertisedInitialConnectionFlowControlWindow =
FLAGS_conn_flow_control;
hqParams.transportSettings.advertisedInitialBidiLocalStreamWindowSize =
hqParams.transportSettings.advertisedInitialBidiLocalStreamFlowControlWindow =
FLAGS_stream_flow_control;
hqParams.transportSettings.advertisedInitialBidiRemoteStreamWindowSize =
hqParams.transportSettings
.advertisedInitialBidiRemoteStreamFlowControlWindow =
FLAGS_stream_flow_control;
hqParams.transportSettings.advertisedInitialUniStreamWindowSize =
hqParams.transportSettings.advertisedInitialUniStreamFlowControlWindow =
FLAGS_stream_flow_control;
hqParams.congestionControlName = FLAGS_congestion;
hqParams.congestionControl =
Expand Down

0 comments on commit db6d58c

Please sign in to comment.