Class CgroupV1Source

src/monitoring.ts:203–297

}

export class CgroupV1Source implements MachineStatsSource {
  public readonly name = 'cgroup-v1';
  protected log = new Logger('hardware');
  protected lastSample: Sample | null = null;
  protected loggedFailure: Set<string> = new Set();

  protected now: () => number;
  protected readFile: ReadFileFn;

  constructor(opts: CgroupSourceOpts = {}) {
    this.now = opts.now ?? Date.now;
    this.readFile = opts.readFile ?? defaultReadFile;
  }

  public async read(): Promise<IResourceLoad> {
    const [cpu, memory] = await Promise.all([
      this.readCpu(),
      this.readMemory(),
    ]);
    return { cpu, memory };
  }

  protected async readCpu(): Promise<number | null> {
    let usageNsContent: string;
    let quotaContent: string;
    let periodContent: string;
    try {
      [usageNsContent, quotaContent, periodContent] = await Promise.all([
        readWithTimeout('/sys/fs/cgroup/cpu/cpuacct.usage', this.readFile),
        readWithTimeout('/sys/fs/cgroup/cpu/cpu.cfs_quota_us', this.readFile),
        readWithTimeout('/sys/fs/cgroup/cpu/cpu.cfs_period_us', this.readFile),
      ]);
    } catch (err) {
      this.logOnce('cpu-read', err);
      return null;
    }

    const usageNs = Number(usageNsContent.trim());
    const cores = parseCpuV1Quota(quotaContent, periodContent);
    if (!Number.isFinite(usageNs) || cores === null || cores <= 0) {
      this.logOnce('cpu-parse', new Error('cgroup v1 cpu parse failed'));
      return null;
    }

    const usageUsec = usageNs / 1000;
    const timestamp = this.now();
    const previous = this.lastSample;
    this.lastSample = { usageUsec, timestamp };
    if (!previous) return null;

    const dWallMs = timestamp - previous.timestamp;
    if (dWallMs <= 0) return null;
    const dUsageUsec = usageUsec - previous.usageUsec;
    if (dUsageUsec < 0) return null;

    return dUsageUsec / (dWallMs * cores * 1000);
  }