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

Commit 083ef5a7 authored by Yu Shan's avatar Yu Shan Committed by Android Build Coastguard Worker
Browse files

Revert "Attach defer_outgoing_bcasts flag." 

This reverts commit 29b69986.

Reason for revert: the cause for b/329506600
Test: Apply the revert locally, observe gcar_emu booting up normally.
(cherry picked from https://googleplex-android-review.googlesource.com/q/commit:cc00ed9ca3952f6af97052011642a155d4edb150)
Merged-In: Ifc525bf34cae178b70416c1255224596921852b4
Change-Id: Ifc525bf34cae178b70416c1255224596921852b4
parent 061d7333

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

+4 −1
Original line number Diff line number Diff line
@@ -286,6 +286,9 @@ class BroadcastQueueModernImpl extends BroadcastQueue { 
    // when the flag is fused on.

    private static final int MSG_DELIVERY_TIMEOUT_SOFT = 8;



    // TODO: Use the trunk stable flag.

    private static final boolean DEFER_FROZEN_OUTGOING_BCASTS = false;



    private void enqueueUpdateRunningList() {

        mLocalHandler.removeMessages(MSG_UPDATE_RUNNING_LIST);

        mLocalHandler.sendEmptyMessage(MSG_UPDATE_RUNNING_LIST);
@@ -763,7 +766,7 @@ class BroadcastQueueModernImpl extends BroadcastQueue { 
        // TODO: Apply delivery group policies and FLAG_REPLACE_PENDING to collapse the

        // outgoing broadcasts.

        // TODO: Add traces/logs for the enqueueing outgoing broadcasts logic.

        if (Flags.deferOutgoingBcasts() && isProcessFreezable(r.callerApp)) {

        if (DEFER_FROZEN_OUTGOING_BCASTS && isProcessFreezable(r.callerApp)) {

            final BroadcastProcessQueue queue = getOrCreateProcessQueue(

                    r.callerApp.processName, r.callerApp.uid);

            if (queue.getOutgoingBroadcastCount() >= mConstants.MAX_FROZEN_OUTGOING_BROADCASTS) {

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

+0 −2
Original line number Diff line number Diff line
@@ -56,7 +56,6 @@ import com.android.server.wm.ActivityTaskManagerService; 


import org.junit.Rule;

import org.mockito.Mock;

import org.mockito.Mockito;

import org.mockito.MockitoAnnotations;



import java.io.File;
@@ -161,7 +160,6 @@ public abstract class BaseBroadcastQueueTest { 
        realAms.mActivityTaskManager = new ActivityTaskManagerService(mContext);

        realAms.mActivityTaskManager.initialize(null, null, mContext.getMainLooper());

        realAms.mAtmInternal = spy(realAms.mActivityTaskManager.getAtmInternal());

        realAms.mOomAdjuster.mCachedAppOptimizer = Mockito.mock(CachedAppOptimizer.class);

        realAms.mOomAdjuster = spy(realAms.mOomAdjuster);

        ExtendedMockito.doNothing().when(() -> ProcessList.setOomAdj(anyInt(), anyInt(), anyInt()));

        realAms.mPackageManagerInt = mPackageManagerInt;

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

+2 −3
Original line number Diff line number Diff line
@@ -86,6 +86,7 @@ import androidx.test.platform.app.InstrumentationRegistry; 


import org.junit.After;

import org.junit.Before;

import org.junit.Ignore;

import org.junit.Test;

import org.mockito.ArgumentMatcher;

import org.mockito.InOrder;
@@ -2334,8 +2335,8 @@ public class BroadcastQueueTest extends BaseBroadcastQueueTest { 
                .isGreaterThan(getReceiverScheduledTime(prioritizedRecord, receiverBlue));

    }



    @Ignore

    @Test

    @RequiresFlagsEnabled(Flags.FLAG_DEFER_OUTGOING_BCASTS)

    public void testDeferOutgoingBroadcasts() throws Exception {

        final ProcessRecord callerApp = makeActiveProcessRecord(PACKAGE_RED);

        setProcessFreezable(callerApp, true /* pendingFreeze */, false /* frozen */);
@@ -2349,8 +2350,6 @@ public class BroadcastQueueTest extends BaseBroadcastQueueTest { 
                makeRegisteredReceiver(receiverGreenApp),

                makeManifestReceiver(PACKAGE_BLUE, CLASS_BLUE),

                makeManifestReceiver(PACKAGE_YELLOW, CLASS_YELLOW))));

        // Verify that we invoke the call to freeze the caller app.

        verify(mAms.mOomAdjuster.mCachedAppOptimizer).freezeAppAsyncImmediateLSP(callerApp);



        waitForIdle();

        verifyScheduleRegisteredReceiver(never(), receiverGreenApp, timeTick);