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

Commit e8268f13 authored by Sudheer Shanka's avatar Sudheer Shanka Committed by Automerger Merge Worker
Browse files

Merge "Changed the cached threshold that decides when to defer bcasts." into... 

Merge "Changed the cached threshold that decides when to defer bcasts." into udc-dev am: dea20a43 am: c907c02a

Original change: https://googleplex-android-review.googlesource.com/c/platform/frameworks/base/+/23705814



Change-Id: I2e7008ecfb2c0cb99a242bf1e21f2687e1af8432
Signed-off-by: default avatarAutomerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
parents 41713738 c907c02a

services/core/java/com/android/server/am/BroadcastQueueModernImpl.java

+8 −4
Original line number Diff line number Diff line
@@ -1608,11 +1608,15 @@ class BroadcastQueueModernImpl extends BroadcastQueue { 
                    refreshProcessQueuesLocked(uid);

                }

            }

        }, ActivityManager.UID_OBSERVER_PROCSTATE,

                ActivityManager.PROCESS_STATE_TOP, "android");



        mService.registerUidObserver(new UidObserver() {

            @Override

            public void onUidCachedChanged(int uid, boolean cached) {

            public void onUidStateChanged(int uid, int procState, long procStateSeq,

                    int capability) {

                synchronized (mService) {

                    if (cached) {

                    if (procState > ActivityManager.PROCESS_STATE_LAST_ACTIVITY) {

                        mUidCached.put(uid, true);

                    } else {

                        mUidCached.delete(uid);
@@ -1620,8 +1624,8 @@ class BroadcastQueueModernImpl extends BroadcastQueue { 
                    refreshProcessQueuesLocked(uid);

                }

            }

        }, ActivityManager.UID_OBSERVER_PROCSTATE | ActivityManager.UID_OBSERVER_CACHED,

                ActivityManager.PROCESS_STATE_TOP, "android");

        }, ActivityManager.UID_OBSERVER_PROCSTATE,

                ActivityManager.PROCESS_STATE_LAST_ACTIVITY, "android");



        // Kick off periodic health checks

        mLocalHandler.sendEmptyMessage(MSG_CHECK_HEALTH);

services/tests/mockingservicestests/src/com/android/server/am/BroadcastQueueTest.java

+32 −9
Original line number Diff line number Diff line
@@ -172,6 +172,7 @@ public class BroadcastQueueTest { 
    BroadcastConstants mConstants;

    private BroadcastSkipPolicy mSkipPolicy;

    private UidObserver mUidObserver;

    private UidObserver mUidCachedStateObserver;



    /**

     * Desired behavior of the next
@@ -317,7 +318,13 @@ public class BroadcastQueueTest { 
        doAnswer((invocation) -> {

            mUidObserver = invocation.getArgument(0);

            return null;

        }).when(mAms).registerUidObserver(any(), anyInt(), anyInt(), any());

        }).when(mAms).registerUidObserver(any(), anyInt(),

                eq(ActivityManager.PROCESS_STATE_TOP), any());

        doAnswer((invocation) -> {

            mUidCachedStateObserver = invocation.getArgument(0);

            return null;

        }).when(mAms).registerUidObserver(any(), anyInt(),

                eq(ActivityManager.PROCESS_STATE_LAST_ACTIVITY), any());



        mConstants = new BroadcastConstants(Settings.Global.BROADCAST_FG_CONSTANTS);

        mConstants.TIMEOUT = 100;
@@ -1762,8 +1769,12 @@ public class BroadcastQueueTest { 
        final ProcessRecord receiverYellowApp = makeActiveProcessRecord(PACKAGE_YELLOW);

        final ProcessRecord receiverOrangeApp = makeActiveProcessRecord(PACKAGE_ORANGE);



        mUidObserver.onUidCachedChanged(getUidForPackage(PACKAGE_GREEN), true);

        mUidObserver.onUidCachedChanged(getUidForPackage(PACKAGE_BLUE), true);

        mUidCachedStateObserver.onUidStateChanged(getUidForPackage(PACKAGE_GREEN),

                ActivityManager.PROCESS_STATE_CACHED_ACTIVITY, 0,

                ActivityManager.PROCESS_CAPABILITY_NONE);

        mUidCachedStateObserver.onUidStateChanged(getUidForPackage(PACKAGE_BLUE),

                ActivityManager.PROCESS_STATE_CACHED_EMPTY, 0,

                ActivityManager.PROCESS_CAPABILITY_NONE);



        final Intent timeTick = new Intent(Intent.ACTION_TIME_TICK);

        final BroadcastOptions opts = BroadcastOptions.makeBasic()
@@ -1807,12 +1818,16 @@ public class BroadcastQueueTest { 
                eq(UserHandle.USER_SYSTEM), anyInt(), anyInt(), any());



        // Shift blue to be active and confirm that deferred broadcast is delivered

        mUidObserver.onUidCachedChanged(getUidForPackage(PACKAGE_BLUE), false);

        mUidCachedStateObserver.onUidStateChanged(getUidForPackage(PACKAGE_BLUE),

                ActivityManager.PROCESS_STATE_TOP, 0,

                ActivityManager.PROCESS_CAPABILITY_NONE);

        waitForIdle();

        verifyScheduleRegisteredReceiver(times(1), receiverBlueApp, timeTick);



        // Shift green to be active and confirm that deferred broadcast is delivered

        mUidObserver.onUidCachedChanged(getUidForPackage(PACKAGE_GREEN), false);

        mUidCachedStateObserver.onUidStateChanged(getUidForPackage(PACKAGE_GREEN),

                ActivityManager.PROCESS_STATE_SERVICE, 0,

                ActivityManager.PROCESS_CAPABILITY_NONE);

        waitForIdle();

        verifyScheduleRegisteredReceiver(times(1), receiverGreenApp, timeTick);

    }
@@ -2237,9 +2252,15 @@ public class BroadcastQueueTest { 
        final ProcessRecord receiverBlueApp = makeActiveProcessRecord(PACKAGE_BLUE);

        final ProcessRecord receiverYellowApp = makeActiveProcessRecord(PACKAGE_YELLOW);



        mUidObserver.onUidCachedChanged(getUidForPackage(PACKAGE_GREEN), true);

        mUidObserver.onUidCachedChanged(getUidForPackage(PACKAGE_BLUE), true);

        mUidObserver.onUidCachedChanged(getUidForPackage(PACKAGE_YELLOW), false);

        mUidCachedStateObserver.onUidStateChanged(getUidForPackage(PACKAGE_GREEN),

                ActivityManager.PROCESS_STATE_CACHED_ACTIVITY, 0,

                ActivityManager.PROCESS_CAPABILITY_NONE);

        mUidCachedStateObserver.onUidStateChanged(getUidForPackage(PACKAGE_BLUE),

                ActivityManager.PROCESS_STATE_CACHED_EMPTY, 0,

                ActivityManager.PROCESS_CAPABILITY_NONE);

        mUidCachedStateObserver.onUidStateChanged(getUidForPackage(PACKAGE_YELLOW),

                ActivityManager.PROCESS_STATE_SERVICE, 0,

                ActivityManager.PROCESS_CAPABILITY_NONE);



        final Intent airplane = new Intent(Intent.ACTION_AIRPLANE_MODE_CHANGED);

        final BroadcastOptions opts = BroadcastOptions.makeBasic()
@@ -2262,7 +2283,9 @@ public class BroadcastQueueTest { 
        verifyScheduleRegisteredReceiver(times(1), receiverYellowApp, airplane);



        // Shift green to be active and confirm that deferred broadcast is delivered

        mUidObserver.onUidCachedChanged(getUidForPackage(PACKAGE_GREEN), false);

        mUidCachedStateObserver.onUidStateChanged(getUidForPackage(PACKAGE_GREEN),

                ActivityManager.PROCESS_STATE_TOP_SLEEPING, 0,

                ActivityManager.PROCESS_CAPABILITY_NONE);

        waitForIdle();

        verifyScheduleRegisteredReceiver(times(1), receiverGreenApp, airplane);

    }