@@ -341,12 +341,12 @@ public void testGaugeCounterStartsAJobToConsumeTheGeneratedMetrics() throws Inte
341341 assertThat (fakeScheduledExecutorService .isEmpty ()).isTrue ();
342342
343343 // Generate metrics that don't exceed the GaugeCounter.MAX_COUNT.
344- generateMetricsAndIncrementCounter (24 );
344+ generateMetricsAndIncrementCounter (20 );
345345
346346 // There's still no job to log the gauges.
347347 assertThat (fakeScheduledExecutorService .isEmpty ()).isTrue ();
348348
349- generateMetricsAndIncrementCounter (2 );
349+ generateMetricsAndIncrementCounter (10 );
350350
351351 assertThat (fakeScheduledExecutorService .isEmpty ()).isFalse ();
352352 assertThat (fakeScheduledExecutorService .getDelayToNextTask (TimeUnit .MILLISECONDS ))
@@ -366,7 +366,7 @@ public void testGaugeCounterStartsAJobToConsumeTheGeneratedMetrics() throws Inte
366366 int recordedGaugeMetricsCount =
367367 recordedGaugeMetric .getAndroidMemoryReadingsCount ()
368368 + recordedGaugeMetric .getCpuMetricReadingsCount ();
369- assertThat (recordedGaugeMetricsCount ).isEqualTo (26 );
369+ assertThat (recordedGaugeMetricsCount ).isEqualTo (30 );
370370
371371 assertThat (recordedGaugeMetric .getSessionId ()).isEqualTo (testSessionId (1 ));
372372 }
@@ -501,19 +501,21 @@ public void testStopCollectingGaugesCreatesOneLastJobToConsumeAnyPendingMetrics(
501501 testGaugeManager .startCollectingGauges (fakeSession );
502502 assertThat (fakeScheduledExecutorService .isEmpty ()).isTrue ();
503503
504+ generateMetricsAndIncrementCounter (2 );
505+
504506 testGaugeManager .stopCollectingGauges ();
505507 assertThat (fakeScheduledExecutorService .isEmpty ()).isFalse ();
506508
507- generateMetricsAndIncrementCounter (2 );
508-
509509 assertThat (fakeScheduledExecutorService .getDelayToNextTask (TimeUnit .MILLISECONDS ))
510510 .isEqualTo (TIME_TO_WAIT_BEFORE_FLUSHING_GAUGES_QUEUE_MS );
511511
512512 fakeScheduledExecutorService .simulateSleepExecutingAtMostOneTask ();
513+
513514 GaugeMetric recordedGaugeMetric =
514515 getLastRecordedGaugeMetric (ApplicationProcessState .FOREGROUND );
515516 assertThat (recordedGaugeMetric .getSessionId ()).isEqualTo (testSessionId (1 ));
516517
518+ // TODO(b/394127311): Investigate why this isn't 0 on local runs.
517519 assertThat (GaugeCounter .INSTANCE .count ()).isEqualTo (0 );
518520 }
519521
0 commit comments