Method runWalHeal

src/db/index.ts:571–586

(beforeBytes: number)

  private walHeal: Promise<{ healed: boolean; beforeBytes: number; afterBytes: number }> | null = null;

  private async runWalHeal(beforeBytes: number): Promise<{ healed: boolean; beforeBytes: number; afterBytes: number }> {
    // A racing reader/writer (another session healing the same file, a query
    // pool warming up) degrades a checkpoint pass to a busy no-op — retry a
    // few times before leaving the rest to the next open.
    for (let attempt = 0; attempt < 3; attempt++) {
      if (attempt > 0) await new Promise((r) => setTimeout(r, 300));
      await this.checkpointWalPassive();
      await this.checkpointWalTruncate();
      if (this.getWalSizeBytes() <= WAL_HEAL_THRESHOLD_BYTES) break;
    }
    const afterBytes = this.getWalSizeBytes();
    if (process.env.CODEGRAPH_WAL_VALVE_DEBUG) {
      console.error(`[wal-heal] oversized WAL at open: ${Math.round(beforeBytes / (1024 * 1024))}MB -> ${Math.round(afterBytes / (1024 * 1024))}MB`);
    }
    return { healed: afterBytes < beforeBytes, beforeBytes, afterBytes };
  }

  private async checkpointWal(mode: 'PASSIVE' | 'TRUNCATE'): Promise<{ busy: number; log: number; checkpointed: number } | null> {
    if (!this.dbPath || this.dbPath === ':memory:') {