blob: 97ad212b480ef389f77ea9f7f8c82aebe68213a5 [file] [log] [blame]
Marissa Wallfd668622018-05-10 10:21:13 -07001/*
2 * Copyright (C) 2018 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
Ady Abrahamb0dbdaa2020-01-06 16:19:42 -080017// TODO(b/129481165): remove the #pragma below and fix conversion issues
18#pragma clang diagnostic push
19#pragma clang diagnostic ignored "-Wconversion"
20
Alec Mouri485e4c32019-04-30 18:24:05 -070021#undef LOG_TAG
22#define LOG_TAG "BufferQueueLayer"
23#define ATRACE_TAG ATRACE_TAG_GRAPHICS
Lloyd Pique9755fb72019-03-26 14:44:40 -070024#include "BufferQueueLayer.h"
25
Lloyd Pique9755fb72019-03-26 14:44:40 -070026#include <compositionengine/LayerFECompositionState.h>
Ady Abrahamcd1580c2019-04-29 15:40:03 -070027#include <gui/BufferQueueConsumer.h>
Lloyd Pique37c2c9b2018-12-04 17:25:10 -080028#include <system/window.h>
29
Marissa Wallfd668622018-05-10 10:21:13 -070030#include "LayerRejecter.h"
Dominik Laskowski9dab3432019-03-27 13:21:10 -070031#include "SurfaceInterceptor.h"
Marissa Wallfd668622018-05-10 10:21:13 -070032
Mikael Pessa90092f42019-08-26 17:22:04 -070033#include "FrameTracer/FrameTracer.h"
Ady Abraham5def7332020-05-29 16:13:47 -070034#include "Scheduler/LayerHistory.h"
Yiwei Zhang7e666a52018-11-15 13:33:42 -080035#include "TimeStats/TimeStats.h"
36
Marissa Wallfd668622018-05-10 10:21:13 -070037namespace android {
38
Lloyd Pique42ab75e2018-09-12 20:46:03 -070039BufferQueueLayer::BufferQueueLayer(const LayerCreationArgs& args) : BufferLayer(args) {}
40
Robert Carr2e102c92018-10-23 12:11:15 -070041BufferQueueLayer::~BufferQueueLayer() {
chaviw2d9a4292019-12-02 16:00:24 -080042 mContentsChangedListener->abandon();
Robert Carr2e102c92018-10-23 12:11:15 -070043 mConsumer->abandon();
44}
Marissa Wallfd668622018-05-10 10:21:13 -070045
46// -----------------------------------------------------------------------
47// Interface implementation for Layer
48// -----------------------------------------------------------------------
49
50void BufferQueueLayer::onLayerDisplayed(const sp<Fence>& releaseFence) {
51 mConsumer->setReleaseFence(releaseFence);
Mikael Pessa2e1608f2019-07-19 11:25:35 -070052
53 // Prevent tracing the same release multiple times.
54 if (mPreviousFrameNumber != mPreviousReleasedFrameNumber) {
Mikael Pessa90092f42019-08-26 17:22:04 -070055 mFlinger->mFrameTracer->traceFence(getSequence(), mPreviousBufferId, mPreviousFrameNumber,
56 std::make_shared<FenceTime>(releaseFence),
57 FrameTracer::FrameEvent::RELEASE_FENCE);
Mikael Pessa2e1608f2019-07-19 11:25:35 -070058 mPreviousReleasedFrameNumber = mPreviousFrameNumber;
59 }
Marissa Wallfd668622018-05-10 10:21:13 -070060}
61
Dominik Laskowskib7251f42020-04-20 17:42:59 -070062void BufferQueueLayer::setTransformHint(ui::Transform::RotationFlags displayTransformHint) {
Vishnu Nair6213bd92020-05-08 17:42:25 -070063 BufferLayer::setTransformHint(displayTransformHint);
64 mConsumer->setTransformHint(mTransformHint);
Marissa Wallfd668622018-05-10 10:21:13 -070065}
66
67std::vector<OccupancyTracker::Segment> BufferQueueLayer::getOccupancyHistory(bool forceFlush) {
68 std::vector<OccupancyTracker::Segment> history;
69 status_t result = mConsumer->getOccupancyHistory(forceFlush, &history);
70 if (result != NO_ERROR) {
Dominik Laskowski87a07e42019-10-10 20:38:02 -070071 ALOGW("[%s] Failed to obtain occupancy history (%d)", getDebugName(), result);
Marissa Wallfd668622018-05-10 10:21:13 -070072 return {};
73 }
74 return history;
75}
76
Marissa Wallfd668622018-05-10 10:21:13 -070077void BufferQueueLayer::releasePendingBuffer(nsecs_t dequeueReadyTime) {
78 if (!mConsumer->releasePendingBuffer()) {
79 return;
80 }
81
82 auto releaseFenceTime = std::make_shared<FenceTime>(mConsumer->getPrevFinalReleaseFence());
83 mReleaseTimeline.updateSignalTimes();
84 mReleaseTimeline.push(releaseFenceTime);
85
86 Mutex::Autolock lock(mFrameEventHistoryMutex);
87 if (mPreviousFrameNumber != 0) {
88 mFrameEventHistory.addRelease(mPreviousFrameNumber, dequeueReadyTime,
89 std::move(releaseFenceTime));
90 }
91}
92
93void BufferQueueLayer::setDefaultBufferSize(uint32_t w, uint32_t h) {
94 mConsumer->setDefaultBufferSize(w, h);
95}
96
97int32_t BufferQueueLayer::getQueuedFrameCount() const {
98 return mQueuedFrames;
99}
100
Ana Krulec010d2192018-10-08 06:29:54 -0700101bool BufferQueueLayer::shouldPresentNow(nsecs_t expectedPresentTime) const {
Marissa Wallfd668622018-05-10 10:21:13 -0700102 if (getSidebandStreamChanged() || getAutoRefresh()) {
103 return true;
104 }
105
Marissa Wall024a1912018-08-13 13:55:35 -0700106 if (!hasFrameUpdate()) {
Marissa Wallfd668622018-05-10 10:21:13 -0700107 return false;
108 }
109
110 Mutex::Autolock lock(mQueueItemLock);
111
112 const int64_t addedTime = mQueueItems[0].mTimestamp;
Marissa Wallfd668622018-05-10 10:21:13 -0700113
114 // Ignore timestamps more than a second in the future
115 const bool isPlausible = addedTime < (expectedPresentTime + s2ns(1));
116 ALOGW_IF(!isPlausible,
117 "[%s] Timestamp %" PRId64 " seems implausible "
118 "relative to expectedPresent %" PRId64,
Dominik Laskowski87a07e42019-10-10 20:38:02 -0700119 getDebugName(), addedTime, expectedPresentTime);
Marissa Wallfd668622018-05-10 10:21:13 -0700120
Alec Mouri91f6df32020-01-30 08:48:58 -0800121 if (!isPlausible) {
122 mFlinger->mTimeStats->incrementBadDesiredPresent(getSequence());
123 }
124
Marissa Wallfd668622018-05-10 10:21:13 -0700125 const bool isDue = addedTime < expectedPresentTime;
126 return isDue || !isPlausible;
127}
128
129// -----------------------------------------------------------------------
130// Interface implementation for BufferLayer
131// -----------------------------------------------------------------------
132
133bool BufferQueueLayer::fenceHasSignaled() const {
Marissa Wall024a1912018-08-13 13:55:35 -0700134 if (!hasFrameUpdate()) {
Marissa Wallfd668622018-05-10 10:21:13 -0700135 return true;
136 }
137
138 Mutex::Autolock lock(mQueueItemLock);
139 if (mQueueItems[0].mIsDroppable) {
140 // Even though this buffer's fence may not have signaled yet, it could
141 // be replaced by another buffer before it has a chance to, which means
142 // that it's possible to get into a situation where a buffer is never
143 // able to be latched. To avoid this, grab this buffer anyway.
144 return true;
145 }
Alec Mouri91f6df32020-01-30 08:48:58 -0800146 const bool fenceSignaled =
147 mQueueItems[0].mFenceTime->getSignalTime() != Fence::SIGNAL_TIME_PENDING;
148 if (!fenceSignaled) {
149 mFlinger->mTimeStats->incrementLatchSkipped(getSequence(),
150 TimeStats::LatchSkipReason::LateAcquire);
151 }
152
153 return fenceSignaled;
Marissa Wallfd668622018-05-10 10:21:13 -0700154}
155
Dominik Laskowskia8955dd2019-07-10 10:19:09 -0700156bool BufferQueueLayer::framePresentTimeIsCurrent(nsecs_t expectedPresentTime) const {
Ady Abrahamcd1580c2019-04-29 15:40:03 -0700157 if (!hasFrameUpdate() || isRemovedFromCurrentState()) {
158 return true;
159 }
160
161 Mutex::Autolock lock(mQueueItemLock);
Dominik Laskowskia8955dd2019-07-10 10:19:09 -0700162 return mQueueItems[0].mTimestamp <= expectedPresentTime;
Ady Abrahamcd1580c2019-04-29 15:40:03 -0700163}
164
Dominik Laskowskia8955dd2019-07-10 10:19:09 -0700165uint64_t BufferQueueLayer::getFrameNumber(nsecs_t expectedPresentTime) const {
Marissa Wallfd668622018-05-10 10:21:13 -0700166 Mutex::Autolock lock(mQueueItemLock);
Ady Abrahamcd1580c2019-04-29 15:40:03 -0700167 uint64_t frameNumber = mQueueItems[0].mFrameNumber;
168
169 // The head of the queue will be dropped if there are signaled and timely frames behind it
Ady Abrahamcd1580c2019-04-29 15:40:03 -0700170 if (isRemovedFromCurrentState()) {
171 expectedPresentTime = 0;
172 }
173
174 for (int i = 1; i < mQueueItems.size(); i++) {
175 const bool fenceSignaled =
176 mQueueItems[i].mFenceTime->getSignalTime() != Fence::SIGNAL_TIME_PENDING;
177 if (!fenceSignaled) {
178 break;
179 }
180
181 // We don't drop frames without explicit timestamps
182 if (mQueueItems[i].mIsAutoTimestamp) {
183 break;
184 }
185
186 const nsecs_t desiredPresent = mQueueItems[i].mTimestamp;
187 if (desiredPresent < expectedPresentTime - BufferQueueConsumer::MAX_REASONABLE_NSEC ||
188 desiredPresent > expectedPresentTime) {
189 break;
190 }
191
192 frameNumber = mQueueItems[i].mFrameNumber;
193 }
194
195 return frameNumber;
Marissa Wallfd668622018-05-10 10:21:13 -0700196}
197
198bool BufferQueueLayer::getAutoRefresh() const {
199 return mAutoRefresh;
200}
201
202bool BufferQueueLayer::getSidebandStreamChanged() const {
203 return mSidebandStreamChanged;
204}
205
Vishnu Nair6194e2e2019-02-06 12:58:39 -0800206bool BufferQueueLayer::latchSidebandStream(bool& recomputeVisibleRegions) {
Marin Shalamanovd6280d62020-06-26 13:18:15 +0200207 // We need to update the sideband stream if the layer has both a buffer and a sideband stream.
Marin Shalamanov7cc3dd32020-06-23 12:40:24 +0200208 const bool updateSidebandStream = hasFrameUpdate() && mSidebandStream.get();
Marin Shalamanov7cc3dd32020-06-23 12:40:24 +0200209
Lloyd Piquef1c675b2018-09-12 20:45:39 -0700210 bool sidebandStreamChanged = true;
Marin Shalamanov7cc3dd32020-06-23 12:40:24 +0200211 if (mSidebandStreamChanged.compare_exchange_strong(sidebandStreamChanged, false) ||
212 updateSidebandStream) {
Lloyd Piquef1c675b2018-09-12 20:45:39 -0700213 // mSidebandStreamChanged was changed to false
Pierre Couillaudd66b6c22019-08-27 13:43:22 -0700214 mSidebandStream = mConsumer->getSidebandStream();
Lloyd Piquede196652020-01-22 17:29:58 -0800215 auto* layerCompositionState = editCompositionState();
216 layerCompositionState->sidebandStream = mSidebandStream;
217 if (layerCompositionState->sidebandStream != nullptr) {
Marissa Wallfd668622018-05-10 10:21:13 -0700218 setTransactionFlags(eTransactionNeeded);
219 mFlinger->setTransactionFlags(eTraversalNeeded);
220 }
Ady Abraham83729882018-12-07 12:26:48 -0800221 recomputeVisibleRegions = true;
Lloyd Pique0449b0f2018-12-20 16:23:45 -0800222
Vishnu Nair6194e2e2019-02-06 12:58:39 -0800223 return true;
Marissa Wallfd668622018-05-10 10:21:13 -0700224 }
Vishnu Nair6194e2e2019-02-06 12:58:39 -0800225 return false;
Marissa Wallfd668622018-05-10 10:21:13 -0700226}
227
Lloyd Pique0449b0f2018-12-20 16:23:45 -0800228bool BufferQueueLayer::hasFrameUpdate() const {
Marissa Wallfd668622018-05-10 10:21:13 -0700229 return mQueuedFrames > 0;
230}
231
Dominik Laskowskia8955dd2019-07-10 10:19:09 -0700232status_t BufferQueueLayer::updateTexImage(bool& recomputeVisibleRegions, nsecs_t latchTime,
233 nsecs_t expectedPresentTime) {
Marissa Wallfd668622018-05-10 10:21:13 -0700234 // This boolean is used to make sure that SurfaceFlinger's shadow copy
235 // of the buffer queue isn't modified when the buffer queue is returning
236 // BufferItem's that weren't actually queued. This can happen in shared
237 // buffer mode.
238 bool queuedBuffer = false;
Yiwei Zhang1a88c402019-11-18 10:43:58 -0800239 const int32_t layerId = getSequence();
Lloyd Pique0449b0f2018-12-20 16:23:45 -0800240 LayerRejecter r(mDrawingState, getCurrentState(), recomputeVisibleRegions,
Dominik Laskowski87a07e42019-10-10 20:38:02 -0700241 getProducerStickyTransform() != 0, mName, mOverrideScalingMode,
chaviw214c89d2019-09-04 16:03:53 -0700242 getTransformToDisplayInverse());
Ana Krulece588e312018-09-18 12:32:24 -0700243
Robert Carra0629232019-02-07 15:28:54 -0800244 if (isRemovedFromCurrentState()) {
245 expectedPresentTime = 0;
246 }
247
Ady Abrahamfe95fd72018-12-17 17:58:51 -0800248 // updateTexImage() below might drop the some buffers at the head of the queue if there is a
249 // buffer behind them which is timely to be presented. However this buffer may not be signaled
250 // yet. The code below makes sure that this wouldn't happen by setting maxFrameNumber to the
251 // last buffer that was signaled.
252 uint64_t lastSignaledFrameNumber = mLastFrameNumberReceived;
253 {
254 Mutex::Autolock lock(mQueueItemLock);
255 for (int i = 0; i < mQueueItems.size(); i++) {
256 bool fenceSignaled =
257 mQueueItems[i].mFenceTime->getSignalTime() != Fence::SIGNAL_TIME_PENDING;
258 if (!fenceSignaled) {
259 break;
260 }
261 lastSignaledFrameNumber = mQueueItems[i].mFrameNumber;
262 }
263 }
264 const uint64_t maxFrameNumberToAcquire =
265 std::min(mLastFrameNumberReceived.load(), lastSignaledFrameNumber);
Robert Carra0629232019-02-07 15:28:54 -0800266
Alec Mouri56e538f2019-01-14 15:22:01 -0800267 status_t updateResult = mConsumer->updateTexImage(&r, expectedPresentTime, &mAutoRefresh,
268 &queuedBuffer, maxFrameNumberToAcquire);
Marissa Wallfd668622018-05-10 10:21:13 -0700269 if (updateResult == BufferQueue::PRESENT_LATER) {
270 // Producer doesn't want buffer to be displayed yet. Signal a
271 // layer update so we check again at the next opportunity.
272 mFlinger->signalLayerUpdate();
273 return BAD_VALUE;
274 } else if (updateResult == BufferLayerConsumer::BUFFER_REJECTED) {
275 // If the buffer has been rejected, remove it from the shadow queue
276 // and return early
277 if (queuedBuffer) {
278 Mutex::Autolock lock(mQueueItemLock);
Steven Thomas44685cb2019-07-23 16:19:31 -0700279 mConsumer->mergeSurfaceDamage(mQueueItems[0].mSurfaceDamage);
Yiwei Zhang1a88c402019-11-18 10:43:58 -0800280 mFlinger->mTimeStats->removeTimeRecord(layerId, mQueueItems[0].mFrameNumber);
Marissa Wallfd668622018-05-10 10:21:13 -0700281 mQueueItems.removeAt(0);
Lloyd Piquef1c675b2018-09-12 20:45:39 -0700282 mQueuedFrames--;
Marissa Wallfd668622018-05-10 10:21:13 -0700283 }
284 return BAD_VALUE;
285 } else if (updateResult != NO_ERROR || mUpdateTexImageFailed) {
286 // This can occur if something goes wrong when trying to create the
287 // EGLImage for this buffer. If this happens, the buffer has already
288 // been released, so we need to clean up the queue and bug out
289 // early.
290 if (queuedBuffer) {
291 Mutex::Autolock lock(mQueueItemLock);
292 mQueueItems.clear();
Lloyd Piquef1c675b2018-09-12 20:45:39 -0700293 mQueuedFrames = 0;
Yiwei Zhang1a88c402019-11-18 10:43:58 -0800294 mFlinger->mTimeStats->onDestroy(layerId);
295 mFlinger->mFrameTracer->onDestroy(layerId);
Marissa Wallfd668622018-05-10 10:21:13 -0700296 }
297
298 // Once we have hit this state, the shadow queue may no longer
299 // correctly reflect the incoming BufferQueue's contents, so even if
300 // updateTexImage starts working, the only safe course of action is
301 // to continue to ignore updates.
302 mUpdateTexImageFailed = true;
303
304 return BAD_VALUE;
305 }
306
307 if (queuedBuffer) {
308 // Autolock scope
309 auto currentFrameNumber = mConsumer->getFrameNumber();
310
311 Mutex::Autolock lock(mQueueItemLock);
312
313 // Remove any stale buffers that have been dropped during
314 // updateTexImage
315 while (mQueueItems[0].mFrameNumber != currentFrameNumber) {
Steven Thomas44685cb2019-07-23 16:19:31 -0700316 mConsumer->mergeSurfaceDamage(mQueueItems[0].mSurfaceDamage);
Yiwei Zhang1a88c402019-11-18 10:43:58 -0800317 mFlinger->mTimeStats->removeTimeRecord(layerId, mQueueItems[0].mFrameNumber);
Marissa Wallfd668622018-05-10 10:21:13 -0700318 mQueueItems.removeAt(0);
Lloyd Piquef1c675b2018-09-12 20:45:39 -0700319 mQueuedFrames--;
Marissa Wallfd668622018-05-10 10:21:13 -0700320 }
321
Mikael Pessa2e1608f2019-07-19 11:25:35 -0700322 uint64_t bufferID = mQueueItems[0].mGraphicBuffer->getId();
Yiwei Zhang1a88c402019-11-18 10:43:58 -0800323 mFlinger->mTimeStats->setLatchTime(layerId, currentFrameNumber, latchTime);
324 mFlinger->mFrameTracer->traceTimestamp(layerId, bufferID, currentFrameNumber, latchTime,
Mikael Pessa90092f42019-08-26 17:22:04 -0700325 FrameTracer::FrameEvent::LATCH);
Marissa Wallfd668622018-05-10 10:21:13 -0700326
327 mQueueItems.removeAt(0);
328 }
329
330 // Decrement the queued-frames count. Signal another event if we
331 // have more frames pending.
Lloyd Piquef1c675b2018-09-12 20:45:39 -0700332 if ((queuedBuffer && mQueuedFrames.fetch_sub(1) > 1) || mAutoRefresh) {
Marissa Wallfd668622018-05-10 10:21:13 -0700333 mFlinger->signalLayerUpdate();
334 }
335
336 return NO_ERROR;
337}
338
339status_t BufferQueueLayer::updateActiveBuffer() {
340 // update the active buffer
Mikael Pessa2e1608f2019-07-19 11:25:35 -0700341 mPreviousBufferId = getCurrentBufferId();
chaviwd62d3062019-09-04 14:48:02 -0700342 mBufferInfo.mBuffer =
343 mConsumer->getCurrentBuffer(&mBufferInfo.mBufferSlot, &mBufferInfo.mFence);
Marissa Wallfd668622018-05-10 10:21:13 -0700344
chaviwd62d3062019-09-04 14:48:02 -0700345 if (mBufferInfo.mBuffer == nullptr) {
Marissa Wallfd668622018-05-10 10:21:13 -0700346 // this can only happen if the very first buffer was rejected.
347 return BAD_VALUE;
348 }
349 return NO_ERROR;
350}
351
352status_t BufferQueueLayer::updateFrameNumber(nsecs_t latchTime) {
353 mPreviousFrameNumber = mCurrentFrameNumber;
354 mCurrentFrameNumber = mConsumer->getFrameNumber();
355
356 {
357 Mutex::Autolock lock(mFrameEventHistoryMutex);
358 mFrameEventHistory.addLatch(mCurrentFrameNumber, latchTime);
359 }
360 return NO_ERROR;
361}
362
Marissa Wallfd668622018-05-10 10:21:13 -0700363// -----------------------------------------------------------------------
364// Interface implementation for BufferLayerConsumer::ContentsChangedListener
365// -----------------------------------------------------------------------
366
Adithya Srinivasan2e434382019-10-09 11:43:01 -0700367void BufferQueueLayer::onFrameDequeued(const uint64_t bufferId) {
Yiwei Zhang1a88c402019-11-18 10:43:58 -0800368 const int32_t layerId = getSequence();
369 mFlinger->mFrameTracer->traceNewLayer(layerId, getName().c_str());
370 mFlinger->mFrameTracer->traceTimestamp(layerId, bufferId, FrameTracer::UNSPECIFIED_FRAME_NUMBER,
Adithya Srinivasan7dbf76d2019-10-25 18:17:11 -0700371 systemTime(), FrameTracer::FrameEvent::DEQUEUE);
372}
373
374void BufferQueueLayer::onFrameDetached(const uint64_t bufferId) {
Yiwei Zhang1a88c402019-11-18 10:43:58 -0800375 const int32_t layerId = getSequence();
376 mFlinger->mFrameTracer->traceNewLayer(layerId, getName().c_str());
377 mFlinger->mFrameTracer->traceTimestamp(layerId, bufferId, FrameTracer::UNSPECIFIED_FRAME_NUMBER,
Adithya Srinivasan7dbf76d2019-10-25 18:17:11 -0700378 systemTime(), FrameTracer::FrameEvent::DETACH);
379}
380
381void BufferQueueLayer::onFrameCancelled(const uint64_t bufferId) {
Yiwei Zhang1a88c402019-11-18 10:43:58 -0800382 const int32_t layerId = getSequence();
383 mFlinger->mFrameTracer->traceTimestamp(layerId, bufferId, FrameTracer::UNSPECIFIED_FRAME_NUMBER,
Adithya Srinivasan7dbf76d2019-10-25 18:17:11 -0700384 systemTime(), FrameTracer::FrameEvent::CANCEL);
Adithya Srinivasan2e434382019-10-09 11:43:01 -0700385}
386
Marissa Wallfd668622018-05-10 10:21:13 -0700387void BufferQueueLayer::onFrameAvailable(const BufferItem& item) {
Yiwei Zhang1a88c402019-11-18 10:43:58 -0800388 const int32_t layerId = getSequence();
Adithya Srinivasanf1e87ab2020-06-19 14:57:06 -0700389 const uint64_t bufferId = item.mGraphicBuffer->getId();
390 mFlinger->mFrameTracer->traceTimestamp(layerId, bufferId, item.mFrameNumber, systemTime(),
391 FrameTracer::FrameEvent::QUEUE);
392 mFlinger->mFrameTracer->traceFence(layerId, bufferId, item.mFrameNumber,
393 std::make_shared<FenceTime>(item.mFence),
394 FrameTracer::FrameEvent::ACQUIRE_FENCE);
Mikael Pessa2e1608f2019-07-19 11:25:35 -0700395
Alec Mouri485e4c32019-04-30 18:24:05 -0700396 ATRACE_CALL();
Marissa Wallfd668622018-05-10 10:21:13 -0700397 // Add this buffer from our internal queue tracker
398 { // Autolock scope
Dominik Laskowski49cea512019-11-12 14:13:23 -0800399 const nsecs_t presentTime = item.mIsAutoTimestamp ? 0 : item.mTimestamp;
Ady Abraham5def7332020-05-29 16:13:47 -0700400 mFlinger->mScheduler->recordLayerHistory(this, presentTime,
401 LayerHistory::LayerUpdateType::Buffer);
Ana Krulec7ab56032018-11-02 20:51:06 +0100402
Marissa Wallfd668622018-05-10 10:21:13 -0700403 Mutex::Autolock lock(mQueueItemLock);
404 // Reset the frame number tracker when we receive the first buffer after
405 // a frame number reset
406 if (item.mFrameNumber == 1) {
407 mLastFrameNumberReceived = 0;
408 }
409
410 // Ensure that callbacks are handled in order
411 while (item.mFrameNumber != mLastFrameNumberReceived + 1) {
412 status_t result = mQueueItemCondition.waitRelative(mQueueItemLock, ms2ns(500));
413 if (result != NO_ERROR) {
Dominik Laskowski87a07e42019-10-10 20:38:02 -0700414 ALOGE("[%s] Timed out waiting on callback", getDebugName());
Marissa Wall6a3e6712020-02-07 09:45:47 -0800415 break;
Marissa Wallfd668622018-05-10 10:21:13 -0700416 }
417 }
418
419 mQueueItems.push_back(item);
Lloyd Piquef1c675b2018-09-12 20:45:39 -0700420 mQueuedFrames++;
Marissa Wallfd668622018-05-10 10:21:13 -0700421
422 // Wake up any pending callbacks
423 mLastFrameNumberReceived = item.mFrameNumber;
424 mQueueItemCondition.broadcast();
425 }
426
Rob Carra79435b2020-03-06 14:46:07 -0800427 mFlinger->mInterceptor->saveBufferUpdate(layerId, item.mGraphicBuffer->getWidth(),
Marissa Wallfd668622018-05-10 10:21:13 -0700428 item.mGraphicBuffer->getHeight(), item.mFrameNumber);
Ana Krulec3084c052018-11-21 20:27:17 +0100429
chaviw49a108c2019-08-12 11:23:06 -0700430 mFlinger->signalLayerUpdate();
Alec Mouri485e4c32019-04-30 18:24:05 -0700431 mConsumer->onBufferAvailable(item);
Marissa Wallfd668622018-05-10 10:21:13 -0700432}
433
434void BufferQueueLayer::onFrameReplaced(const BufferItem& item) {
Alec Mouri485e4c32019-04-30 18:24:05 -0700435 ATRACE_CALL();
Marissa Wallfd668622018-05-10 10:21:13 -0700436 { // Autolock scope
437 Mutex::Autolock lock(mQueueItemLock);
438
439 // Ensure that callbacks are handled in order
440 while (item.mFrameNumber != mLastFrameNumberReceived + 1) {
441 status_t result = mQueueItemCondition.waitRelative(mQueueItemLock, ms2ns(500));
442 if (result != NO_ERROR) {
Dominik Laskowski87a07e42019-10-10 20:38:02 -0700443 ALOGE("[%s] Timed out waiting on callback", getDebugName());
Marissa Wall6a3e6712020-02-07 09:45:47 -0800444 break;
Marissa Wallfd668622018-05-10 10:21:13 -0700445 }
446 }
447
Marissa Wall024a1912018-08-13 13:55:35 -0700448 if (!hasFrameUpdate()) {
Marissa Wallfd668622018-05-10 10:21:13 -0700449 ALOGE("Can't replace a frame on an empty queue");
450 return;
451 }
452 mQueueItems.editItemAt(mQueueItems.size() - 1) = item;
453
454 // Wake up any pending callbacks
455 mLastFrameNumberReceived = item.mFrameNumber;
456 mQueueItemCondition.broadcast();
457 }
Adithya Srinivasanba45bae2019-12-30 12:39:11 -0800458
459 const int32_t layerId = getSequence();
Adithya Srinivasanf1e87ab2020-06-19 14:57:06 -0700460 const uint64_t bufferId = item.mGraphicBuffer->getId();
461 mFlinger->mFrameTracer->traceTimestamp(layerId, bufferId, item.mFrameNumber, systemTime(),
462 FrameTracer::FrameEvent::QUEUE);
463 mFlinger->mFrameTracer->traceFence(layerId, bufferId, item.mFrameNumber,
464 std::make_shared<FenceTime>(item.mFence),
465 FrameTracer::FrameEvent::ACQUIRE_FENCE);
Alec Mouri485e4c32019-04-30 18:24:05 -0700466 mConsumer->onBufferAvailable(item);
Marissa Wallfd668622018-05-10 10:21:13 -0700467}
468
469void BufferQueueLayer::onSidebandStreamChanged() {
Lloyd Piquef1c675b2018-09-12 20:45:39 -0700470 bool sidebandStreamChanged = false;
471 if (mSidebandStreamChanged.compare_exchange_strong(sidebandStreamChanged, true)) {
472 // mSidebandStreamChanged was changed to true
Marissa Wallfd668622018-05-10 10:21:13 -0700473 mFlinger->signalLayerUpdate();
474 }
475}
476
477// -----------------------------------------------------------------------
478
479void BufferQueueLayer::onFirstRef() {
Dan Stoza7b1b5a82018-07-31 16:00:21 -0700480 BufferLayer::onFirstRef();
481
Marissa Wallfd668622018-05-10 10:21:13 -0700482 // Creates a custom BufferQueue for SurfaceFlingerConsumer to use
483 sp<IGraphicBufferProducer> producer;
484 sp<IGraphicBufferConsumer> consumer;
Lloyd Piquee300b312019-10-03 13:03:45 -0700485 mFlinger->getFactory().createBufferQueue(&producer, &consumer, true);
486 mProducer = mFlinger->getFactory().createMonitoredProducer(producer, mFlinger, this);
487 mConsumer =
488 mFlinger->getFactory().createBufferLayerConsumer(consumer, mFlinger->getRenderEngine(),
489 mTextureName, this);
Marissa Wallfd668622018-05-10 10:21:13 -0700490 mConsumer->setConsumerUsageBits(getEffectiveUsage(0));
chaviw2d9a4292019-12-02 16:00:24 -0800491
492 mContentsChangedListener = new ContentsChangedListener(this);
493 mConsumer->setContentsChangedListener(mContentsChangedListener);
Dominik Laskowski87a07e42019-10-10 20:38:02 -0700494 mConsumer->setName(String8(mName.data(), mName.size()));
Marissa Wallfd668622018-05-10 10:21:13 -0700495
Yiwei Zhangb770ed32018-12-17 17:44:28 -0800496 // BufferQueueCore::mMaxDequeuedBufferCount is default to 1
497 if (!mFlinger->isLayerTripleBufferingDisabled()) {
Marissa Wallfd668622018-05-10 10:21:13 -0700498 mProducer->setMaxDequeuedBufferCount(2);
499 }
500}
501
502status_t BufferQueueLayer::setDefaultBufferProperties(uint32_t w, uint32_t h, PixelFormat format) {
503 uint32_t const maxSurfaceDims =
Peiyong Lin3db42342018-08-16 09:15:59 -0700504 std::min(mFlinger->getMaxTextureSize(), mFlinger->getMaxViewportDims());
Marissa Wallfd668622018-05-10 10:21:13 -0700505
506 // never allow a surface larger than what our underlying GL implementation
507 // can handle.
508 if ((uint32_t(w) > maxSurfaceDims) || (uint32_t(h) > maxSurfaceDims)) {
509 ALOGE("dimensions too large %u x %u", uint32_t(w), uint32_t(h));
510 return BAD_VALUE;
511 }
512
Marissa Wallfd668622018-05-10 10:21:13 -0700513 setDefaultBufferSize(w, h);
514 mConsumer->setDefaultBufferFormat(format);
515 mConsumer->setConsumerUsageBits(getEffectiveUsage(0));
516
517 return NO_ERROR;
518}
519
520sp<IGraphicBufferProducer> BufferQueueLayer::getProducer() const {
521 return mProducer;
522}
523
524uint32_t BufferQueueLayer::getProducerStickyTransform() const {
525 int producerStickyTransform = 0;
526 int ret = mProducer->query(NATIVE_WINDOW_STICKY_TRANSFORM, &producerStickyTransform);
527 if (ret != OK) {
528 ALOGW("%s: Error %s (%d) while querying window sticky transform.", __FUNCTION__,
529 strerror(-ret), ret);
530 return 0;
531 }
532 return static_cast<uint32_t>(producerStickyTransform);
533}
534
chaviw4244e032019-09-04 11:27:49 -0700535void BufferQueueLayer::gatherBufferInfo() {
chaviwdebadb82020-03-26 14:57:24 -0700536 BufferLayer::gatherBufferInfo();
537
chaviw4244e032019-09-04 11:27:49 -0700538 mBufferInfo.mDesiredPresentTime = mConsumer->getTimestamp();
539 mBufferInfo.mFenceTime = mConsumer->getCurrentFenceTime();
540 mBufferInfo.mFence = mConsumer->getCurrentFence();
chaviw4244e032019-09-04 11:27:49 -0700541 mBufferInfo.mTransform = mConsumer->getCurrentTransform();
542 mBufferInfo.mDataspace = translateDataspace(mConsumer->getCurrentDataSpace());
543 mBufferInfo.mCrop = mConsumer->getCurrentCrop();
544 mBufferInfo.mScaleMode = mConsumer->getCurrentScalingMode();
545 mBufferInfo.mSurfaceDamage = mConsumer->getSurfaceDamage();
546 mBufferInfo.mHdrMetadata = mConsumer->getCurrentHdrMetadata();
547 mBufferInfo.mApi = mConsumer->getCurrentApi();
chaviw4244e032019-09-04 11:27:49 -0700548 mBufferInfo.mTransformToDisplayInverse = mConsumer->getTransformToDisplayInverse();
549}
550
chaviwb4c6e582019-08-16 14:35:07 -0700551sp<Layer> BufferQueueLayer::createClone() {
Dominik Laskowski87a07e42019-10-10 20:38:02 -0700552 LayerCreationArgs args(mFlinger.get(), nullptr, mName + " (Mirror)", 0, 0, 0, LayerMetadata());
chaviwb4c6e582019-08-16 14:35:07 -0700553 args.textureName = mTextureName;
Lloyd Pique1c3a5eb2019-10-03 13:07:08 -0700554 sp<BufferQueueLayer> layer = mFlinger->getFactory().createBufferQueueLayer(args);
chaviwb4c6e582019-08-16 14:35:07 -0700555 layer->setInitialValuesForClone(this);
556
557 return layer;
558}
559
chaviw2d9a4292019-12-02 16:00:24 -0800560// -----------------------------------------------------------------------
561// Interface implementation for BufferLayerConsumer::ContentsChangedListener
562// -----------------------------------------------------------------------
563
564void BufferQueueLayer::ContentsChangedListener::onFrameAvailable(const BufferItem& item) {
565 Mutex::Autolock lock(mMutex);
566 if (mBufferQueueLayer != nullptr) {
567 mBufferQueueLayer->onFrameAvailable(item);
568 }
569}
570
571void BufferQueueLayer::ContentsChangedListener::onFrameReplaced(const BufferItem& item) {
572 Mutex::Autolock lock(mMutex);
573 if (mBufferQueueLayer != nullptr) {
574 mBufferQueueLayer->onFrameReplaced(item);
575 }
576}
577
578void BufferQueueLayer::ContentsChangedListener::onSidebandStreamChanged() {
579 Mutex::Autolock lock(mMutex);
580 if (mBufferQueueLayer != nullptr) {
581 mBufferQueueLayer->onSidebandStreamChanged();
582 }
583}
584
585void BufferQueueLayer::ContentsChangedListener::onFrameDequeued(const uint64_t bufferId) {
586 Mutex::Autolock lock(mMutex);
587 if (mBufferQueueLayer != nullptr) {
588 mBufferQueueLayer->onFrameDequeued(bufferId);
589 }
590}
591
592void BufferQueueLayer::ContentsChangedListener::onFrameDetached(const uint64_t bufferId) {
593 Mutex::Autolock lock(mMutex);
594 if (mBufferQueueLayer != nullptr) {
595 mBufferQueueLayer->onFrameDetached(bufferId);
596 }
597}
598
599void BufferQueueLayer::ContentsChangedListener::onFrameCancelled(const uint64_t bufferId) {
600 Mutex::Autolock lock(mMutex);
601 if (mBufferQueueLayer != nullptr) {
602 mBufferQueueLayer->onFrameCancelled(bufferId);
603 }
604}
605
606void BufferQueueLayer::ContentsChangedListener::abandon() {
607 Mutex::Autolock lock(mMutex);
608 mBufferQueueLayer = nullptr;
609}
610
611// -----------------------------------------------------------------------
612
Marissa Wallfd668622018-05-10 10:21:13 -0700613} // namespace android
Ady Abrahamb0dbdaa2020-01-06 16:19:42 -0800614
615// TODO(b/129481165): remove the #pragma below and fix conversion issues
616#pragma clang diagnostic pop // ignored "-Wconversion"