Ayuriel/openclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: queue targeted memory sync requests

Browse Source
This commit is contained in:
Junebugg1214 2026-03-13 13:08:24 -04:00
parent 1c4fbc0023
commit f1d3ce6d4b
1 changed files with 30 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/memory/manager.ts
View File

@ -122,6 +122,12 @@ export class MemoryIndexManager extends MemoryManagerEmbeddingOps implements Mem
>();
private sessionWarm = new Set<string>();
private syncing: Promise<void> | null = null;
private queuedSyncParams: {
reason?: string;
force?: boolean;
sessionFiles?: string[];
progress?: (update: MemorySyncProgressUpdate) => void;
} | null = null;
private readonlyRecoveryAttempts = 0;
private readonlyRecoverySuccesses = 0;
private readonlyRecoveryFailures = 0;
@ -456,10 +462,33 @@ export class MemoryIndexManager extends MemoryManagerEmbeddingOps implements Mem
return;
}
if (this.syncing) {
const queued = this.queuedSyncParams;
this.queuedSyncParams = {
reason: params?.reason ?? queued?.reason,
force: params?.force || queued?.force,
sessionFiles: Array.from(
new Set([
...(queued?.sessionFiles ?? []),
...(params?.sessionFiles?.filter((sessionFile) => sessionFile.trim().length > 0) ?? []),
]),
),
progress: params?.progress ?? queued?.progress,
};
return this.syncing;
}
this.syncing = this.runSyncWithReadonlyRecovery(params).finally(() => {
this.syncing = (async () => {
let nextParams = params;
while (!this.closed) {
this.queuedSyncParams = null;
await this.runSyncWithReadonlyRecovery(nextParams);
if (!this.queuedSyncParams) {
break;
}
nextParams = this.queuedSyncParams;
}
})().finally(() => {
this.syncing = null;
this.queuedSyncParams = null;
});
return this.syncing ?? Promise.resolve();
}