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

Commit ace080f9 authored by Hui Wang's avatar Hui Wang
Browse files

Clear the cache after the logs get pulled

Flag: EXEMPT bugfix
Bug: 381915369
Test: atest TelecomUnitTests:TelecomPulledAtomTest
Test: manual
Change-Id: Icf5856baa343c3c1e7ba896a45bce3141bff7371
parent 385a742f
Loading
Loading
Loading
Loading
+2 −0
Original line number Diff line number Diff line
@@ -191,6 +191,8 @@ public class ApiStats extends TelecomPulledAtom {
            Arrays.stream(mPulledAtoms.telecomApiStats).forEach(v -> data.add(
                    TelecomStatsLog.buildStatsEvent(getTag(),
                            v.getApiName(), v.getUid(), v.getApiResult(), v.getCount())));
            mApiStatsMap.clear();
            onAggregate();
            return StatsManager.PULL_SUCCESS;
        } else {
            return StatsManager.PULL_SKIP;
+2 −0
Original line number Diff line number Diff line
@@ -99,6 +99,8 @@ public class AudioRouteStats extends TelecomPulledAtom {
                    TelecomStatsLog.buildStatsEvent(getTag(),
                            v.getCallAudioRouteSource(), v.getCallAudioRouteDest(),
                            v.getSuccess(), v.getRevert(), v.getCount(), v.getAverageLatencyMs())));
            mAudioRouteStatsMap.clear();
            onAggregate();
            return StatsManager.PULL_SUCCESS;
        } else {
            return StatsManager.PULL_SKIP;
+2 −0
Original line number Diff line number Diff line
@@ -81,6 +81,8 @@ public class CallStats extends TelecomPulledAtom {
                            v.getCallDirection(), v.getExternalCall(), v.getEmergencyCall(),
                            v.getMultipleAudioAvailable(), v.getAccountType(), v.getUid(),
                            v.getCount(), v.getAverageDurationMs())));
            mCallStatsMap.clear();
            onAggregate();
            return StatsManager.PULL_SUCCESS;
        } else {
            return StatsManager.PULL_SKIP;
+2 −0
Original line number Diff line number Diff line
@@ -140,6 +140,8 @@ public class ErrorStats extends TelecomPulledAtom {
            Arrays.stream(mPulledAtoms.telecomErrorStats).forEach(v -> data.add(
                    TelecomStatsLog.buildStatsEvent(getTag(),
                            v.getSubmodule(), v.getError(), v.getCount())));
            mErrorStatsMap.clear();
            onAggregate();
            return StatsManager.PULL_SUCCESS;
        } else {
            return StatsManager.PULL_SKIP;
+12 −4
Original line number Diff line number Diff line
@@ -207,12 +207,14 @@ public class TelecomPulledAtomTest extends TelecomTestCase {
        createTestFileForApiStats(System.currentTimeMillis() - MIN_PULL_INTERVAL_MILLIS - 1);
        ApiStats apiStats = spy(new ApiStats(mSpyContext, mLooper));
        final List<StatsEvent> data = new ArrayList<>();
        int sizePulled = apiStats.mPulledAtoms.telecomApiStats.length;

        int result = apiStats.pull(data);

        assertEquals(StatsManager.PULL_SUCCESS, result);
        verify(apiStats).onPull(eq(data));
        assertEquals(data.size(), apiStats.mPulledAtoms.telecomApiStats.length);
        assertEquals(data.size(), sizePulled);
        assertEquals(apiStats.mPulledAtoms.telecomApiStats.length, 0);
    }

    @Test
@@ -233,12 +235,14 @@ public class TelecomPulledAtomTest extends TelecomTestCase {
        createTestFileForAudioRouteStats(System.currentTimeMillis() - MIN_PULL_INTERVAL_MILLIS - 1);
        AudioRouteStats audioRouteStats = spy(new AudioRouteStats(mSpyContext, mLooper));
        final List<StatsEvent> data = new ArrayList<>();
        int sizePulled = audioRouteStats.mPulledAtoms.callAudioRouteStats.length;

        int result = audioRouteStats.pull(data);

        assertEquals(StatsManager.PULL_SUCCESS, result);
        verify(audioRouteStats).onPull(eq(data));
        assertEquals(data.size(), audioRouteStats.mPulledAtoms.callAudioRouteStats.length);
        assertEquals(data.size(), sizePulled);
        assertEquals(audioRouteStats.mPulledAtoms.callAudioRouteStats.length, 0);
    }

    @Test
@@ -259,12 +263,14 @@ public class TelecomPulledAtomTest extends TelecomTestCase {
        createTestFileForCallStats(System.currentTimeMillis() - MIN_PULL_INTERVAL_MILLIS - 1);
        CallStats callStats = spy(new CallStats(mSpyContext, mLooper));
        final List<StatsEvent> data = new ArrayList<>();
        int sizePulled = callStats.mPulledAtoms.callStats.length;

        int result = callStats.pull(data);

        assertEquals(StatsManager.PULL_SUCCESS, result);
        verify(callStats).onPull(eq(data));
        assertEquals(data.size(), callStats.mPulledAtoms.callStats.length);
        assertEquals(data.size(), sizePulled);
        assertEquals(callStats.mPulledAtoms.callStats.length, 0);
    }

    @Test
@@ -285,12 +291,14 @@ public class TelecomPulledAtomTest extends TelecomTestCase {
        createTestFileForErrorStats(System.currentTimeMillis() - MIN_PULL_INTERVAL_MILLIS - 1);
        ErrorStats errorStats = spy(new ErrorStats(mSpyContext, mLooper));
        final List<StatsEvent> data = new ArrayList<>();
        int sizePulled = errorStats.mPulledAtoms.telecomErrorStats.length;

        int result = errorStats.pull(data);

        assertEquals(StatsManager.PULL_SUCCESS, result);
        verify(errorStats).onPull(eq(data));
        assertEquals(data.size(), errorStats.mPulledAtoms.telecomErrorStats.length);
        assertEquals(data.size(), sizePulled);
        assertEquals(errorStats.mPulledAtoms.telecomErrorStats.length, 0);
    }

    @Test