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) {
|
||||
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,
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -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,
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue