|  | /* | 
|  | * Copyright 2019 The Android Open Source Project | 
|  | * | 
|  | * Licensed under the Apache License, Version 2.0 (the "License"); | 
|  | * you may not use this file except in compliance with the License. | 
|  | * You may obtain a copy of the License at | 
|  | * | 
|  | *      http://www.apache.org/licenses/LICENSE-2.0 | 
|  | * | 
|  | * Unless required by applicable law or agreed to in writing, software | 
|  | * distributed under the License is distributed on an "AS IS" BASIS, | 
|  | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | 
|  | * See the License for the specific language governing permissions and | 
|  | * limitations under the License. | 
|  | */ | 
|  |  | 
|  |  | 
|  | #undef LOG_TAG | 
|  | #define LOG_TAG "CompositionTest" | 
|  |  | 
|  | #include <compositionengine/Display.h> | 
|  | #include <compositionengine/mock/DisplaySurface.h> | 
|  | #include <gmock/gmock.h> | 
|  | #include <gtest/gtest.h> | 
|  | #include <gui/SurfaceComposerClient.h> | 
|  | #include <log/log.h> | 
|  | #include <ui/MockFence.h> | 
|  | #include <utils/String8.h> | 
|  |  | 
|  | #include "TestableSurfaceFlinger.h" | 
|  | #include "mock/MockEventThread.h" | 
|  | #include "mock/MockVsyncController.h" | 
|  |  | 
|  | namespace android { | 
|  |  | 
|  | using testing::_; | 
|  | using testing::Return; | 
|  |  | 
|  | using FakeHwcDisplayInjector = TestableSurfaceFlinger::FakeHwcDisplayInjector; | 
|  |  | 
|  | class TransactionApplicationTest : public testing::Test { | 
|  | public: | 
|  | TransactionApplicationTest() { | 
|  | const ::testing::TestInfo* const test_info = | 
|  | ::testing::UnitTest::GetInstance()->current_test_info(); | 
|  | ALOGD("**** Setting up for %s.%s\n", test_info->test_case_name(), test_info->name()); | 
|  |  | 
|  | setupScheduler(); | 
|  | } | 
|  |  | 
|  | ~TransactionApplicationTest() { | 
|  | const ::testing::TestInfo* const test_info = | 
|  | ::testing::UnitTest::GetInstance()->current_test_info(); | 
|  | ALOGD("**** Tearing down after %s.%s\n", test_info->test_case_name(), test_info->name()); | 
|  | } | 
|  |  | 
|  | void setupScheduler() { | 
|  | auto eventThread = std::make_unique<mock::EventThread>(); | 
|  | auto sfEventThread = std::make_unique<mock::EventThread>(); | 
|  |  | 
|  | EXPECT_CALL(*eventThread, registerDisplayEventConnection(_)); | 
|  | EXPECT_CALL(*eventThread, createEventConnection(_, _)) | 
|  | .WillOnce(Return(new EventThreadConnection(eventThread.get(), /*callingUid=*/0, | 
|  | ResyncCallback()))); | 
|  |  | 
|  | EXPECT_CALL(*sfEventThread, registerDisplayEventConnection(_)); | 
|  | EXPECT_CALL(*sfEventThread, createEventConnection(_, _)) | 
|  | .WillOnce(Return(new EventThreadConnection(sfEventThread.get(), /*callingUid=*/0, | 
|  | ResyncCallback()))); | 
|  |  | 
|  | EXPECT_CALL(*mVSyncTracker, nextAnticipatedVSyncTimeFrom(_)).WillRepeatedly(Return(0)); | 
|  | EXPECT_CALL(*mVSyncTracker, currentPeriod()) | 
|  | .WillRepeatedly(Return(FakeHwcDisplayInjector::DEFAULT_VSYNC_PERIOD)); | 
|  |  | 
|  | EXPECT_CALL(*mFenceUnsignaled, getStatus()) | 
|  | .WillRepeatedly(Return(Fence::Status::Unsignaled)); | 
|  | EXPECT_CALL(*mFenceUnsignaled2, getStatus()) | 
|  | .WillRepeatedly(Return(Fence::Status::Unsignaled)); | 
|  | EXPECT_CALL(*mFenceSignaled, getStatus()).WillRepeatedly(Return(Fence::Status::Signaled)); | 
|  | EXPECT_CALL(*mFenceSignaled2, getStatus()).WillRepeatedly(Return(Fence::Status::Signaled)); | 
|  |  | 
|  | mFlinger.setupComposer(std::make_unique<Hwc2::mock::Composer>()); | 
|  | mFlinger.setupScheduler(std::unique_ptr<mock::VsyncController>(mVsyncController), | 
|  | std::unique_ptr<mock::VSyncTracker>(mVSyncTracker), | 
|  | std::move(eventThread), std::move(sfEventThread)); | 
|  | } | 
|  |  | 
|  | TestableSurfaceFlinger mFlinger; | 
|  |  | 
|  | mock::VsyncController* mVsyncController = new mock::VsyncController(); | 
|  | mock::VSyncTracker* mVSyncTracker = new mock::VSyncTracker(); | 
|  | mock::MockFence* mFenceUnsignaled = new mock::MockFence(); | 
|  | mock::MockFence* mFenceSignaled = new mock::MockFence(); | 
|  | mock::MockFence* mFenceUnsignaled2 = new mock::MockFence(); | 
|  | mock::MockFence* mFenceSignaled2 = new mock::MockFence(); | 
|  |  | 
|  | struct TransactionInfo { | 
|  | Vector<ComposerState> states; | 
|  | Vector<DisplayState> displays; | 
|  | uint32_t flags = 0; | 
|  | sp<IBinder> applyToken = IInterface::asBinder(TransactionCompletedListener::getIInstance()); | 
|  | InputWindowCommands inputWindowCommands; | 
|  | int64_t desiredPresentTime = 0; | 
|  | bool isAutoTimestamp = true; | 
|  | FrameTimelineInfo frameTimelineInfo; | 
|  | client_cache_t uncacheBuffer; | 
|  | uint64_t id = static_cast<uint64_t>(-1); | 
|  | static_assert(0xffffffffffffffff == static_cast<uint64_t>(-1)); | 
|  | }; | 
|  |  | 
|  | void checkEqual(TransactionInfo info, TransactionState state) { | 
|  | EXPECT_EQ(0u, info.states.size()); | 
|  | EXPECT_EQ(0u, state.states.size()); | 
|  |  | 
|  | EXPECT_EQ(0u, info.displays.size()); | 
|  | EXPECT_EQ(0u, state.displays.size()); | 
|  | EXPECT_EQ(info.flags, state.flags); | 
|  | EXPECT_EQ(info.desiredPresentTime, state.desiredPresentTime); | 
|  | } | 
|  |  | 
|  | void setupSingle(TransactionInfo& transaction, uint32_t flags, bool syncInputWindows, | 
|  | int64_t desiredPresentTime, bool isAutoTimestamp, | 
|  | const FrameTimelineInfo& frameTimelineInfo) { | 
|  | mTransactionNumber++; | 
|  | transaction.flags |= flags; // ISurfaceComposer::eSynchronous; | 
|  | transaction.inputWindowCommands.syncInputWindows = syncInputWindows; | 
|  | transaction.desiredPresentTime = desiredPresentTime; | 
|  | transaction.isAutoTimestamp = isAutoTimestamp; | 
|  | transaction.frameTimelineInfo = frameTimelineInfo; | 
|  | } | 
|  |  | 
|  | void setupSingleWithComposer(TransactionInfo& transaction, uint32_t flags, | 
|  | bool syncInputWindows, int64_t desiredPresentTime, | 
|  | bool isAutoTimestamp, const FrameTimelineInfo& frameTimelineInfo, | 
|  | const Vector<ComposerState>* states) { | 
|  | setupSingle(transaction, flags, syncInputWindows, desiredPresentTime, isAutoTimestamp, | 
|  | frameTimelineInfo); | 
|  | transaction.states = *states; | 
|  | } | 
|  |  | 
|  | void NotPlacedOnTransactionQueue(uint32_t flags, bool syncInputWindows) { | 
|  | ASSERT_EQ(0u, mFlinger.getTransactionQueue().size()); | 
|  | EXPECT_CALL(*mFlinger.scheduler(), scheduleFrame()).Times(1); | 
|  | TransactionInfo transaction; | 
|  | setupSingle(transaction, flags, syncInputWindows, | 
|  | /*desiredPresentTime*/ systemTime(), /*isAutoTimestamp*/ true, | 
|  | FrameTimelineInfo{}); | 
|  | nsecs_t applicationTime = systemTime(); | 
|  | mFlinger.setTransactionState(transaction.frameTimelineInfo, transaction.states, | 
|  | transaction.displays, transaction.flags, | 
|  | transaction.applyToken, transaction.inputWindowCommands, | 
|  | transaction.desiredPresentTime, transaction.isAutoTimestamp, | 
|  | transaction.uncacheBuffer, mHasListenerCallbacks, mCallbacks, | 
|  | transaction.id); | 
|  |  | 
|  | // If transaction is synchronous or syncs input windows, SF | 
|  | // applyTransactionState should time out (5s) wating for SF to commit | 
|  | // the transaction or to receive a signal that syncInputWindows has | 
|  | // completed.  If this is animation, it should not time out waiting. | 
|  | nsecs_t returnedTime = systemTime(); | 
|  | if (flags & ISurfaceComposer::eSynchronous || syncInputWindows) { | 
|  | EXPECT_GE(returnedTime, applicationTime + s2ns(5)); | 
|  | } else { | 
|  | EXPECT_LE(returnedTime, applicationTime + s2ns(5)); | 
|  | } | 
|  | // Each transaction should have been placed on the transaction queue | 
|  | auto transactionQueue = mFlinger.getTransactionQueue(); | 
|  | EXPECT_EQ(1u, transactionQueue.size()); | 
|  | } | 
|  |  | 
|  | void PlaceOnTransactionQueue(uint32_t flags, bool syncInputWindows) { | 
|  | ASSERT_EQ(0u, mFlinger.getTransactionQueue().size()); | 
|  | EXPECT_CALL(*mFlinger.scheduler(), scheduleFrame()).Times(1); | 
|  |  | 
|  | // first check will see desired present time has not passed, | 
|  | // but afterwards it will look like the desired present time has passed | 
|  | nsecs_t time = systemTime(); | 
|  | TransactionInfo transaction; | 
|  | setupSingle(transaction, flags, syncInputWindows, | 
|  | /*desiredPresentTime*/ time + s2ns(1), false, FrameTimelineInfo{}); | 
|  | nsecs_t applicationSentTime = systemTime(); | 
|  | mFlinger.setTransactionState(transaction.frameTimelineInfo, transaction.states, | 
|  | transaction.displays, transaction.flags, | 
|  | transaction.applyToken, transaction.inputWindowCommands, | 
|  | transaction.desiredPresentTime, transaction.isAutoTimestamp, | 
|  | transaction.uncacheBuffer, mHasListenerCallbacks, mCallbacks, | 
|  | transaction.id); | 
|  |  | 
|  | nsecs_t returnedTime = systemTime(); | 
|  | if ((flags & ISurfaceComposer::eSynchronous) || syncInputWindows) { | 
|  | EXPECT_GE(systemTime(), applicationSentTime + s2ns(5)); | 
|  | } else { | 
|  | EXPECT_LE(returnedTime, applicationSentTime + s2ns(5)); | 
|  | } | 
|  | // This transaction should have been placed on the transaction queue | 
|  | auto transactionQueue = mFlinger.getTransactionQueue(); | 
|  | EXPECT_EQ(1u, transactionQueue.size()); | 
|  | } | 
|  |  | 
|  | void BlockedByPriorTransaction(uint32_t flags, bool syncInputWindows) { | 
|  | ASSERT_EQ(0u, mFlinger.getTransactionQueue().size()); | 
|  | nsecs_t time = systemTime(); | 
|  | if (!syncInputWindows) { | 
|  | EXPECT_CALL(*mFlinger.scheduler(), scheduleFrame()).Times(2); | 
|  | } else { | 
|  | EXPECT_CALL(*mFlinger.scheduler(), scheduleFrame()).Times(1); | 
|  | } | 
|  | // transaction that should go on the pending thread | 
|  | TransactionInfo transactionA; | 
|  | setupSingle(transactionA, /*flags*/ 0, /*syncInputWindows*/ false, | 
|  | /*desiredPresentTime*/ time + s2ns(1), false, FrameTimelineInfo{}); | 
|  |  | 
|  | // transaction that would not have gone on the pending thread if not | 
|  | // blocked | 
|  | TransactionInfo transactionB; | 
|  | setupSingle(transactionB, flags, syncInputWindows, | 
|  | /*desiredPresentTime*/ systemTime(), /*isAutoTimestamp*/ true, | 
|  | FrameTimelineInfo{}); | 
|  |  | 
|  | nsecs_t applicationSentTime = systemTime(); | 
|  | mFlinger.setTransactionState(transactionA.frameTimelineInfo, transactionA.states, | 
|  | transactionA.displays, transactionA.flags, | 
|  | transactionA.applyToken, transactionA.inputWindowCommands, | 
|  | transactionA.desiredPresentTime, transactionA.isAutoTimestamp, | 
|  | transactionA.uncacheBuffer, mHasListenerCallbacks, mCallbacks, | 
|  | transactionA.id); | 
|  |  | 
|  | // This thread should not have been blocked by the above transaction | 
|  | // (5s is the timeout period that applyTransactionState waits for SF to | 
|  | // commit the transaction) | 
|  | EXPECT_LE(systemTime(), applicationSentTime + s2ns(5)); | 
|  | // transaction that would goes to pending transaciton queue. | 
|  | mFlinger.flushTransactionQueues(); | 
|  |  | 
|  | applicationSentTime = systemTime(); | 
|  | mFlinger.setTransactionState(transactionB.frameTimelineInfo, transactionB.states, | 
|  | transactionB.displays, transactionB.flags, | 
|  | transactionB.applyToken, transactionB.inputWindowCommands, | 
|  | transactionB.desiredPresentTime, transactionB.isAutoTimestamp, | 
|  | transactionB.uncacheBuffer, mHasListenerCallbacks, mCallbacks, | 
|  | transactionB.id); | 
|  |  | 
|  | // this thread should have been blocked by the above transaction | 
|  | // if this is an animation, this thread should be blocked for 5s | 
|  | // in setTransactionState waiting for transactionA to flush.  Otherwise, | 
|  | // the transaction should be placed on the pending queue | 
|  | if (flags & (ISurfaceComposer::eAnimation | ISurfaceComposer::eSynchronous) || | 
|  | syncInputWindows) { | 
|  | EXPECT_GE(systemTime(), applicationSentTime + s2ns(5)); | 
|  | } else { | 
|  | EXPECT_LE(systemTime(), applicationSentTime + s2ns(5)); | 
|  | } | 
|  |  | 
|  | // transaction that would goes to pending transaciton queue. | 
|  | mFlinger.flushTransactionQueues(); | 
|  |  | 
|  | // check that the transaction was applied. | 
|  | auto transactionQueue = mFlinger.getPendingTransactionQueue(); | 
|  | EXPECT_EQ(0u, transactionQueue.size()); | 
|  | } | 
|  |  | 
|  | void Flush_removesUnsignaledFromTheQueue(Vector<ComposerState> state1, | 
|  | Vector<ComposerState> state2, | 
|  | bool updateApplyToken = true) { | 
|  | ASSERT_EQ(0u, mFlinger.getTransactionQueue().size()); | 
|  |  | 
|  | TransactionInfo transactionA; | 
|  | setupSingleWithComposer(transactionA, ISurfaceComposer::eSynchronous, | 
|  | /*syncInputWindows*/ false, | 
|  | /*desiredPresentTime*/ systemTime(), /*isAutoTimestamp*/ true, | 
|  | FrameTimelineInfo{}, &state1); | 
|  |  | 
|  | mFlinger.setTransactionState(transactionA.frameTimelineInfo, transactionA.states, | 
|  | transactionA.displays, transactionA.flags, | 
|  | transactionA.applyToken, transactionA.inputWindowCommands, | 
|  | transactionA.desiredPresentTime, transactionA.isAutoTimestamp, | 
|  | transactionA.uncacheBuffer, mHasListenerCallbacks, mCallbacks, | 
|  | transactionA.id); | 
|  |  | 
|  | TransactionInfo transactionB; | 
|  | if (updateApplyToken) { | 
|  | transactionB.applyToken = sp<IBinder>(); | 
|  | } | 
|  | setupSingleWithComposer(transactionB, ISurfaceComposer::eSynchronous, | 
|  | /*syncInputWindows*/ false, | 
|  | /*desiredPresentTime*/ systemTime(), /*isAutoTimestamp*/ true, | 
|  | FrameTimelineInfo{}, &state2); | 
|  | mFlinger.setTransactionState(transactionB.frameTimelineInfo, transactionB.states, | 
|  | transactionB.displays, transactionB.flags, | 
|  | transactionB.applyToken, transactionB.inputWindowCommands, | 
|  | transactionB.desiredPresentTime, transactionB.isAutoTimestamp, | 
|  | transactionB.uncacheBuffer, mHasListenerCallbacks, mCallbacks, | 
|  | transactionB.id); | 
|  |  | 
|  | mFlinger.flushTransactionQueues(); | 
|  | EXPECT_EQ(0u, mFlinger.getPendingTransactionQueue().size()); | 
|  | EXPECT_EQ(0u, mFlinger.getTransactionQueue().size()); | 
|  | EXPECT_EQ(2ul, mFlinger.getTransactionCommittedSignals().size()); | 
|  | } | 
|  |  | 
|  | void Flush_removesFromTheQueue(const Vector<ComposerState>& state) { | 
|  | ASSERT_EQ(0u, mFlinger.getTransactionQueue().size()); | 
|  | EXPECT_EQ(0u, mFlinger.getPendingTransactionQueue().size()); | 
|  |  | 
|  | TransactionInfo transaction; | 
|  | setupSingleWithComposer(transaction, ISurfaceComposer::eSynchronous, | 
|  | /*syncInputWindows*/ false, | 
|  | /*desiredPresentTime*/ systemTime(), /*isAutoTimestamp*/ true, | 
|  | FrameTimelineInfo{}, &state); | 
|  |  | 
|  | mFlinger.setTransactionState(transaction.frameTimelineInfo, transaction.states, | 
|  | transaction.displays, transaction.flags, | 
|  | transaction.applyToken, transaction.inputWindowCommands, | 
|  | transaction.desiredPresentTime, transaction.isAutoTimestamp, | 
|  | transaction.uncacheBuffer, mHasListenerCallbacks, mCallbacks, | 
|  | transaction.id); | 
|  |  | 
|  | mFlinger.flushTransactionQueues(); | 
|  | EXPECT_EQ(0u, mFlinger.getPendingTransactionQueue().size()); | 
|  | EXPECT_EQ(0u, mFlinger.getTransactionQueue().size()); | 
|  | EXPECT_EQ(1u, mFlinger.getTransactionCommittedSignals().size()); | 
|  | } | 
|  |  | 
|  | void Flush_keepsInTheQueue(const Vector<ComposerState>& state) { | 
|  | ASSERT_EQ(0u, mFlinger.getTransactionQueue().size()); | 
|  | EXPECT_EQ(0u, mFlinger.getPendingTransactionQueue().size()); | 
|  |  | 
|  | TransactionInfo transaction; | 
|  | setupSingleWithComposer(transaction, ISurfaceComposer::eSynchronous, | 
|  | /*syncInputWindows*/ false, | 
|  | /*desiredPresentTime*/ systemTime(), /*isAutoTimestamp*/ true, | 
|  | FrameTimelineInfo{}, &state); | 
|  |  | 
|  | mFlinger.setTransactionState(transaction.frameTimelineInfo, transaction.states, | 
|  | transaction.displays, transaction.flags, | 
|  | transaction.applyToken, transaction.inputWindowCommands, | 
|  | transaction.desiredPresentTime, transaction.isAutoTimestamp, | 
|  | transaction.uncacheBuffer, mHasListenerCallbacks, mCallbacks, | 
|  | transaction.id); | 
|  |  | 
|  | mFlinger.flushTransactionQueues(); | 
|  | EXPECT_EQ(1u, mFlinger.getPendingTransactionQueue().size()); | 
|  | EXPECT_EQ(0u, mFlinger.getTransactionQueue().size()); | 
|  | EXPECT_EQ(0ul, mFlinger.getTransactionCommittedSignals().size()); | 
|  | } | 
|  |  | 
|  | void Flush_KeepsUnsignaledInTheQueue(const Vector<ComposerState>& state1, | 
|  | const Vector<ComposerState>& state2, | 
|  | bool updateApplyToken = true, | 
|  | uint32_t pendingTransactionQueueSize = 1u) { | 
|  | EXPECT_EQ(0u, mFlinger.getPendingTransactionQueue().size()); | 
|  | ASSERT_EQ(0u, mFlinger.getTransactionQueue().size()); | 
|  | auto time = systemTime(); | 
|  | TransactionInfo transactionA; | 
|  | TransactionInfo transactionB; | 
|  | setupSingleWithComposer(transactionA, ISurfaceComposer::eSynchronous, | 
|  | /*syncInputWindows*/ false, | 
|  | /*desiredPresentTime*/ time, /*isAutoTimestamp*/ true, | 
|  | FrameTimelineInfo{}, &state1); | 
|  | setupSingleWithComposer(transactionB, ISurfaceComposer::eSynchronous, | 
|  | /*syncInputWindows*/ false, | 
|  | /*desiredPresentTime*/ time, /*isAutoTimestamp*/ true, | 
|  | FrameTimelineInfo{}, &state2); | 
|  | mFlinger.setTransactionState(transactionA.frameTimelineInfo, transactionA.states, | 
|  | transactionA.displays, transactionA.flags, | 
|  | transactionA.applyToken, transactionA.inputWindowCommands, | 
|  | transactionA.desiredPresentTime, transactionA.isAutoTimestamp, | 
|  | transactionA.uncacheBuffer, mHasListenerCallbacks, mCallbacks, | 
|  | transactionA.id); | 
|  | if (updateApplyToken) { | 
|  | transactionB.applyToken = sp<IBinder>(); | 
|  | } | 
|  | mFlinger.setTransactionState(transactionB.frameTimelineInfo, transactionB.states, | 
|  | transactionB.displays, transactionB.flags, | 
|  | transactionB.applyToken, transactionB.inputWindowCommands, | 
|  | transactionB.desiredPresentTime, transactionB.isAutoTimestamp, | 
|  | transactionB.uncacheBuffer, mHasListenerCallbacks, mCallbacks, | 
|  | transactionB.id); | 
|  |  | 
|  | mFlinger.flushTransactionQueues(); | 
|  | EXPECT_EQ(pendingTransactionQueueSize, mFlinger.getPendingTransactionQueue().size()); | 
|  | EXPECT_EQ(0u, mFlinger.getTransactionQueue().size()); | 
|  | } | 
|  |  | 
|  | void Flush_removesSignaledFromTheQueue(const Vector<ComposerState>& state1, | 
|  | const Vector<ComposerState>& state2) { | 
|  | ASSERT_EQ(0u, mFlinger.getTransactionQueue().size()); | 
|  | EXPECT_EQ(0u, mFlinger.getPendingTransactionQueue().size()); | 
|  |  | 
|  | auto time = systemTime(); | 
|  | TransactionInfo transactionA; | 
|  | TransactionInfo transactionB; | 
|  | setupSingleWithComposer(transactionA, ISurfaceComposer::eSynchronous, | 
|  | /*syncInputWindows*/ false, | 
|  | /*desiredPresentTime*/ time, /*isAutoTimestamp*/ true, | 
|  | FrameTimelineInfo{}, &state1); | 
|  | setupSingleWithComposer(transactionB, ISurfaceComposer::eSynchronous, | 
|  | /*syncInputWindows*/ false, | 
|  | /*desiredPresentTime*/ time, /*isAutoTimestamp*/ true, | 
|  | FrameTimelineInfo{}, &state2); | 
|  | mFlinger.setTransactionState(transactionA.frameTimelineInfo, transactionA.states, | 
|  | transactionA.displays, transactionA.flags, | 
|  | transactionA.applyToken, transactionA.inputWindowCommands, | 
|  | transactionA.desiredPresentTime, transactionA.isAutoTimestamp, | 
|  | transactionA.uncacheBuffer, mHasListenerCallbacks, mCallbacks, | 
|  | transactionA.id); | 
|  | mFlinger.setTransactionState(transactionB.frameTimelineInfo, transactionB.states, | 
|  | transactionB.displays, transactionB.flags, | 
|  | transactionB.applyToken, transactionB.inputWindowCommands, | 
|  | transactionB.desiredPresentTime, transactionB.isAutoTimestamp, | 
|  | transactionB.uncacheBuffer, mHasListenerCallbacks, mCallbacks, | 
|  | transactionB.id); | 
|  |  | 
|  | mFlinger.flushTransactionQueues(); | 
|  | EXPECT_EQ(0u, mFlinger.getPendingTransactionQueue().size()); | 
|  | EXPECT_EQ(0u, mFlinger.getTransactionQueue().size()); | 
|  | EXPECT_EQ(2ul, mFlinger.getTransactionCommittedSignals().size()); | 
|  | } | 
|  |  | 
|  | static Vector<ComposerState> createComposerStateVector(const ComposerState& state1, | 
|  | const ComposerState& state2) { | 
|  | Vector<ComposerState> states; | 
|  | states.push_back(state1); | 
|  | states.push_back(state2); | 
|  | return states; | 
|  | } | 
|  |  | 
|  | static Vector<ComposerState> createComposerStateVector(const ComposerState& state) { | 
|  | Vector<ComposerState> states; | 
|  | states.push_back(state); | 
|  | return states; | 
|  | } | 
|  |  | 
|  | static ComposerState createComposerState(int layerId, sp<Fence> fence, | 
|  | uint32_t stateFlags = layer_state_t::eBufferChanged) { | 
|  | ComposerState composer_state; | 
|  | composer_state.state.bufferData = std::make_shared<BufferData>(); | 
|  | composer_state.state.bufferData->acquireFence = std::move(fence); | 
|  | composer_state.state.layerId = layerId; | 
|  | composer_state.state.bufferData->flags = BufferData::BufferDataChange::fenceChanged; | 
|  | composer_state.state.flags = stateFlags; | 
|  | return composer_state; | 
|  | } | 
|  |  | 
|  | bool mHasListenerCallbacks = false; | 
|  | std::vector<ListenerCallbacks> mCallbacks; | 
|  | int mTransactionNumber = 0; | 
|  | }; | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_RemovesFromQueue) { | 
|  | ASSERT_EQ(0u, mFlinger.getTransactionQueue().size()); | 
|  | EXPECT_CALL(*mFlinger.scheduler(), scheduleFrame()).Times(1); | 
|  |  | 
|  | TransactionInfo transactionA; // transaction to go on pending queue | 
|  | setupSingle(transactionA, /*flags*/ 0, /*syncInputWindows*/ false, | 
|  | /*desiredPresentTime*/ s2ns(1), false, FrameTimelineInfo{}); | 
|  | mFlinger.setTransactionState(transactionA.frameTimelineInfo, transactionA.states, | 
|  | transactionA.displays, transactionA.flags, transactionA.applyToken, | 
|  | transactionA.inputWindowCommands, transactionA.desiredPresentTime, | 
|  | transactionA.isAutoTimestamp, transactionA.uncacheBuffer, | 
|  | mHasListenerCallbacks, mCallbacks, transactionA.id); | 
|  |  | 
|  | auto& transactionQueue = mFlinger.getTransactionQueue(); | 
|  | ASSERT_EQ(1u, transactionQueue.size()); | 
|  |  | 
|  | auto& transactionState = transactionQueue.front(); | 
|  | checkEqual(transactionA, transactionState); | 
|  |  | 
|  | // because flushing uses the cached expected present time, we send an empty | 
|  | // transaction here (sending a null applyToken to fake it as from a | 
|  | // different process) to re-query and reset the cached expected present time | 
|  | TransactionInfo empty; | 
|  | empty.applyToken = sp<IBinder>(); | 
|  | mFlinger.setTransactionState(empty.frameTimelineInfo, empty.states, empty.displays, empty.flags, | 
|  | empty.applyToken, empty.inputWindowCommands, | 
|  | empty.desiredPresentTime, empty.isAutoTimestamp, | 
|  | empty.uncacheBuffer, mHasListenerCallbacks, mCallbacks, empty.id); | 
|  |  | 
|  | // flush transaction queue should flush as desiredPresentTime has | 
|  | // passed | 
|  | mFlinger.flushTransactionQueues(); | 
|  |  | 
|  | EXPECT_EQ(0u, transactionQueue.size()); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, NotPlacedOnTransactionQueue_Synchronous) { | 
|  | NotPlacedOnTransactionQueue(ISurfaceComposer::eSynchronous, /*syncInputWindows*/ false); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, NotPlacedOnTransactionQueue_Animation) { | 
|  | NotPlacedOnTransactionQueue(ISurfaceComposer::eAnimation, /*syncInputWindows*/ false); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, NotPlacedOnTransactionQueue_SyncInputWindows) { | 
|  | NotPlacedOnTransactionQueue(/*flags*/ 0, /*syncInputWindows*/ true); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, PlaceOnTransactionQueue_Synchronous) { | 
|  | PlaceOnTransactionQueue(ISurfaceComposer::eSynchronous, /*syncInputWindows*/ false); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, PlaceOnTransactionQueue_Animation) { | 
|  | PlaceOnTransactionQueue(ISurfaceComposer::eAnimation, /*syncInputWindows*/ false); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, PlaceOnTransactionQueue_SyncInputWindows) { | 
|  | PlaceOnTransactionQueue(/*flags*/ 0, /*syncInputWindows*/ true); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, BlockWithPriorTransaction_Synchronous) { | 
|  | BlockedByPriorTransaction(ISurfaceComposer::eSynchronous, /*syncInputWindows*/ false); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, BlockWithPriorTransaction_Animation) { | 
|  | BlockedByPriorTransaction(ISurfaceComposer::eSynchronous, /*syncInputWindows*/ false); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, BlockWithPriorTransaction_SyncInputWindows) { | 
|  | BlockedByPriorTransaction(/*flags*/ 0, /*syncInputWindows*/ true); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, FromHandle) { | 
|  | sp<IBinder> badHandle; | 
|  | auto ret = mFlinger.fromHandle(badHandle); | 
|  | EXPECT_EQ(nullptr, ret.promote().get()); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_RemovesSingleSignaledFromTheQueue_LatchUnsignaled_Auto) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Auto; | 
|  | Flush_removesFromTheQueue( | 
|  | createComposerStateVector(createComposerState(/*layerId*/ 1, mFenceSignaled))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_RemovesSingleUnSignaledFromTheQueue_LatchUnsignaled_Auto) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Auto; | 
|  | Flush_removesFromTheQueue( | 
|  | createComposerStateVector(createComposerState(/*layerId*/ 1, mFenceUnsignaled))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, | 
|  | Flush_KeepsUnSignaledInTheQueue_NonBufferCropChange_LatchUnsignaled_Auto) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Auto; | 
|  | Flush_keepsInTheQueue(createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 1, mFenceUnsignaled, layer_state_t::eCropChanged))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, | 
|  | Flush_KeepsUnSignaledInTheQueue_NonBufferChangeClubed_LatchUnsignaled_Auto) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Auto; | 
|  | Flush_keepsInTheQueue(createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 1, mFenceUnsignaled, | 
|  | layer_state_t::eCropChanged | layer_state_t::eBufferChanged))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, | 
|  | Flush_KeepsInTheQueueSameApplyTokenMultiState_LatchUnsignaled_Auto) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Auto; | 
|  | Flush_keepsInTheQueue( | 
|  | createComposerStateVector(createComposerState(/*layerId*/ 1, mFenceUnsignaled), | 
|  | createComposerState(/*layerId*/ 1, mFenceSignaled))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_KeepsInTheQueue_MultipleStateTransaction_Auto) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Auto; | 
|  | Flush_keepsInTheQueue( | 
|  | createComposerStateVector(createComposerState(/*layerId*/ 1, mFenceUnsignaled), | 
|  | createComposerState(/*layerId*/ 2, mFenceSignaled))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_RemovesSignaledFromTheQueue_LatchUnsignaled_Auto) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Auto; | 
|  | Flush_removesSignaledFromTheQueue(createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 1, mFenceSignaled)), | 
|  | createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 2, mFenceSignaled2))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_RemoveSignaledWithUnsignaledIntact_LatchUnsignaled_Auto) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Auto; | 
|  | Flush_KeepsUnsignaledInTheQueue(createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 1, mFenceSignaled)), | 
|  | createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 2, mFenceUnsignaled))); | 
|  | EXPECT_EQ(1ul, mFlinger.getTransactionCommittedSignals().size()); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, | 
|  | Flush_KeepsTransactionInTheQueueSameApplyToken_LatchUnsignaled_Auto) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Auto; | 
|  | Flush_KeepsUnsignaledInTheQueue(createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 1, mFenceUnsignaled)), | 
|  | createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 2, mFenceSignaled)), | 
|  | /*updateApplyToken*/ false); | 
|  | EXPECT_EQ(1ul, mFlinger.getTransactionCommittedSignals().size()); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_KeepsTransactionInTheQueue_LatchUnsignaled_Auto) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Auto; | 
|  | Flush_KeepsUnsignaledInTheQueue(createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 1, mFenceUnsignaled)), | 
|  | createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 2, mFenceUnsignaled)), | 
|  | /*updateApplyToken*/ true, | 
|  | /*pendingTransactionQueueSize*/ 2u); | 
|  | EXPECT_EQ(0ul, mFlinger.getTransactionCommittedSignals().size()); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_RemovesSignaledFromTheQueue_LatchUnsignaled_Disabled) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Disabled; | 
|  | Flush_removesFromTheQueue( | 
|  | createComposerStateVector(createComposerState(/*layerId*/ 1, mFenceSignaled))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_KeepsInTheQueue_LatchUnsignaled_Disabled) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Disabled; | 
|  | Flush_keepsInTheQueue( | 
|  | createComposerStateVector(createComposerState(/*layerId*/ 1, mFenceUnsignaled))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_KeepsInTheQueueSameLayerId_LatchUnsignaled_Disabled) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Disabled; | 
|  | Flush_keepsInTheQueue( | 
|  | createComposerStateVector(createComposerState(/*layerId*/ 1, mFenceUnsignaled), | 
|  | createComposerState(/*layerId*/ 1, mFenceUnsignaled))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_KeepsInTheQueueDifferentLayerId_LatchUnsignaled_Disabled) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Disabled; | 
|  | Flush_keepsInTheQueue( | 
|  | createComposerStateVector(createComposerState(/*layerId*/ 1, mFenceUnsignaled), | 
|  | createComposerState(/*layerId*/ 2, mFenceUnsignaled))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_RemovesSignaledFromTheQueue_LatchUnSignaled_Disabled) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Disabled; | 
|  | Flush_removesSignaledFromTheQueue(createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 1, mFenceSignaled)), | 
|  | createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 2, mFenceSignaled2))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, | 
|  | Flush_KeepInTheQueueDifferentApplyToken_LatchUnsignaled_Disabled) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Disabled; | 
|  | Flush_KeepsUnsignaledInTheQueue(createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 1, mFenceUnsignaled)), | 
|  | createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 2, mFenceSignaled))); | 
|  | EXPECT_EQ(1ul, mFlinger.getTransactionCommittedSignals().size()); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_KeepInTheQueueSameApplyToken_LatchUnsignaled_Disabled) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Disabled; | 
|  | Flush_KeepsUnsignaledInTheQueue(createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 1, mFenceSignaled)), | 
|  | createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 2, mFenceUnsignaled)), | 
|  | /*updateApplyToken*/ false); | 
|  | EXPECT_EQ(1ul, mFlinger.getTransactionCommittedSignals().size()); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_KeepInTheUnsignaledTheQueue_LatchUnsignaled_Disabled) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Disabled; | 
|  | Flush_KeepsUnsignaledInTheQueue(createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 1, mFenceUnsignaled)), | 
|  | createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 2, mFenceUnsignaled)), | 
|  | /*updateApplyToken*/ false); | 
|  | EXPECT_EQ(0ul, mFlinger.getTransactionCommittedSignals().size()); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_RemovesSignaledFromTheQueue_LatchUnsignaled_Always) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Always; | 
|  | Flush_removesFromTheQueue( | 
|  | createComposerStateVector(createComposerState(/*layerId*/ 1, mFenceSignaled))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_RemovesFromTheQueue_LatchUnsignaled_Always) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Always; | 
|  | Flush_removesFromTheQueue( | 
|  | createComposerStateVector(createComposerState(/*layerId*/ 1, mFenceUnsignaled))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_RemovesFromTheQueueSameLayerId_LatchUnsignaled_Always) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Always; | 
|  | Flush_removesFromTheQueue( | 
|  | createComposerStateVector(createComposerState(/*layerId*/ 1, mFenceUnsignaled), | 
|  | createComposerState(/*layerId*/ 1, mFenceSignaled))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, | 
|  | Flush_RemovesFromTheQueueDifferentLayerId_LatchUnsignaled_Always) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Always; | 
|  | Flush_removesFromTheQueue( | 
|  | createComposerStateVector(createComposerState(/*layerId*/ 1, mFenceUnsignaled), | 
|  | createComposerState(/*layerId*/ 2, mFenceSignaled))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_RemovesSignaledFromTheQueue_LatchUnSignaled_Always) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Always; | 
|  | Flush_removesSignaledFromTheQueue(createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 1, mFenceSignaled)), | 
|  | createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 2, mFenceSignaled2))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, | 
|  | Flush_RemovesFromTheQueueDifferentApplyToken_LatchUnsignaled_Always) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Always; | 
|  | Flush_removesUnsignaledFromTheQueue(createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 1, mFenceSignaled)), | 
|  | createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 2, | 
|  | mFenceUnsignaled))); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, | 
|  | Flush_RemovesUnsignaledFromTheQueueSameApplyToken_LatchUnsignaled_Always) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Always; | 
|  | Flush_removesUnsignaledFromTheQueue(createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 1, | 
|  | mFenceUnsignaled)), | 
|  | createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 2, mFenceSignaled)), | 
|  | /*updateApplyToken*/ false); | 
|  | } | 
|  |  | 
|  | TEST_F(TransactionApplicationTest, Flush_RemovesUnsignaledFromTheQueue_LatchUnsignaled_Always) { | 
|  | SurfaceFlinger::enableLatchUnsignaledConfig = LatchUnsignaledConfig::Always; | 
|  | Flush_removesUnsignaledFromTheQueue(createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 1, | 
|  | mFenceUnsignaled)), | 
|  | createComposerStateVector( | 
|  | createComposerState(/*layerId*/ 2, | 
|  | mFenceUnsignaled))); | 
|  | } | 
|  |  | 
|  | } // namespace android |