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

Commit 5f0d4ca5 authored by TreeHugger Robot's avatar TreeHugger Robot Committed by Automerger Merge Worker
Browse files

Merge "SF: avoid rearming Timer during cancel" into rvc-dev am: 0f083b8f 

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

Change-Id: I2767eeca9ed78e0fa91f6e6f85319c610651afdf
parents 609de5a2 0f083b8f

services/surfaceflinger/Scheduler/VSyncDispatchTimerQueue.cpp

+7 −3
Original line number Diff line number Diff line
@@ -338,10 +338,14 @@ CancelResult VSyncDispatchTimerQueue::cancel(CallbackToken token) { 
    }

    auto& callback = it->second;



    if (callback->wakeupTime()) {

    auto const wakeupTime = callback->wakeupTime();

    if (wakeupTime) {

        callback->disarm();



        if (*wakeupTime == mIntendedWakeupTime) {

            mIntendedWakeupTime = kInvalidTime;

            rearmTimer(mTimeKeeper->now());

        }

        return CancelResult::Cancelled;

    }

    return CancelResult::TooLate;

services/surfaceflinger/tests/unittests/VSyncDispatchTimerQueueTest.cpp

+46 −0
Original line number Diff line number Diff line
@@ -701,6 +701,52 @@ TEST_F(VSyncDispatchTimerQueueTest, skipsSchedulingIfTimerReschedulingIsImminent 
    EXPECT_THAT(cb.mCalls.size(), Eq(1));

}



// b/154303580.

TEST_F(VSyncDispatchTimerQueueTest, skipsRearmingWhenNotNextScheduled) {

    Sequence seq;

    EXPECT_CALL(mMockClock, alarmIn(_, 600)).InSequence(seq);

    EXPECT_CALL(mMockClock, alarmCancel()).InSequence(seq);

    CountingCallback cb1(mDispatch);

    CountingCallback cb2(mDispatch);



    EXPECT_EQ(mDispatch.schedule(cb1, 400, 1000), ScheduleResult::Scheduled);

    EXPECT_EQ(mDispatch.schedule(cb2, 100, 2000), ScheduleResult::Scheduled);



    mMockClock.setLag(100);

    mMockClock.advanceBy(620);



    EXPECT_EQ(mDispatch.cancel(cb2), CancelResult::Cancelled);



    mMockClock.advanceBy(80);



    EXPECT_THAT(cb1.mCalls.size(), Eq(1));

    EXPECT_THAT(cb2.mCalls.size(), Eq(0));

}



TEST_F(VSyncDispatchTimerQueueTest, rearmsWhenCancelledAndIsNextScheduled) {

    Sequence seq;

    EXPECT_CALL(mMockClock, alarmIn(_, 600)).InSequence(seq);

    EXPECT_CALL(mMockClock, alarmIn(_, 1280)).InSequence(seq);

    EXPECT_CALL(mMockClock, alarmCancel()).InSequence(seq);

    CountingCallback cb1(mDispatch);

    CountingCallback cb2(mDispatch);



    EXPECT_EQ(mDispatch.schedule(cb1, 400, 1000), ScheduleResult::Scheduled);

    EXPECT_EQ(mDispatch.schedule(cb2, 100, 2000), ScheduleResult::Scheduled);



    mMockClock.setLag(100);

    mMockClock.advanceBy(620);



    EXPECT_EQ(mDispatch.cancel(cb1), CancelResult::Cancelled);



    EXPECT_THAT(cb1.mCalls.size(), Eq(0));

    EXPECT_THAT(cb2.mCalls.size(), Eq(0));

    mMockClock.advanceToNextCallback();



    EXPECT_THAT(cb1.mCalls.size(), Eq(0));

    EXPECT_THAT(cb2.mCalls.size(), Eq(1));

}



class VSyncDispatchTimerQueueEntryTest : public testing::Test {

protected:

    nsecs_t const mPeriod = 1000;