From 570d873270985e6775e585917d56b3bfca7bac86 Mon Sep 17 00:00:00 2001 From: Mehdi Osman Date: Thu, 9 May 2024 11:36:54 -0400 Subject: [PATCH 1/2] Added logs for maxHttpBufferSize --- ee/assist/utils/wsServer.js | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/ee/assist/utils/wsServer.js b/ee/assist/utils/wsServer.js index 97fa6c268..5a5fa950e 100644 --- a/ee/assist/utils/wsServer.js +++ b/ee/assist/utils/wsServer.js @@ -60,9 +60,10 @@ const createSocketIOServer = function (server, prefix) { if (io) { return io; } + let bufferSize = (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6 if (process.env.uws !== "true") { io = _io(server, { - maxHttpBufferSize: (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6, + maxHttpBufferSize: bufferSize, cors: { origin: "*", methods: ["GET", "POST", "PUT"], @@ -71,9 +72,10 @@ const createSocketIOServer = function (server, prefix) { path: (prefix ? prefix : '') + '/socket', ...getCompressionConfig() }); + console.log('The maximum http buffer size:', bufferSize); } else { io = new _io.Server({ - maxHttpBufferSize: (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6, + maxHttpBufferSize: bufferSize, cors: { origin: "*", methods: ["GET", "POST", "PUT"], @@ -82,6 +84,7 @@ const createSocketIOServer = function (server, prefix) { path: (prefix ? prefix : '') + '/socket', ...getCompressionConfig() }); + console.log('The maximum http buffer size:', bufferSize); io.attachApp(server); } return io; @@ -91,4 +94,4 @@ module.exports = { createSocketIOServer, getServer, fetchSockets, -} \ No newline at end of file +} From d7ea0d44aa4476c9f16f454ab92f3bae838aa46e Mon Sep 17 00:00:00 2001 From: Mehdi Osman Date: Thu, 9 May 2024 11:49:40 -0400 Subject: [PATCH 2/2] Update foss --- assist/utils/wsServer.js | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/assist/utils/wsServer.js b/assist/utils/wsServer.js index bac62e750..625bb6cc4 100644 --- a/assist/utils/wsServer.js +++ b/assist/utils/wsServer.js @@ -21,8 +21,9 @@ const createSocketIOServer = function (server, prefix) { if (io) { return io; } + let bufferSize = (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6 io = _io(server, { - maxHttpBufferSize: (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6, + maxHttpBufferSize: bufferSize, cors: { origin: "*", methods: ["GET", "POST", "PUT"] @@ -30,6 +31,7 @@ const createSocketIOServer = function (server, prefix) { path: (prefix ? prefix : '') + '/socket', ...getCompressionConfig() }); + console.log('The maximum http buffer size:', bufferSize); return io; } @@ -37,4 +39,4 @@ module.exports = { createSocketIOServer, getServer, fetchSockets, -} \ No newline at end of file +}