diff options
| author | Matthew Wild <mwild1@gmail.com> | 2020-09-17 16:42:14 +0100 |
|---|---|---|
| committer | Matthew Wild <mwild1@gmail.com> | 2020-09-17 16:42:14 +0100 |
| commit | 3c0924eee1130bdcec884e58cc2e04efdb54afb2 (patch) | |
| tree | 44a73e7147c49de16d875d04a2ba474c7a02b20e /plugins | |
| parent | a4e9e4815c0f14d438a57b40b838f9715da6f3f5 (diff) | |
| download | prosody-3c0924eee1130bdcec884e58cc2e04efdb54afb2.tar.gz prosody-3c0924eee1130bdcec884e58cc2e04efdb54afb2.zip | |
mod_websocket: Add separate limit for frame buffer size
Diffstat (limited to 'plugins')
| -rw-r--r-- | plugins/mod_websocket.lua | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/plugins/mod_websocket.lua b/plugins/mod_websocket.lua index d3b035db..53a1d452 100644 --- a/plugins/mod_websocket.lua +++ b/plugins/mod_websocket.lua @@ -29,6 +29,7 @@ local parse_close = websocket_frames.parse_close; local t_concat = table.concat; local stanza_size_limit = module:get_option_number("c2s_stanza_size_limit", 10 * 1024 * 1024); +local frame_buffer_limit = module:get_option_number("websocket_frame_buffer_limit", 2 * stanza_size_limit); local frame_fragment_limit = module:get_option_number("websocket_frame_fragment_limit", 8); local stream_close_timeout = module:get_option_number("c2s_close_timeout", 5); local consider_websocket_secure = module:get_option_boolean("consider_websocket_secure"); @@ -272,8 +273,7 @@ function handle_request(event) session.open_stream = session_open_stream; session.close = session_close; - -- max frame header is 22 bytes - local frameBuffer = dbuffer.new(stanza_size_limit + 22, frame_fragment_limit); + local frameBuffer = dbuffer.new(frame_buffer_limit, frame_fragment_limit); add_filter(session, "bytes/in", function(data) if not frameBuffer:write(data) then session.log("warn", "websocket frame buffer full - terminating session"); |