Skip to content

Commit a9ddb3a

Browse files
committed
fixup! fixup! fix(childprocess): noisy "memory threshold" logs
1 parent 07acf5a commit a9ddb3a

File tree

3 files changed

+12
-3
lines changed

3 files changed

+12
-3
lines changed

packages/core/src/shared/utilities/collectionUtils.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -588,4 +588,8 @@ export class CircularBuffer {
588588
contains(value: number): boolean {
589589
return this.buffer.has(value)
590590
}
591+
592+
clear(): void {
593+
this.buffer.clear()
594+
}
591595
}

packages/core/src/shared/utilities/processUtils.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ export class ChildProcessTracker {
7474
cpu: 50,
7575
}
7676
static readonly logger = logger.getLogger('childProcess')
77-
static readonly #loggedPids = new CircularBuffer(1000)
77+
static readonly loggedPids = new CircularBuffer(1000)
7878
#processByPid: Map<number, ChildProcess> = new Map<number, ChildProcess>()
7979
#pids: PollingSet<number>
8080

@@ -118,8 +118,8 @@ export class ChildProcessTracker {
118118
}
119119

120120
public static logOnce(pid: number, msg: string) {
121-
if (!ChildProcessTracker.#loggedPids.contains(pid)) {
122-
ChildProcessTracker.#loggedPids.add(pid)
121+
if (!ChildProcessTracker.loggedPids.contains(pid)) {
122+
ChildProcessTracker.loggedPids.add(pid)
123123
ChildProcessTracker.logger.warn(msg)
124124
}
125125
}

packages/core/src/test/shared/utilities/processUtils.test.ts

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -393,6 +393,10 @@ describe('ChildProcessTracker', function () {
393393
usageMock = sinon.stub(ChildProcessTracker.prototype, 'getUsage')
394394
})
395395

396+
beforeEach(function () {
397+
ChildProcessTracker.loggedPids.clear()
398+
})
399+
396400
afterEach(function () {
397401
tracker.clear()
398402
usageMock.reset()
@@ -463,6 +467,7 @@ describe('ChildProcessTracker', function () {
463467
await clock.tickAsync(ChildProcessTracker.pollingInterval)
464468
assertLogsContain('exceeded cpu threshold', false, 'warn')
465469

470+
ChildProcessTracker.loggedPids.clear()
466471
usageMock.returns(highMemory)
467472
await clock.tickAsync(ChildProcessTracker.pollingInterval)
468473
assertLogsContain('exceeded memory threshold', false, 'warn')

0 commit comments

Comments
 (0)