Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 58e609e3 authored by Yangster-mac's avatar Yangster-mac
Browse files

Fix the flaky gauge/value e2e test due to cached events. 

Test: statsd test
BUG: b/79265262
Change-Id: I4d67f1c2edb6215a3cea23f8c7b2e8d5099c4aac
parent efaec53a

cmds/statsd/tests/e2e/GaugeMetric_e2e_pull_test.cpp

+3 −0
Original line number Original line Diff line number Diff line
@@ -66,6 +66,7 @@ TEST(GaugeMetricE2eTest, TestRandomSamplePulledEvents) { 
        baseTimeNs, configAddedTimeNs, config, cfgKey);

        baseTimeNs, configAddedTimeNs, config, cfgKey);

    EXPECT_EQ(processor->mMetricsManagers.size(), 1u);

    EXPECT_EQ(processor->mMetricsManagers.size(), 1u);

    EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid());

    EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid());

    processor->mStatsPullerManager.ForceClearPullerCache();





    int startBucketNum = processor->mMetricsManagers.begin()->second->

    int startBucketNum = processor->mMetricsManagers.begin()->second->

            mAllMetricProducers[0]->getCurrentBucketNum();

            mAllMetricProducers[0]->getCurrentBucketNum();
@@ -211,6 +212,7 @@ TEST(GaugeMetricE2eTest, TestAllConditionChangesSamplePulledEvents) { 
        baseTimeNs, configAddedTimeNs, config, cfgKey);

        baseTimeNs, configAddedTimeNs, config, cfgKey);

    EXPECT_EQ(processor->mMetricsManagers.size(), 1u);

    EXPECT_EQ(processor->mMetricsManagers.size(), 1u);

    EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid());

    EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid());

    processor->mStatsPullerManager.ForceClearPullerCache();





    int startBucketNum = processor->mMetricsManagers.begin()->second->

    int startBucketNum = processor->mMetricsManagers.begin()->second->

            mAllMetricProducers[0]->getCurrentBucketNum();

            mAllMetricProducers[0]->getCurrentBucketNum();
@@ -311,6 +313,7 @@ TEST(GaugeMetricE2eTest, TestRandomSamplePulledEvent_LateAlarm) { 
        baseTimeNs, configAddedTimeNs, config, cfgKey);

        baseTimeNs, configAddedTimeNs, config, cfgKey);

    EXPECT_EQ(processor->mMetricsManagers.size(), 1u);

    EXPECT_EQ(processor->mMetricsManagers.size(), 1u);

    EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid());

    EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid());

    processor->mStatsPullerManager.ForceClearPullerCache();





    int startBucketNum = processor->mMetricsManagers.begin()->second->

    int startBucketNum = processor->mMetricsManagers.begin()->second->

            mAllMetricProducers[0]->getCurrentBucketNum();

            mAllMetricProducers[0]->getCurrentBucketNum();

cmds/statsd/tests/e2e/ValueMetric_pull_e2e_test.cpp

+2 −0
Original line number Original line Diff line number Diff line
@@ -66,6 +66,7 @@ TEST(ValueMetricE2eTest, TestPulledEvents) { 
        baseTimeNs, configAddedTimeNs, config, cfgKey);

        baseTimeNs, configAddedTimeNs, config, cfgKey);

    EXPECT_EQ(processor->mMetricsManagers.size(), 1u);

    EXPECT_EQ(processor->mMetricsManagers.size(), 1u);

    EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid());

    EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid());

    processor->mStatsPullerManager.ForceClearPullerCache();





    int startBucketNum = processor->mMetricsManagers.begin()->second->

    int startBucketNum = processor->mMetricsManagers.begin()->second->

            mAllMetricProducers[0]->getCurrentBucketNum();

            mAllMetricProducers[0]->getCurrentBucketNum();
@@ -172,6 +173,7 @@ TEST(ValueMetricE2eTest, TestPulledEvents_LateAlarm) { 
        baseTimeNs, configAddedTimeNs, config, cfgKey);

        baseTimeNs, configAddedTimeNs, config, cfgKey);

    EXPECT_EQ(processor->mMetricsManagers.size(), 1u);

    EXPECT_EQ(processor->mMetricsManagers.size(), 1u);

    EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid());

    EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid());

    processor->mStatsPullerManager.ForceClearPullerCache();





    int startBucketNum = processor->mMetricsManagers.begin()->second->

    int startBucketNum = processor->mMetricsManagers.begin()->second->

            mAllMetricProducers[0]->getCurrentBucketNum();

            mAllMetricProducers[0]->getCurrentBucketNum();