• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
2  * Copyright (C) 2017 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 
17 // TODO(b/129481165): remove the #pragma below and fix conversion issues
18 #pragma clang diagnostic push
19 #pragma clang diagnostic ignored "-Wconversion"
20 
21 //#define LOG_NDEBUG 0
22 #undef LOG_TAG
23 #define LOG_TAG "BufferStateLayer"
24 #define ATRACE_TAG ATRACE_TAG_GRAPHICS
25 
26 #include "BufferStateLayer.h"
27 
28 #include <limits>
29 
30 #include <compositionengine/LayerFECompositionState.h>
31 #include <gui/BufferQueue.h>
32 #include <private/gui/SyncFeatures.h>
33 #include <renderengine/Image.h>
34 
35 #include "EffectLayer.h"
36 #include "TimeStats/TimeStats.h"
37 
38 namespace android {
39 
40 // clang-format off
41 const std::array<float, 16> BufferStateLayer::IDENTITY_MATRIX{
42         1, 0, 0, 0,
43         0, 1, 0, 0,
44         0, 0, 1, 0,
45         0, 0, 0, 1
46 };
47 // clang-format on
48 
BufferStateLayer(const LayerCreationArgs & args)49 BufferStateLayer::BufferStateLayer(const LayerCreationArgs& args)
50       : BufferLayer(args), mHwcSlotGenerator(new HwcSlotGenerator()) {
51     mOverrideScalingMode = NATIVE_WINDOW_SCALING_MODE_SCALE_TO_WINDOW;
52     mCurrentState.dataspace = ui::Dataspace::V0_SRGB;
53 }
54 
~BufferStateLayer()55 BufferStateLayer::~BufferStateLayer() {
56     // The original layer and the clone layer share the same texture and buffer. Therefore, only
57     // one of the layers, in this case the original layer, needs to handle the deletion. The
58     // original layer and the clone should be removed at the same time so there shouldn't be any
59     // issue with the clone layer trying to use the texture.
60     if (mBufferInfo.mBuffer != nullptr && !isClone()) {
61         // Ensure that mBuffer is uncached from RenderEngine here, as
62         // RenderEngine may have been using the buffer as an external texture
63         // after the client uncached the buffer.
64         auto& engine(mFlinger->getRenderEngine());
65         engine.unbindExternalTextureBuffer(mBufferInfo.mBuffer->getId());
66     }
67 }
68 
69 // -----------------------------------------------------------------------
70 // Interface implementation for Layer
71 // -----------------------------------------------------------------------
onLayerDisplayed(const sp<Fence> & releaseFence)72 void BufferStateLayer::onLayerDisplayed(const sp<Fence>& releaseFence) {
73     // The previous release fence notifies the client that SurfaceFlinger is done with the previous
74     // buffer that was presented on this layer. The first transaction that came in this frame that
75     // replaced the previous buffer on this layer needs this release fence, because the fence will
76     // let the client know when that previous buffer is removed from the screen.
77     //
78     // Every other transaction on this layer does not need a release fence because no other
79     // Transactions that were set on this layer this frame are going to have their preceeding buffer
80     // removed from the display this frame.
81     //
82     // For example, if we have 3 transactions this frame. The first transaction doesn't contain a
83     // buffer so it doesn't need a previous release fence because the layer still needs the previous
84     // buffer. The second transaction contains a buffer so it needs a previous release fence because
85     // the previous buffer will be released this frame. The third transaction also contains a
86     // buffer. It replaces the buffer in the second transaction. The buffer in the second
87     // transaction will now no longer be presented so it is released immediately and the third
88     // transaction doesn't need a previous release fence.
89     for (auto& handle : mDrawingState.callbackHandles) {
90         if (handle->releasePreviousBuffer) {
91             handle->previousReleaseFence = releaseFence;
92             break;
93         }
94     }
95 
96     mPreviousReleaseFence = releaseFence;
97 
98     // Prevent tracing the same release multiple times.
99     if (mPreviousFrameNumber != mPreviousReleasedFrameNumber) {
100         mPreviousReleasedFrameNumber = mPreviousFrameNumber;
101     }
102 }
103 
releasePendingBuffer(nsecs_t dequeueReadyTime)104 void BufferStateLayer::releasePendingBuffer(nsecs_t dequeueReadyTime) {
105     for (const auto& handle : mDrawingState.callbackHandles) {
106         handle->transformHint = mTransformHint;
107         handle->dequeueReadyTime = dequeueReadyTime;
108     }
109 
110     mFlinger->getTransactionCompletedThread().finalizePendingCallbackHandles(
111             mDrawingState.callbackHandles);
112 
113     mDrawingState.callbackHandles = {};
114 
115     const sp<Fence>& releaseFence(mPreviousReleaseFence);
116     std::shared_ptr<FenceTime> releaseFenceTime = std::make_shared<FenceTime>(releaseFence);
117     {
118         Mutex::Autolock lock(mFrameEventHistoryMutex);
119         if (mPreviousFrameNumber != 0) {
120             mFrameEventHistory.addRelease(mPreviousFrameNumber, dequeueReadyTime,
121                                           std::move(releaseFenceTime));
122         }
123     }
124 }
125 
finalizeFrameEventHistory(const std::shared_ptr<FenceTime> & glDoneFence,const CompositorTiming & compositorTiming)126 void BufferStateLayer::finalizeFrameEventHistory(const std::shared_ptr<FenceTime>& glDoneFence,
127                                                  const CompositorTiming& compositorTiming) {
128     for (const auto& handle : mDrawingState.callbackHandles) {
129         handle->gpuCompositionDoneFence = glDoneFence;
130         handle->compositorTiming = compositorTiming;
131     }
132 }
133 
shouldPresentNow(nsecs_t) const134 bool BufferStateLayer::shouldPresentNow(nsecs_t /*expectedPresentTime*/) const {
135     if (getSidebandStreamChanged() || getAutoRefresh()) {
136         return true;
137     }
138 
139     return hasFrameUpdate();
140 }
141 
willPresentCurrentTransaction() const142 bool BufferStateLayer::willPresentCurrentTransaction() const {
143     // Returns true if the most recent Transaction applied to CurrentState will be presented.
144     return (getSidebandStreamChanged() || getAutoRefresh() ||
145             (mCurrentState.modified &&
146              (mCurrentState.buffer != nullptr || mCurrentState.bgColorLayer != nullptr))) &&
147         !mLayerDetached;
148 }
149 
150 /* TODO: vhau uncomment once deferred transaction migration complete in
151  * WindowManager
152 void BufferStateLayer::pushPendingState() {
153     if (!mCurrentState.modified) {
154         return;
155     }
156     mPendingStates.push_back(mCurrentState);
157     ATRACE_INT(mTransactionName.c_str(), mPendingStates.size());
158 }
159 */
160 
applyPendingStates(Layer::State * stateToCommit)161 bool BufferStateLayer::applyPendingStates(Layer::State* stateToCommit) {
162     mCurrentStateModified = mCurrentState.modified;
163     bool stateUpdateAvailable = Layer::applyPendingStates(stateToCommit);
164     mCurrentStateModified = stateUpdateAvailable && mCurrentStateModified;
165     mCurrentState.modified = false;
166     return stateUpdateAvailable;
167 }
168 
169 // Crop that applies to the window
getCrop(const Layer::State &) const170 Rect BufferStateLayer::getCrop(const Layer::State& /*s*/) const {
171     return Rect::INVALID_RECT;
172 }
173 
setTransform(uint32_t transform)174 bool BufferStateLayer::setTransform(uint32_t transform) {
175     if (mCurrentState.transform == transform) return false;
176     mCurrentState.transform = transform;
177     mCurrentState.modified = true;
178     setTransactionFlags(eTransactionNeeded);
179     return true;
180 }
181 
setTransformToDisplayInverse(bool transformToDisplayInverse)182 bool BufferStateLayer::setTransformToDisplayInverse(bool transformToDisplayInverse) {
183     if (mCurrentState.transformToDisplayInverse == transformToDisplayInverse) return false;
184     mCurrentState.sequence++;
185     mCurrentState.transformToDisplayInverse = transformToDisplayInverse;
186     mCurrentState.modified = true;
187     setTransactionFlags(eTransactionNeeded);
188     return true;
189 }
190 
setCrop(const Rect & crop)191 bool BufferStateLayer::setCrop(const Rect& crop) {
192     Rect c = crop;
193     if (c.left < 0) {
194         c.left = 0;
195     }
196     if (c.top < 0) {
197         c.top = 0;
198     }
199     // If the width and/or height are < 0, make it [0, 0, -1, -1] so the equality comparision below
200     // treats all invalid rectangles the same.
201     if (!c.isValid()) {
202         c.makeInvalid();
203     }
204 
205     if (mCurrentState.crop == c) return false;
206     mCurrentState.crop = c;
207     mCurrentState.modified = true;
208     setTransactionFlags(eTransactionNeeded);
209     return true;
210 }
211 
setFrame(const Rect & frame)212 bool BufferStateLayer::setFrame(const Rect& frame) {
213     int x = frame.left;
214     int y = frame.top;
215     int w = frame.getWidth();
216     int h = frame.getHeight();
217 
218     if (x < 0) {
219         x = 0;
220         w = frame.right;
221     }
222 
223     if (y < 0) {
224         y = 0;
225         h = frame.bottom;
226     }
227 
228     if (mCurrentState.active.transform.tx() == x && mCurrentState.active.transform.ty() == y &&
229         mCurrentState.active.w == w && mCurrentState.active.h == h) {
230         return false;
231     }
232 
233     if (!frame.isValid()) {
234         x = y = w = h = 0;
235     }
236     mCurrentState.active.transform.set(x, y);
237     mCurrentState.active.w = w;
238     mCurrentState.active.h = h;
239 
240     mCurrentState.sequence++;
241     mCurrentState.modified = true;
242     setTransactionFlags(eTransactionNeeded);
243     return true;
244 }
245 
addFrameEvent(const sp<Fence> & acquireFence,nsecs_t postedTime,nsecs_t desiredPresentTime)246 bool BufferStateLayer::addFrameEvent(const sp<Fence>& acquireFence, nsecs_t postedTime,
247                                      nsecs_t desiredPresentTime) {
248     Mutex::Autolock lock(mFrameEventHistoryMutex);
249     mAcquireTimeline.updateSignalTimes();
250     std::shared_ptr<FenceTime> acquireFenceTime =
251             std::make_shared<FenceTime>((acquireFence ? acquireFence : Fence::NO_FENCE));
252     NewFrameEventsEntry newTimestamps = {mCurrentState.frameNumber, postedTime, desiredPresentTime,
253                                          acquireFenceTime};
254     mFrameEventHistory.setProducerWantsEvents();
255     mFrameEventHistory.addQueue(newTimestamps);
256     return true;
257 }
258 
setBuffer(const sp<GraphicBuffer> & buffer,const sp<Fence> & acquireFence,nsecs_t postTime,nsecs_t desiredPresentTime,const client_cache_t & clientCacheId)259 bool BufferStateLayer::setBuffer(const sp<GraphicBuffer>& buffer, const sp<Fence>& acquireFence,
260                                  nsecs_t postTime, nsecs_t desiredPresentTime,
261                                  const client_cache_t& clientCacheId) {
262     if (mCurrentState.buffer) {
263         mReleasePreviousBuffer = true;
264     }
265 
266     mCurrentState.frameNumber++;
267 
268     mCurrentState.buffer = buffer;
269     mCurrentState.clientCacheId = clientCacheId;
270     mCurrentState.modified = true;
271     setTransactionFlags(eTransactionNeeded);
272 
273     const int32_t layerId = getSequence();
274     mFlinger->mTimeStats->setPostTime(layerId, mCurrentState.frameNumber, getName().c_str(),
275                                       postTime);
276     desiredPresentTime = desiredPresentTime <= 0 ? 0 : desiredPresentTime;
277     mCurrentState.desiredPresentTime = desiredPresentTime;
278 
279     mFlinger->mScheduler->recordLayerHistory(this, desiredPresentTime,
280                                              LayerHistory::LayerUpdateType::Buffer);
281 
282     addFrameEvent(acquireFence, postTime, desiredPresentTime);
283     return true;
284 }
285 
setAcquireFence(const sp<Fence> & fence)286 bool BufferStateLayer::setAcquireFence(const sp<Fence>& fence) {
287     // The acquire fences of BufferStateLayers have already signaled before they are set
288     mCallbackHandleAcquireTime = fence->getSignalTime();
289 
290     mCurrentState.acquireFence = fence;
291     mCurrentState.modified = true;
292     setTransactionFlags(eTransactionNeeded);
293     return true;
294 }
295 
setDataspace(ui::Dataspace dataspace)296 bool BufferStateLayer::setDataspace(ui::Dataspace dataspace) {
297     if (mCurrentState.dataspace == dataspace) return false;
298     mCurrentState.dataspace = dataspace;
299     mCurrentState.modified = true;
300     setTransactionFlags(eTransactionNeeded);
301     return true;
302 }
303 
setHdrMetadata(const HdrMetadata & hdrMetadata)304 bool BufferStateLayer::setHdrMetadata(const HdrMetadata& hdrMetadata) {
305     if (mCurrentState.hdrMetadata == hdrMetadata) return false;
306     mCurrentState.hdrMetadata = hdrMetadata;
307     mCurrentState.modified = true;
308     setTransactionFlags(eTransactionNeeded);
309     return true;
310 }
311 
setSurfaceDamageRegion(const Region & surfaceDamage)312 bool BufferStateLayer::setSurfaceDamageRegion(const Region& surfaceDamage) {
313     mCurrentState.surfaceDamageRegion = surfaceDamage;
314     mCurrentState.modified = true;
315     setTransactionFlags(eTransactionNeeded);
316     return true;
317 }
318 
setApi(int32_t api)319 bool BufferStateLayer::setApi(int32_t api) {
320     if (mCurrentState.api == api) return false;
321     mCurrentState.api = api;
322     mCurrentState.modified = true;
323     setTransactionFlags(eTransactionNeeded);
324     return true;
325 }
326 
setSidebandStream(const sp<NativeHandle> & sidebandStream)327 bool BufferStateLayer::setSidebandStream(const sp<NativeHandle>& sidebandStream) {
328     if (mCurrentState.sidebandStream == sidebandStream) return false;
329     mCurrentState.sidebandStream = sidebandStream;
330     mCurrentState.modified = true;
331     setTransactionFlags(eTransactionNeeded);
332 
333     if (!mSidebandStreamChanged.exchange(true)) {
334         // mSidebandStreamChanged was false
335         mFlinger->signalLayerUpdate();
336     }
337     return true;
338 }
339 
setTransactionCompletedListeners(const std::vector<sp<CallbackHandle>> & handles)340 bool BufferStateLayer::setTransactionCompletedListeners(
341         const std::vector<sp<CallbackHandle>>& handles) {
342     // If there is no handle, we will not send a callback so reset mReleasePreviousBuffer and return
343     if (handles.empty()) {
344         mReleasePreviousBuffer = false;
345         return false;
346     }
347 
348     const bool willPresent = willPresentCurrentTransaction();
349 
350     for (const auto& handle : handles) {
351         // If this transaction set a buffer on this layer, release its previous buffer
352         handle->releasePreviousBuffer = mReleasePreviousBuffer;
353 
354         // If this layer will be presented in this frame
355         if (willPresent) {
356             // If this transaction set an acquire fence on this layer, set its acquire time
357             handle->acquireTime = mCallbackHandleAcquireTime;
358 
359             // Notify the transaction completed thread that there is a pending latched callback
360             // handle
361             mFlinger->getTransactionCompletedThread().registerPendingCallbackHandle(handle);
362 
363             // Store so latched time and release fence can be set
364             mCurrentState.callbackHandles.push_back(handle);
365 
366         } else { // If this layer will NOT need to be relatched and presented this frame
367             // Notify the transaction completed thread this handle is done
368             mFlinger->getTransactionCompletedThread().registerUnpresentedCallbackHandle(handle);
369         }
370     }
371 
372     mReleasePreviousBuffer = false;
373     mCallbackHandleAcquireTime = -1;
374 
375     return willPresent;
376 }
377 
forceSendCallbacks()378 void BufferStateLayer::forceSendCallbacks() {
379     mFlinger->getTransactionCompletedThread().finalizePendingCallbackHandles(
380             mCurrentState.callbackHandles);
381 }
382 
setTransparentRegionHint(const Region & transparent)383 bool BufferStateLayer::setTransparentRegionHint(const Region& transparent) {
384     mCurrentState.transparentRegionHint = transparent;
385     mCurrentState.modified = true;
386     setTransactionFlags(eTransactionNeeded);
387     return true;
388 }
389 
getBufferSize(const State & s) const390 Rect BufferStateLayer::getBufferSize(const State& s) const {
391     // for buffer state layers we use the display frame size as the buffer size.
392     if (getActiveWidth(s) < UINT32_MAX && getActiveHeight(s) < UINT32_MAX) {
393         return Rect(getActiveWidth(s), getActiveHeight(s));
394     }
395 
396     // if the display frame is not defined, use the parent bounds as the buffer size.
397     const auto& p = mDrawingParent.promote();
398     if (p != nullptr) {
399         Rect parentBounds = Rect(p->getBounds(Region()));
400         if (!parentBounds.isEmpty()) {
401             return parentBounds;
402         }
403     }
404 
405     return Rect::INVALID_RECT;
406 }
407 
computeSourceBounds(const FloatRect & parentBounds) const408 FloatRect BufferStateLayer::computeSourceBounds(const FloatRect& parentBounds) const {
409     const State& s(getDrawingState());
410     // for buffer state layers we use the display frame size as the buffer size.
411     if (getActiveWidth(s) < UINT32_MAX && getActiveHeight(s) < UINT32_MAX) {
412         return FloatRect(0, 0, getActiveWidth(s), getActiveHeight(s));
413     }
414 
415     // if the display frame is not defined, use the parent bounds as the buffer size.
416     return parentBounds;
417 }
418 
419 // -----------------------------------------------------------------------
420 
421 // -----------------------------------------------------------------------
422 // Interface implementation for BufferLayer
423 // -----------------------------------------------------------------------
fenceHasSignaled() const424 bool BufferStateLayer::fenceHasSignaled() const {
425     if (latchUnsignaledBuffers()) {
426         return true;
427     }
428 
429     const bool fenceSignaled =
430             getDrawingState().acquireFence->getStatus() == Fence::Status::Signaled;
431     if (!fenceSignaled) {
432         mFlinger->mTimeStats->incrementLatchSkipped(getSequence(),
433                                                     TimeStats::LatchSkipReason::LateAcquire);
434     }
435 
436     return fenceSignaled;
437 }
438 
framePresentTimeIsCurrent(nsecs_t expectedPresentTime) const439 bool BufferStateLayer::framePresentTimeIsCurrent(nsecs_t expectedPresentTime) const {
440     if (!hasFrameUpdate() || isRemovedFromCurrentState()) {
441         return true;
442     }
443 
444     return mCurrentState.desiredPresentTime <= expectedPresentTime;
445 }
446 
onPreComposition(nsecs_t refreshStartTime)447 bool BufferStateLayer::onPreComposition(nsecs_t refreshStartTime) {
448     for (const auto& handle : mDrawingState.callbackHandles) {
449         handle->refreshStartTime = refreshStartTime;
450     }
451     return BufferLayer::onPreComposition(refreshStartTime);
452 }
453 
getFrameNumber(nsecs_t) const454 uint64_t BufferStateLayer::getFrameNumber(nsecs_t /*expectedPresentTime*/) const {
455     return mDrawingState.frameNumber;
456 }
457 
458 /**
459  * This is the frameNumber used for deferred transaction signalling. We need to use this because
460  * of cases where we defer a transaction for a surface to itself. In the BLAST world this
461  * may not make a huge amount of sense (Why not just merge the Buffer transaction with the
462  * deferred transaction?) but this is an important legacy use case, for example moving
463  * a window at the same time it draws makes use of this kind of technique. So anyway
464  * imagine we have something like this:
465  *
466  * Transaction { // containing
467  *     Buffer -> frameNumber = 2
468  *     DeferTransactionUntil -> frameNumber = 2
469  *     Random other stuff
470  *  }
471  * Now imagine getHeadFrameNumber returned mDrawingState.mFrameNumber (or mCurrentFrameNumber).
472  * Prior to doTransaction SurfaceFlinger will call notifyAvailableFrames, but because we
473  * haven't swapped mCurrentState to mDrawingState yet we will think the sync point
474  * is not ready. So we will return false from applyPendingState and not swap
475  * current state to drawing state. But because we don't swap current state
476  * to drawing state the number will never update and we will be stuck. This way
477  * we can see we need to return the frame number for the buffer we are about
478  * to apply.
479  */
getHeadFrameNumber(nsecs_t) const480 uint64_t BufferStateLayer::getHeadFrameNumber(nsecs_t /* expectedPresentTime */) const {
481     return mCurrentState.frameNumber;
482 }
483 
getAutoRefresh() const484 bool BufferStateLayer::getAutoRefresh() const {
485     // TODO(marissaw): support shared buffer mode
486     return false;
487 }
488 
getSidebandStreamChanged() const489 bool BufferStateLayer::getSidebandStreamChanged() const {
490     return mSidebandStreamChanged.load();
491 }
492 
latchSidebandStream(bool & recomputeVisibleRegions)493 bool BufferStateLayer::latchSidebandStream(bool& recomputeVisibleRegions) {
494     if (mSidebandStreamChanged.exchange(false)) {
495         const State& s(getDrawingState());
496         // mSidebandStreamChanged was true
497         mSidebandStream = s.sidebandStream;
498         editCompositionState()->sidebandStream = mSidebandStream;
499         if (mSidebandStream != nullptr) {
500             setTransactionFlags(eTransactionNeeded);
501             mFlinger->setTransactionFlags(eTraversalNeeded);
502         }
503         recomputeVisibleRegions = true;
504 
505         return true;
506     }
507     return false;
508 }
509 
hasFrameUpdate() const510 bool BufferStateLayer::hasFrameUpdate() const {
511     const State& c(getCurrentState());
512     return mCurrentStateModified && (c.buffer != nullptr || c.bgColorLayer != nullptr);
513 }
514 
bindTextureImage()515 status_t BufferStateLayer::bindTextureImage() {
516     const State& s(getDrawingState());
517     auto& engine(mFlinger->getRenderEngine());
518 
519     return engine.bindExternalTextureBuffer(mTextureName, s.buffer, s.acquireFence);
520 }
521 
updateTexImage(bool &,nsecs_t latchTime,nsecs_t)522 status_t BufferStateLayer::updateTexImage(bool& /*recomputeVisibleRegions*/, nsecs_t latchTime,
523                                           nsecs_t /*expectedPresentTime*/) {
524     const State& s(getDrawingState());
525 
526     if (!s.buffer) {
527         if (s.bgColorLayer) {
528             for (auto& handle : mDrawingState.callbackHandles) {
529                 handle->latchTime = latchTime;
530             }
531         }
532         return NO_ERROR;
533     }
534 
535     const int32_t layerId = getSequence();
536 
537     // Reject if the layer is invalid
538     uint32_t bufferWidth = s.buffer->width;
539     uint32_t bufferHeight = s.buffer->height;
540 
541     if (s.transform & ui::Transform::ROT_90) {
542         std::swap(bufferWidth, bufferHeight);
543     }
544 
545     if (s.transformToDisplayInverse) {
546         uint32_t invTransform = DisplayDevice::getPrimaryDisplayRotationFlags();
547         if (invTransform & ui::Transform::ROT_90) {
548             std::swap(bufferWidth, bufferHeight);
549         }
550     }
551 
552     if (getEffectiveScalingMode() == NATIVE_WINDOW_SCALING_MODE_FREEZE &&
553         (s.active.w != bufferWidth || s.active.h != bufferHeight)) {
554         ALOGE("[%s] rejecting buffer: "
555               "bufferWidth=%d, bufferHeight=%d, front.active.{w=%d, h=%d}",
556               getDebugName(), bufferWidth, bufferHeight, s.active.w, s.active.h);
557         mFlinger->mTimeStats->removeTimeRecord(layerId, mDrawingState.frameNumber);
558         return BAD_VALUE;
559     }
560 
561     for (auto& handle : mDrawingState.callbackHandles) {
562         handle->latchTime = latchTime;
563         handle->frameNumber = mDrawingState.frameNumber;
564     }
565 
566     if (!SyncFeatures::getInstance().useNativeFenceSync()) {
567         // Bind the new buffer to the GL texture.
568         //
569         // Older devices require the "implicit" synchronization provided
570         // by glEGLImageTargetTexture2DOES, which this method calls.  Newer
571         // devices will either call this in Layer::onDraw, or (if it's not
572         // a GL-composited layer) not at all.
573         status_t err = bindTextureImage();
574         if (err != NO_ERROR) {
575             mFlinger->mTimeStats->onDestroy(layerId);
576             return BAD_VALUE;
577         }
578     }
579 
580     mFlinger->mTimeStats->setAcquireFence(layerId, mDrawingState.frameNumber,
581                                           std::make_shared<FenceTime>(mDrawingState.acquireFence));
582     mFlinger->mTimeStats->setLatchTime(layerId, mDrawingState.frameNumber, latchTime);
583 
584     mCurrentStateModified = false;
585 
586     return NO_ERROR;
587 }
588 
updateActiveBuffer()589 status_t BufferStateLayer::updateActiveBuffer() {
590     const State& s(getDrawingState());
591 
592     if (s.buffer == nullptr) {
593         return BAD_VALUE;
594     }
595 
596     mPreviousBufferId = getCurrentBufferId();
597     mBufferInfo.mBuffer = s.buffer;
598     mBufferInfo.mFence = s.acquireFence;
599 
600     return NO_ERROR;
601 }
602 
updateFrameNumber(nsecs_t latchTime)603 status_t BufferStateLayer::updateFrameNumber(nsecs_t latchTime) {
604     // TODO(marissaw): support frame history events
605     mPreviousFrameNumber = mCurrentFrameNumber;
606     mCurrentFrameNumber = mDrawingState.frameNumber;
607     {
608         Mutex::Autolock lock(mFrameEventHistoryMutex);
609         mFrameEventHistory.addLatch(mCurrentFrameNumber, latchTime);
610     }
611     return NO_ERROR;
612 }
613 
bufferErased(const client_cache_t & clientCacheId)614 void BufferStateLayer::HwcSlotGenerator::bufferErased(const client_cache_t& clientCacheId) {
615     std::lock_guard lock(mMutex);
616     if (!clientCacheId.isValid()) {
617         ALOGE("invalid process, failed to erase buffer");
618         return;
619     }
620     eraseBufferLocked(clientCacheId);
621 }
622 
getHwcCacheSlot(const client_cache_t & clientCacheId)623 uint32_t BufferStateLayer::HwcSlotGenerator::getHwcCacheSlot(const client_cache_t& clientCacheId) {
624     std::lock_guard<std::mutex> lock(mMutex);
625     auto itr = mCachedBuffers.find(clientCacheId);
626     if (itr == mCachedBuffers.end()) {
627         return addCachedBuffer(clientCacheId);
628     }
629     auto& [hwcCacheSlot, counter] = itr->second;
630     counter = mCounter++;
631     return hwcCacheSlot;
632 }
633 
addCachedBuffer(const client_cache_t & clientCacheId)634 uint32_t BufferStateLayer::HwcSlotGenerator::addCachedBuffer(const client_cache_t& clientCacheId)
635         REQUIRES(mMutex) {
636     if (!clientCacheId.isValid()) {
637         ALOGE("invalid process, returning invalid slot");
638         return BufferQueue::INVALID_BUFFER_SLOT;
639     }
640 
641     ClientCache::getInstance().registerErasedRecipient(clientCacheId, wp<ErasedRecipient>(this));
642 
643     uint32_t hwcCacheSlot = getFreeHwcCacheSlot();
644     mCachedBuffers[clientCacheId] = {hwcCacheSlot, mCounter++};
645     return hwcCacheSlot;
646 }
647 
getFreeHwcCacheSlot()648 uint32_t BufferStateLayer::HwcSlotGenerator::getFreeHwcCacheSlot() REQUIRES(mMutex) {
649     if (mFreeHwcCacheSlots.empty()) {
650         evictLeastRecentlyUsed();
651     }
652 
653     uint32_t hwcCacheSlot = mFreeHwcCacheSlots.top();
654     mFreeHwcCacheSlots.pop();
655     return hwcCacheSlot;
656 }
657 
evictLeastRecentlyUsed()658 void BufferStateLayer::HwcSlotGenerator::evictLeastRecentlyUsed() REQUIRES(mMutex) {
659     uint64_t minCounter = UINT_MAX;
660     client_cache_t minClientCacheId = {};
661     for (const auto& [clientCacheId, slotCounter] : mCachedBuffers) {
662         const auto& [hwcCacheSlot, counter] = slotCounter;
663         if (counter < minCounter) {
664             minCounter = counter;
665             minClientCacheId = clientCacheId;
666         }
667     }
668     eraseBufferLocked(minClientCacheId);
669 
670     ClientCache::getInstance().unregisterErasedRecipient(minClientCacheId, this);
671 }
672 
eraseBufferLocked(const client_cache_t & clientCacheId)673 void BufferStateLayer::HwcSlotGenerator::eraseBufferLocked(const client_cache_t& clientCacheId)
674         REQUIRES(mMutex) {
675     auto itr = mCachedBuffers.find(clientCacheId);
676     if (itr == mCachedBuffers.end()) {
677         return;
678     }
679     auto& [hwcCacheSlot, counter] = itr->second;
680 
681     // TODO send to hwc cache and resources
682 
683     mFreeHwcCacheSlots.push(hwcCacheSlot);
684     mCachedBuffers.erase(clientCacheId);
685 }
686 
gatherBufferInfo()687 void BufferStateLayer::gatherBufferInfo() {
688     BufferLayer::gatherBufferInfo();
689 
690     const State& s(getDrawingState());
691     mBufferInfo.mDesiredPresentTime = s.desiredPresentTime;
692     mBufferInfo.mFenceTime = std::make_shared<FenceTime>(s.acquireFence);
693     mBufferInfo.mFence = s.acquireFence;
694     mBufferInfo.mTransform = s.transform;
695     mBufferInfo.mDataspace = translateDataspace(s.dataspace);
696     mBufferInfo.mCrop = computeCrop(s);
697     mBufferInfo.mScaleMode = NATIVE_WINDOW_SCALING_MODE_SCALE_TO_WINDOW;
698     mBufferInfo.mSurfaceDamage = s.surfaceDamageRegion;
699     mBufferInfo.mHdrMetadata = s.hdrMetadata;
700     mBufferInfo.mApi = s.api;
701     mBufferInfo.mTransformToDisplayInverse = s.transformToDisplayInverse;
702     mBufferInfo.mBufferSlot = mHwcSlotGenerator->getHwcCacheSlot(s.clientCacheId);
703 }
704 
computeCrop(const State & s)705 Rect BufferStateLayer::computeCrop(const State& s) {
706     if (s.crop.isEmpty() && s.buffer) {
707         return s.buffer->getBounds();
708     } else if (s.buffer) {
709         Rect crop = s.crop;
710         crop.left = std::max(crop.left, 0);
711         crop.top = std::max(crop.top, 0);
712         uint32_t bufferWidth = s.buffer->getWidth();
713         uint32_t bufferHeight = s.buffer->getHeight();
714         if (bufferHeight <= std::numeric_limits<int32_t>::max() &&
715             bufferWidth <= std::numeric_limits<int32_t>::max()) {
716             crop.right = std::min(crop.right, static_cast<int32_t>(bufferWidth));
717             crop.bottom = std::min(crop.bottom, static_cast<int32_t>(bufferHeight));
718         }
719         if (!crop.isValid()) {
720             // Crop rect is out of bounds, return whole buffer
721             return s.buffer->getBounds();
722         }
723         return crop;
724     }
725     return s.crop;
726 }
727 
createClone()728 sp<Layer> BufferStateLayer::createClone() {
729     LayerCreationArgs args(mFlinger.get(), nullptr, mName + " (Mirror)", 0, 0, 0, LayerMetadata());
730     args.textureName = mTextureName;
731     sp<BufferStateLayer> layer = mFlinger->getFactory().createBufferStateLayer(args);
732     layer->mHwcSlotGenerator = mHwcSlotGenerator;
733     layer->setInitialValuesForClone(this);
734     return layer;
735 }
736 
getRoundedCornerState() const737 Layer::RoundedCornerState BufferStateLayer::getRoundedCornerState() const {
738     const auto& p = mDrawingParent.promote();
739     if (p != nullptr) {
740         RoundedCornerState parentState = p->getRoundedCornerState();
741         if (parentState.radius > 0) {
742             ui::Transform t = getActiveTransform(getDrawingState());
743             t = t.inverse();
744             parentState.cropRect = t.transform(parentState.cropRect);
745             // The rounded corners shader only accepts 1 corner radius for performance reasons,
746             // but a transform matrix can define horizontal and vertical scales.
747             // Let's take the average between both of them and pass into the shader, practically we
748             // never do this type of transformation on windows anyway.
749             parentState.radius *= (t[0][0] + t[1][1]) / 2.0f;
750             return parentState;
751         }
752     }
753     const float radius = getDrawingState().cornerRadius;
754     const State& s(getDrawingState());
755     if (radius <= 0 || (getActiveWidth(s) == UINT32_MAX && getActiveHeight(s) == UINT32_MAX))
756         return RoundedCornerState();
757     return RoundedCornerState(FloatRect(static_cast<float>(s.active.transform.tx()),
758                                         static_cast<float>(s.active.transform.ty()),
759                                         static_cast<float>(s.active.transform.tx() + s.active.w),
760                                         static_cast<float>(s.active.transform.ty() + s.active.h)),
761                               radius);
762 }
763 } // namespace android
764 
765 // TODO(b/129481165): remove the #pragma below and fix conversion issues
766 #pragma clang diagnostic pop // ignored "-Wconversion"
767