diff options
| author | Loïc Hoguin <[email protected]> | 2025-04-15 13:35:52 +0200 |
|---|---|---|
| committer | Loïc Hoguin <[email protected]> | 2025-04-15 13:35:52 +0200 |
| commit | 3b075c56a4c75bf75f36287ae1f57eca2c795934 (patch) | |
| tree | 7f9648a5b792ce7011dc53c8c52bbb0188569719 /src/cowboy_websocket.erl | |
| parent | 24d32de931a0c985ff7939077463fc8be939f0e9 (diff) | |
| download | cowboy-improve-dynamic_buffer.tar.gz cowboy-improve-dynamic_buffer.tar.bz2 cowboy-improve-dynamic_buffer.zip | |
Make dynamic_buffer start at 128 and change less abruptlyimprove-dynamic_buffer
Based on RabbitMQ performance testing.
Diffstat (limited to 'src/cowboy_websocket.erl')
| -rw-r--r-- | src/cowboy_websocket.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/cowboy_websocket.erl b/src/cowboy_websocket.erl index dd57730..37ac49c 100644 --- a/src/cowboy_websocket.erl +++ b/src/cowboy_websocket.erl @@ -103,7 +103,7 @@ %% Dynamic buffer moving average and current buffer size. dynamic_buffer_size = false :: pos_integer() | false, - dynamic_buffer_moving_average = 0 :: non_neg_integer(), + dynamic_buffer_moving_average = 0.0 :: non_neg_integer(), hibernate = false :: boolean(), frag_state = undefined :: cow_ws:frag_state(), @@ -320,7 +320,7 @@ takeover(Parent, Ref, Socket, Transport, Opts, Buffer, key=undefined, messages=Messages, %% Dynamic buffer only applies to HTTP/1.1 Websocket. dynamic_buffer_size=init_dynamic_buffer_size(Opts), - dynamic_buffer_moving_average=maps:get(dynamic_buffer_initial_average, Opts, 0)}, 0), + dynamic_buffer_moving_average=maps:get(dynamic_buffer_initial_average, Opts, 0.0)}, 0), %% We call parse_header/3 immediately because there might be %% some data in the buffer that was sent along with the handshake. %% While it is not allowed by the protocol to send frames immediately, |