murm
/
mrmBot-Matrix
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixed events overloading file descriptor limit

This commit is contained in:
TheEssem 2020-12-30 18:46:17 -06:00
parent c4c358dcd9
commit 67ca7d79d0
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
api/index.js
View File

@ -63,7 +63,7 @@ if (isMainThread) {
delete jobs[uuid]; delete jobs[uuid];
} }
}); });
worker.on("error", err => { worker.once("error", err => {
console.error("worker error:", err); console.error("worker error:", err);
socket.send(Buffer.concat([Buffer.from([0x2]), Buffer.from(uuid), Buffer.from(err.toString())]), jobs[uuid].port, jobs[uuid].addr); socket.send(Buffer.concat([Buffer.from([0x2]), Buffer.from(uuid), Buffer.from(err.toString())]), jobs[uuid].port, jobs[uuid].addr);
@ -73,7 +73,7 @@ if (isMainThread) {
delete jobs[uuid]; delete jobs[uuid];
} }
}); });
worker.on("exit", (code) => { worker.once("exit", (code) => {
workingWorkers--; workingWorkers--;
if (queue.length > 0) { if (queue.length > 0) {
acceptJob(queue[0]); acceptJob(queue[0]);
@ -91,6 +91,7 @@ if (isMainThread) {
port: jobs[uuid].port, port: jobs[uuid].port,
threadNum: workingWorkers threadNum: workingWorkers
}); });
return;
}; };
const server = dgram.createSocket("udp4"); //Create a UDP server for listening to requests, we dont need tcp const server = dgram.createSocket("udp4"); //Create a UDP server for listening to requests, we dont need tcp