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 +} diff --git a/ee/assist/utils/wsServer.js b/ee/assist/utils/wsServer.js index e774eb8bf..55ba58380 100644 --- a/ee/assist/utils/wsServer.js +++ b/ee/assist/utils/wsServer.js @@ -72,9 +72,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"], @@ -83,9 +84,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"], @@ -94,6 +96,7 @@ const createSocketIOServer = function (server, prefix) { path: (prefix ? prefix : '') + '/socket', ...getCompressionConfig() }); + console.log('The maximum http buffer size:', bufferSize); io.attachApp(server); } startCacheRefresher(); @@ -104,4 +107,4 @@ module.exports = { createSocketIOServer, getServer, fetchSockets, -} \ No newline at end of file +}