@@ -341,12 +341,12 @@ public void testGaugeCounterStartsAJobToConsumeTheGeneratedMetrics() throws Inte
341
341
assertThat (fakeScheduledExecutorService .isEmpty ()).isTrue ();
342
342
343
343
// Generate metrics that don't exceed the GaugeCounter.MAX_COUNT.
344
- generateMetricsAndIncrementCounter (24 );
344
+ generateMetricsAndIncrementCounter (20 );
345
345
346
346
// There's still no job to log the gauges.
347
347
assertThat (fakeScheduledExecutorService .isEmpty ()).isTrue ();
348
348
349
- generateMetricsAndIncrementCounter (2 );
349
+ generateMetricsAndIncrementCounter (10 );
350
350
351
351
assertThat (fakeScheduledExecutorService .isEmpty ()).isFalse ();
352
352
assertThat (fakeScheduledExecutorService .getDelayToNextTask (TimeUnit .MILLISECONDS ))
@@ -366,7 +366,7 @@ public void testGaugeCounterStartsAJobToConsumeTheGeneratedMetrics() throws Inte
366
366
int recordedGaugeMetricsCount =
367
367
recordedGaugeMetric .getAndroidMemoryReadingsCount ()
368
368
+ recordedGaugeMetric .getCpuMetricReadingsCount ();
369
- assertThat (recordedGaugeMetricsCount ).isEqualTo (26 );
369
+ assertThat (recordedGaugeMetricsCount ).isEqualTo (30 );
370
370
371
371
assertThat (recordedGaugeMetric .getSessionId ()).isEqualTo (testSessionId (1 ));
372
372
}
@@ -501,19 +501,21 @@ public void testStopCollectingGaugesCreatesOneLastJobToConsumeAnyPendingMetrics(
501
501
testGaugeManager .startCollectingGauges (fakeSession );
502
502
assertThat (fakeScheduledExecutorService .isEmpty ()).isTrue ();
503
503
504
+ generateMetricsAndIncrementCounter (2 );
505
+
504
506
testGaugeManager .stopCollectingGauges ();
505
507
assertThat (fakeScheduledExecutorService .isEmpty ()).isFalse ();
506
508
507
- generateMetricsAndIncrementCounter (2 );
508
-
509
509
assertThat (fakeScheduledExecutorService .getDelayToNextTask (TimeUnit .MILLISECONDS ))
510
510
.isEqualTo (TIME_TO_WAIT_BEFORE_FLUSHING_GAUGES_QUEUE_MS );
511
511
512
512
fakeScheduledExecutorService .simulateSleepExecutingAtMostOneTask ();
513
+
513
514
GaugeMetric recordedGaugeMetric =
514
515
getLastRecordedGaugeMetric (ApplicationProcessState .FOREGROUND );
515
516
assertThat (recordedGaugeMetric .getSessionId ()).isEqualTo (testSessionId (1 ));
516
517
518
+ // TODO(b/394127311): Investigate why this isn't 0 on local runs.
517
519
assertThat (GaugeCounter .INSTANCE .count ()).isEqualTo (0 );
518
520
}
519
521
0 commit comments