Method readCpu

src/monitoring.ts:225–259

()

  }

  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);
  }

  protected async readMemory(): Promise<number | null> {
    let usageContent: string;