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

Commit d76c1397 authored by Mark Fasheh's avatar Mark Fasheh
Browse files

DeliQueue process removed messages inline if we are looper thread 

Test: atest MessageQueueTest
Test: atest MessageQueuePerfTest
Bug: 421623328
Flag: EXEMPT new data structure isn't used yet; usages will be flagged.
Change-Id: Iddf94d3dd743db68136053a92457d95a714f78ae
parent 16c68f2d

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

+15 −5
Original line number Diff line number Diff line
@@ -308,11 +308,6 @@ public final class MessageQueue { 
                    + " now: " + SystemClock.uptimeMillis());

        }



        /* If we are running on the looper thread we can add directly to the priority queue */

        if (Thread.currentThread() == mLooperThread) {

            //TODO

        }



        while (true) {

            long waitState = mWaitState;

            long newWaitState;
@@ -762,6 +757,7 @@ public final class MessageQueue { 
            throw new IllegalStateException("The specified message queue synchronization "

                    + " barrier token has not been posted or has already been removed.");

        }

        maybeDrainFreelist();



        boolean needWake;

        while (true) {
@@ -829,6 +825,12 @@ public final class MessageQueue { 
        throw new UnsupportedOperationException("Not implemented");

    }



    void maybeDrainFreelist() {

        if (Thread.currentThread() == mLooperThread) {

            mStack.drainFreelist();

        }

    }



    boolean hasMessages(Handler h, int what, Object object) {

        if (h == null) {

            return false;
@@ -863,6 +865,7 @@ public final class MessageQueue { 
            return;

        }

        mStack.moveMatchingToFreelist(sMatchHandlerWhatAndObject, h, what, object, null, 0);

        maybeDrainFreelist();

    }



    void removeEqualMessages(Handler h, int what, Object object) {
@@ -870,6 +873,7 @@ public final class MessageQueue { 
            return;

        }

        mStack.moveMatchingToFreelist(sMatchHandlerWhatAndObjectEquals, h, what, object, null, 0);

        maybeDrainFreelist();

    }



    void removeMessages(Handler h, Runnable r, Object object) {
@@ -877,6 +881,7 @@ public final class MessageQueue { 
            return;

        }

        mStack.moveMatchingToFreelist(sMatchHandlerRunnableAndObject, h, -1, object, r, 0);

        maybeDrainFreelist();

    }



    void removeEqualMessages(Handler h, Runnable r, Object object) {
@@ -884,6 +889,7 @@ public final class MessageQueue { 
            return;

        }

        mStack.moveMatchingToFreelist(sMatchHandlerRunnableAndObjectEquals, h, -1, object, r, 0);

        maybeDrainFreelist();

    }



    void removeCallbacksAndMessages(Handler h, Object object) {
@@ -891,6 +897,7 @@ public final class MessageQueue { 
            return;

        }

        mStack.moveMatchingToFreelist(sMatchHandlerAndObject, h, -1, object, null, 0);

        maybeDrainFreelist();

    }



    void removeCallbacksAndEqualMessages(Handler h, Object object) {
@@ -898,14 +905,17 @@ public final class MessageQueue { 
            return;

        }

        mStack.moveMatchingToFreelist(sMatchHandlerAndObjectEquals, h, -1, object, null, 0);

        maybeDrainFreelist();

    }



    private void removeAllMessages() {

        mStack.moveMatchingToFreelist(sMatchAllMessages, null, -1, null, null, 0);

        maybeDrainFreelist();

    }



    private void removeAllFutureMessages(long when) {

        mStack.moveMatchingToFreelist(sMatchAllFutureMessages, null, -1, null, null, when);

        maybeDrainFreelist();

    }



    /**