From 8819c4101f5c945a68b3d1c0e6f240f0e8727980 Mon Sep 17 00:00:00 2001 From: Steffen Vogel Date: Sat, 26 May 2018 01:13:22 +0200 Subject: [PATCH] websocket: clear buffer of received data once completely parsed --- lib/nodes/websocket.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/lib/nodes/websocket.c b/lib/nodes/websocket.c index 1494851c6..429e100b0 100644 --- a/lib/nodes/websocket.c +++ b/lib/nodes/websocket.c @@ -321,6 +321,8 @@ int websocket_protocol_cb(struct lws *wsi, enum lws_callback_reasons reason, voi if (enqueued < avail) sample_put_many(&smps[enqueued], avail - enqueued); + buffer_clear(&c->buffers.recv); + if (c->state == STATE_SHUTDOWN) { websocket_connection_close(c, wsi, LWS_CLOSE_STATUS_GOINGAWAY, "Node stopped"); return -1;