dandri/server
1
0
Fork 0
mirror of https://github.com/spacebarchat/server.git synced 2026-07-26 01:31:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Clean up supposedly orphaned unix sockets

Browse Source
This commit is contained in:
Rory&
2026-07-16 09:47:32 +02:00
parent 87988c3039
commit 8393a29b7d
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/util/util/ipc/writer/UnixSocketWriter.ts
+7 -3
View File
@@ -101,16 +101,20 @@ export class UnixSocketWriter extends BaseEventWriter {
});
this.clients[fullPath].on("error", (err) => {
console.error("[UnixSocketWriter] Unix socket client error on", fullPath, ":", err);
// clean up after error
if (this.clients[fullPath]) {
delete this.clients[fullPath];
}
if ("code" in err && err.code == "ECONNREFUSED") {
console.error("[UnixSocketWriter] Got ECONNREFUSED for socket", fullPath, " - assuming it is orphaned...");
fs.unlinkSync(fullPath);
} else console.error("[UnixSocketWriter] Unix socket client error on", fullPath, ":", err);
});
// handle clean socket closure
this.clients[fullPath].on("close", () => {
console.log("[UnixSocketWriter] Unix socket client closed:", fullPath);
this.clients[fullPath].on("close", (hadError) => {
console.log("[UnixSocketWriter] Unix socket client closed:", fullPath, "- hadError:", hadError);
delete this.clients[fullPath];
this.openConnectionsMetric.set(Object.entries(this.clients).length);
});