fix(compiler): force global filesystem sync to flush XFS delayed logging and add diagnostics comparing Node's readdirSync with system ls to detect directory entry inconsistencies

This commit is contained in:
2026-03-05 15:35:57 +00:00
parent 85a33021e4
commit 9dc74fd392
3 changed files with 27 additions and 20 deletions

View File

@@ -1,6 +1,7 @@
import type { CompilerOptions, Diagnostic, Program } from 'typescript';
import typescript from 'typescript';
import * as fs from 'fs';
import { execSync } from 'child_process';
import * as smartdelay from '@push.rocks/smartdelay';
import * as smartpromise from '@push.rocks/smartpromise';
import * as smartpath from '@push.rocks/smartpath';
@@ -453,29 +454,28 @@ export class TsCompiler {
successfulOutputDirs.push(destDir);
}
// Fsync all output directories to force XFS metadata commit
// before the next compilation step. Without this, XFS delayed logging
// can cause directory entries from previous compilations to become
// invisible or corrupted during subsequent TypeScript emit operations.
for (const dir of successfulOutputDirs) {
try {
const fd = fs.openSync(dir, 'r');
fs.fsyncSync(fd);
fs.closeSync(fd);
} catch {
// Directory might not exist yet
}
}
// Force global filesystem sync to flush XFS delayed logging (CIL)
// before the next compilation step. Per-directory fsync was insufficient;
// XFS defers parent B+tree metadata commits which can make sibling
// directory entries invisible to readdirSync after heavy write activity.
execSync('sync');
// Diagnostic: log all output directory states after each compilation
// Diagnostic: compare readdirSync vs external ls to detect Node.js caching
if (!isQuiet && !isJson) {
for (const prevDir of successfulOutputDirs) {
try {
const entries = fs.readdirSync(prevDir);
const dirs = entries.filter(e => {
try { return fs.statSync(prevDir + '/' + e).isDirectory(); } catch { return false; }
});
console.log(` 📋 [diag] ${prevDir.replace(this.cwd + '/', '')}: ${entries.length} entries, ${dirs.length} dirs`);
const nodeEntries = fs.readdirSync(prevDir);
const nodeDirs = nodeEntries.filter(e => { try { return fs.statSync(prevDir + '/' + e).isDirectory(); } catch { return false; } });
const lsOutput = execSync(`ls -1 "${prevDir}"`, { encoding: 'utf8' }).trim();
const lsEntries = lsOutput ? lsOutput.split('\n') : [];
const shortDir = prevDir.replace(this.cwd + '/', '');
if (nodeEntries.length !== lsEntries.length) {
console.log(` ⚠️ [diag] ${shortDir}: readdirSync=${nodeEntries.length}, ls=${lsEntries.length} (MISMATCH!)`);
console.log(` readdirSync: [${nodeEntries.sort().join(', ')}]`);
console.log(` ls: [${lsEntries.sort().join(', ')}]`);
} else {
console.log(` 📋 [diag] ${shortDir}: ${nodeEntries.length} entries, ${nodeDirs.length} dirs ✓`);
}
} catch {
console.log(` 📋 [diag] ${prevDir.replace(this.cwd + '/', '')}: MISSING!`);
}