Skip to content
This repository was archived by the owner on Jan 9, 2023. It is now read-only.

Commit 545e286

Browse files
Release/v6.2.4 (#97)
* Issue #94: restart workers that exit by error or by signal * Issue #95: fix worker memory leak - delete cluster message callback data after use * Bumping version to 6.2.4
1 parent e320d5c commit 545e286

File tree

4 files changed

+13
-2
lines changed

4 files changed

+13
-2
lines changed

lib/cluster_messages.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@ class ClusterMessages extends EventEmitter {
4242
if(!cb) return;
4343

4444
cb.resolve(message.result);
45+
delete this._callbacks[message.msgId];
4546
});
4647
}
4748
}

lib/unity_cache_server.js

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -185,6 +185,16 @@ class UnityCacheServer {
185185
for(let i = 0; i < workers; i++) {
186186
cluster.fork();
187187
}
188+
189+
cluster.on('exit', (deadWorker, code, signal) => {
190+
if (signal) {
191+
console.log(`[Cluster: ${deadWorker.id}] !Process killed by signal: ${signal}`);
192+
} else if (code !== 0) {
193+
console.log(`[Cluster: ${deadWorker.id}] !Process exited with error code: ${code}`);
194+
}
195+
196+
cluster.fork();
197+
});
188198
}
189199

190200
if(cluster.isWorker || workers === 0) {

package-lock.json

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "unity-cache-server",
3-
"version": "6.2.3",
3+
"version": "6.2.4",
44
"description": "Unity Cache Server",
55
"main": "lib/index.js",
66
"engines": {

0 commit comments

Comments
 (0)