alois/OpenFrontIO
1
0
Fork 0
mirror of https://github.com/openfrontio/OpenFrontIO.git synced 2026-07-02 01:33:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

Kill and restart workers when IPC send fails

Browse Source 
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
evanpelle
2026-03-13 19:10:27 -07:00
parent e596b998f8
commit 9721aae9ab
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/server/MasterLobbyService.ts
+11 -3
View File
@@ -117,10 +117,14 @@ export class MasterLobbyService {
games: this.getAllLobbies(),
},
} satisfies MasterLobbiesBroadcast;
for (const worker of this.workers.values()) {
for (const [workerId, worker] of this.workers.entries()) {
worker.send(msg, (e) => {
if (e) {
this.log.error("Failed to send lobbies broadcast to worker:", e);
this.log.error(
`Failed to send lobbies broadcast to worker ${workerId}, killing worker:`,
e,
);
worker.kill();
}
});
}
@@ -162,7 +166,11 @@ export class MasterLobbyService {
}
worker.send(msg, (e) => {
if (e) {
this.log.error("Failed to send message to worker:", e);
this.log.error(
`Failed to send message to worker ${workerId}, killing worker:`,
e,
);
worker.kill();
}
});
}