aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMatthew Wild <mwild1@gmail.com>2020-09-17 16:41:48 +0100
committerMatthew Wild <mwild1@gmail.com>2020-09-17 16:41:48 +0100
commita4e9e4815c0f14d438a57b40b838f9715da6f3f5 (patch)
treefb2f25303f33c81f8a53e73a61c7901ba5ec9c40
parent5a1c206eceafe544292059d3749ad033010af37f (diff)
downloadprosody-a4e9e4815c0f14d438a57b40b838f9715da6f3f5.tar.gz
prosody-a4e9e4815c0f14d438a57b40b838f9715da6f3f5.zip
mod_websocket: handle full frame buffer and raise stream error
-rw-r--r--plugins/mod_websocket.lua6
1 files changed, 5 insertions, 1 deletions
diff --git a/plugins/mod_websocket.lua b/plugins/mod_websocket.lua
index ad94486b..d3b035db 100644
--- a/plugins/mod_websocket.lua
+++ b/plugins/mod_websocket.lua
@@ -275,7 +275,11 @@ function handle_request(event)
-- max frame header is 22 bytes
local frameBuffer = dbuffer.new(stanza_size_limit + 22, frame_fragment_limit);
add_filter(session, "bytes/in", function(data)
- frameBuffer:write(data);
+ if not frameBuffer:write(data) then
+ session.log("warn", "websocket frame buffer full - terminating session");
+ session:close({ condition = "resource-constraint", text = "frame buffer exceeded" });
+ return;
+ end
local cache = {};
local frame, length = parse_frame(frameBuffer);