Compare commits
2 commits
main
...
log-maxHtt
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d7ea0d44aa | ||
|
|
570d873270 |
2 changed files with 10 additions and 5 deletions
|
|
@ -21,8 +21,9 @@ const createSocketIOServer = function (server, prefix) {
|
||||||
if (io) {
|
if (io) {
|
||||||
return io;
|
return io;
|
||||||
}
|
}
|
||||||
|
let bufferSize = (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6
|
||||||
io = _io(server, {
|
io = _io(server, {
|
||||||
maxHttpBufferSize: (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6,
|
maxHttpBufferSize: bufferSize,
|
||||||
cors: {
|
cors: {
|
||||||
origin: "*",
|
origin: "*",
|
||||||
methods: ["GET", "POST", "PUT"]
|
methods: ["GET", "POST", "PUT"]
|
||||||
|
|
@ -30,6 +31,7 @@ const createSocketIOServer = function (server, prefix) {
|
||||||
path: (prefix ? prefix : '') + '/socket',
|
path: (prefix ? prefix : '') + '/socket',
|
||||||
...getCompressionConfig()
|
...getCompressionConfig()
|
||||||
});
|
});
|
||||||
|
console.log('The maximum http buffer size:', bufferSize);
|
||||||
return io;
|
return io;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -37,4 +39,4 @@ module.exports = {
|
||||||
createSocketIOServer,
|
createSocketIOServer,
|
||||||
getServer,
|
getServer,
|
||||||
fetchSockets,
|
fetchSockets,
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -60,9 +60,10 @@ const createSocketIOServer = function (server, prefix) {
|
||||||
if (io) {
|
if (io) {
|
||||||
return io;
|
return io;
|
||||||
}
|
}
|
||||||
|
let bufferSize = (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6
|
||||||
if (process.env.uws !== "true") {
|
if (process.env.uws !== "true") {
|
||||||
io = _io(server, {
|
io = _io(server, {
|
||||||
maxHttpBufferSize: (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6,
|
maxHttpBufferSize: bufferSize,
|
||||||
cors: {
|
cors: {
|
||||||
origin: "*",
|
origin: "*",
|
||||||
methods: ["GET", "POST", "PUT"],
|
methods: ["GET", "POST", "PUT"],
|
||||||
|
|
@ -71,9 +72,10 @@ const createSocketIOServer = function (server, prefix) {
|
||||||
path: (prefix ? prefix : '') + '/socket',
|
path: (prefix ? prefix : '') + '/socket',
|
||||||
...getCompressionConfig()
|
...getCompressionConfig()
|
||||||
});
|
});
|
||||||
|
console.log('The maximum http buffer size:', bufferSize);
|
||||||
} else {
|
} else {
|
||||||
io = new _io.Server({
|
io = new _io.Server({
|
||||||
maxHttpBufferSize: (parseFloat(process.env.maxHttpBufferSize) || 5) * 1e6,
|
maxHttpBufferSize: bufferSize,
|
||||||
cors: {
|
cors: {
|
||||||
origin: "*",
|
origin: "*",
|
||||||
methods: ["GET", "POST", "PUT"],
|
methods: ["GET", "POST", "PUT"],
|
||||||
|
|
@ -82,6 +84,7 @@ const createSocketIOServer = function (server, prefix) {
|
||||||
path: (prefix ? prefix : '') + '/socket',
|
path: (prefix ? prefix : '') + '/socket',
|
||||||
...getCompressionConfig()
|
...getCompressionConfig()
|
||||||
});
|
});
|
||||||
|
console.log('The maximum http buffer size:', bufferSize);
|
||||||
io.attachApp(server);
|
io.attachApp(server);
|
||||||
}
|
}
|
||||||
return io;
|
return io;
|
||||||
|
|
@ -91,4 +94,4 @@ module.exports = {
|
||||||
createSocketIOServer,
|
createSocketIOServer,
|
||||||
getServer,
|
getServer,
|
||||||
fetchSockets,
|
fetchSockets,
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue