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

Commit 40e88ea0 authored by Mark Fasheh's avatar Mark Fasheh
Browse files

DeliQueue: implement isBlockedOnSyncBarrier() 

Bug: 443839962
Test: atest SystemUIGoogleScreenshotTests:com.android.systemui.qs.panels.ui.compose.infinitegrid.InfiniteGridLayoutScreenshotTest#tileGrid[phone]
Flag: build.RELEASE_PACKAGE_MESSAGEQUEUE_IMPLEMENTATION
Change-Id: Ib00e55707e6fbe9e6270b6dfb5e114783e9b3709
parent b112050d

core/java/android/os/CombinedDeliMessageQueue/MessageQueue.java

+6 −1
Original line number Diff line number Diff line
@@ -1442,7 +1442,12 @@ public final class MessageQueue { 
    boolean isBlockedOnSyncBarrier() {

        ActivityThread.throwIfNotInstrumenting();

        if (sUseDeliQueue) {

            throw new UnsupportedOperationException("Not implemented");

            // Call nextMessage to process any pending barriers

            nextMessage(true, false);

            Message asyncMsg = mStack.peek(true);



            return mSyncBarrier != null &&

                    (asyncMsg == null || asyncMsg.when <= mSyncBarrier.when);

        } else {

            Message msg = mMessages;

            return msg != null && msg.target == null;

core/java/android/os/DeliQueue/MessageQueue.java

+6 −1
Original line number Diff line number Diff line
@@ -872,7 +872,12 @@ public final class MessageQueue { 
     */

    boolean isBlockedOnSyncBarrier() {

        ActivityThread.throwIfNotInstrumenting();

        throw new UnsupportedOperationException("Not implemented");

        // Call nextMessage to process any pending barriers

        nextMessage(true, false);

        Message asyncMsg = mStack.peek(true);



        return mSyncBarrier != null &&

                (asyncMsg == null || asyncMsg.when <= mSyncBarrier.when);

    }



    void maybeDrainFreelist() {