vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-06 09:10:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

perf: overlap gateway watch startup

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-04 08:22:29 +01:00
parent 2484f37378
commit 0f7cd6d905
1 changed files with 23 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
scripts/watch-node.mjs
View File

@@ -298,17 +298,12 @@ export async function runWatchMain(params = {}) {
let shuttingDown = false;
let restartRequested = false;
let watchProcess = null;
let watcher = null;
let lockHandle = null;
let autoDoctorAttempted = false;
let onSigInt;
let onSigTerm;
const watcher = deps.createWatcher(deps.watchPaths, {
ignoreInitial: true,
ignored: (watchPath, stats) =>
isIgnoredWatchPath(watchPath, deps.cwd, deps.watchPaths, stats),
});
const settle = (code) => {
if (settled) {
return;
@@ -321,7 +316,7 @@ export async function runWatchMain(params = {}) {
deps.process.off("SIGTERM", onSigTerm);
}
releaseWatchLock(lockHandle);
watcher.close?.().catch?.(() => {});
watcher?.close?.().catch?.(() => {});
resolve(code);
};
@@ -354,6 +349,14 @@ export async function runWatchMain(params = {}) {
});
};
const handleWatcherError = () => {
shuttingDown = true;
if (watchProcess && typeof watchProcess.kill === "function") {
watchProcess.kill(WATCH_RESTART_SIGNAL);
}
settle(1);
};
const runAutoDoctorAndRestart = () => {
autoDoctorAttempted = true;
logWatcher(
@@ -402,16 +405,17 @@ export async function runWatchMain(params = {}) {
}
};
watcher.on("add", requestRestart);
watcher.on("change", requestRestart);
watcher.on("unlink", requestRestart);
watcher.on("error", () => {
shuttingDown = true;
if (watchProcess && typeof watchProcess.kill === "function") {
watchProcess.kill(WATCH_RESTART_SIGNAL);
}
settle(1);
});
const startWatcher = () => {
watcher = deps.createWatcher(deps.watchPaths, {
ignoreInitial: true,
ignored: (watchPath, stats) =>
isIgnoredWatchPath(watchPath, deps.cwd, deps.watchPaths, stats),
});
watcher.on("add", requestRestart);
watcher.on("change", requestRestart);
watcher.on("unlink", requestRestart);
watcher.on("error", handleWatcherError);
};
onSigInt = () => {
shuttingDown = true;
@@ -434,6 +438,7 @@ export async function runWatchMain(params = {}) {
if (deps.lockDisabled) {
lockHandle = { lockPath: "", pid: deps.process.pid };
startRunner();
startWatcher();
return;
}
@@ -445,6 +450,7 @@ export async function runWatchMain(params = {}) {
}
lockHandle = handle;
startRunner();
startWatcher();
})
.catch((error) => {
logWatcher(`Failed to acquire watcher lock: ${error?.message ?? "unknown error"}`, deps);