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

Commit 532b0220 authored by Hui Wang's avatar Hui Wang Committed by Android (Google) Code Review
Browse files

Merge "Clear the cache after the logs get pulled" into main

parents 9586d387 ace080f9
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