BufferQueue.cpp revision fa5b40ebb8923133df12dc70591bfe35b3f1c9b3
16b091c53000c843211c218ce40287a7edca9bc63Daniel Lam/*
26b091c53000c843211c218ce40287a7edca9bc63Daniel Lam * Copyright (C) 2012 The Android Open Source Project
36b091c53000c843211c218ce40287a7edca9bc63Daniel Lam *
46b091c53000c843211c218ce40287a7edca9bc63Daniel Lam * Licensed under the Apache License, Version 2.0 (the "License");
56b091c53000c843211c218ce40287a7edca9bc63Daniel Lam * you may not use this file except in compliance with the License.
66b091c53000c843211c218ce40287a7edca9bc63Daniel Lam * You may obtain a copy of the License at
76b091c53000c843211c218ce40287a7edca9bc63Daniel Lam *
86b091c53000c843211c218ce40287a7edca9bc63Daniel Lam *      http://www.apache.org/licenses/LICENSE-2.0
96b091c53000c843211c218ce40287a7edca9bc63Daniel Lam *
106b091c53000c843211c218ce40287a7edca9bc63Daniel Lam * Unless required by applicable law or agreed to in writing, software
116b091c53000c843211c218ce40287a7edca9bc63Daniel Lam * distributed under the License is distributed on an "AS IS" BASIS,
126b091c53000c843211c218ce40287a7edca9bc63Daniel Lam * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
136b091c53000c843211c218ce40287a7edca9bc63Daniel Lam * See the License for the specific language governing permissions and
146b091c53000c843211c218ce40287a7edca9bc63Daniel Lam * limitations under the License.
156b091c53000c843211c218ce40287a7edca9bc63Daniel Lam */
166b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
176b091c53000c843211c218ce40287a7edca9bc63Daniel Lam#define LOG_TAG "BufferQueue"
181c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis#define ATRACE_TAG ATRACE_TAG_GRAPHICS
19fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis//#define LOG_NDEBUG 0
206b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
216b091c53000c843211c218ce40287a7edca9bc63Daniel Lam#define GL_GLEXT_PROTOTYPES
226b091c53000c843211c218ce40287a7edca9bc63Daniel Lam#define EGL_EGLEXT_PROTOTYPES
236b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
246b091c53000c843211c218ce40287a7edca9bc63Daniel Lam#include <EGL/egl.h>
256b091c53000c843211c218ce40287a7edca9bc63Daniel Lam#include <EGL/eglext.h>
266b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
276b091c53000c843211c218ce40287a7edca9bc63Daniel Lam#include <gui/BufferQueue.h>
2890ac799241f077a7b7e6c1875fd933864c8dd2a7Mathias Agopian#include <gui/ISurfaceComposer.h>
296b091c53000c843211c218ce40287a7edca9bc63Daniel Lam#include <private/gui/ComposerService.h>
306b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
316b091c53000c843211c218ce40287a7edca9bc63Daniel Lam#include <utils/Log.h>
32eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam#include <gui/SurfaceTexture.h>
331c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis#include <utils/Trace.h>
346b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
356b091c53000c843211c218ce40287a7edca9bc63Daniel Lam// This compile option causes SurfaceTexture to return the buffer that is currently
366b091c53000c843211c218ce40287a7edca9bc63Daniel Lam// attached to the GL texture from dequeueBuffer when no other buffers are
376b091c53000c843211c218ce40287a7edca9bc63Daniel Lam// available.  It requires the drivers (Gralloc, GL, OMX IL, and Camera) to do
386b091c53000c843211c218ce40287a7edca9bc63Daniel Lam// implicit cross-process synchronization to prevent the buffer from being
396b091c53000c843211c218ce40287a7edca9bc63Daniel Lam// written to before the buffer has (a) been detached from the GL texture and
406b091c53000c843211c218ce40287a7edca9bc63Daniel Lam// (b) all GL reads from the buffer have completed.
41eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
42eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam// During refactoring, do not support dequeuing the current buffer
43eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam#undef ALLOW_DEQUEUE_CURRENT_BUFFER
44eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
456b091c53000c843211c218ce40287a7edca9bc63Daniel Lam#ifdef ALLOW_DEQUEUE_CURRENT_BUFFER
466b091c53000c843211c218ce40287a7edca9bc63Daniel Lam#define FLAG_ALLOW_DEQUEUE_CURRENT_BUFFER    true
476b091c53000c843211c218ce40287a7edca9bc63Daniel Lam#warning "ALLOW_DEQUEUE_CURRENT_BUFFER enabled"
486b091c53000c843211c218ce40287a7edca9bc63Daniel Lam#else
496b091c53000c843211c218ce40287a7edca9bc63Daniel Lam#define FLAG_ALLOW_DEQUEUE_CURRENT_BUFFER    false
506b091c53000c843211c218ce40287a7edca9bc63Daniel Lam#endif
516b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
526b091c53000c843211c218ce40287a7edca9bc63Daniel Lam// Macros for including the BufferQueue name in log messages
53eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam#define ST_LOGV(x, ...) ALOGV("[%s] "x, mConsumerName.string(), ##__VA_ARGS__)
54eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam#define ST_LOGD(x, ...) ALOGD("[%s] "x, mConsumerName.string(), ##__VA_ARGS__)
55eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam#define ST_LOGI(x, ...) ALOGI("[%s] "x, mConsumerName.string(), ##__VA_ARGS__)
56eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam#define ST_LOGW(x, ...) ALOGW("[%s] "x, mConsumerName.string(), ##__VA_ARGS__)
57eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam#define ST_LOGE(x, ...) ALOGE("[%s] "x, mConsumerName.string(), ##__VA_ARGS__)
586b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
59546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian#define ATRACE_BUFFER_INDEX(index)                                            \
60546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian    char ___traceBuf[1024];                                                   \
61546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian    snprintf(___traceBuf, 1024, "%s: %d", mConsumerName.string(), (index));   \
62546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian    android::ScopedTrace ___bufTracer(ATRACE_TAG, ___traceBuf);
63546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian
646b091c53000c843211c218ce40287a7edca9bc63Daniel Lamnamespace android {
656b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
666b091c53000c843211c218ce40287a7edca9bc63Daniel Lam// Get an ID that's unique within this process.
676b091c53000c843211c218ce40287a7edca9bc63Daniel Lamstatic int32_t createProcessUniqueId() {
686b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    static volatile int32_t globalCounter = 0;
696b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    return android_atomic_inc(&globalCounter);
706b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
716b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
726b091c53000c843211c218ce40287a7edca9bc63Daniel LamBufferQueue::BufferQueue( bool allowSynchronousMode ) :
736b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mDefaultWidth(1),
746b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mDefaultHeight(1),
756b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mPixelFormat(PIXEL_FORMAT_RGBA_8888),
766b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mBufferCount(MIN_ASYNC_BUFFER_SLOTS),
776b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mClientBufferCount(0),
786b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mServerBufferCount(MIN_ASYNC_BUFFER_SLOTS),
796b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mNextTransform(0),
806b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mNextScalingMode(NATIVE_WINDOW_SCALING_MODE_FREEZE),
816b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mSynchronousMode(false),
826b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mAllowSynchronousMode(allowSynchronousMode),
836b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mConnectedApi(NO_CONNECTED_API),
846b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mAbandoned(false),
85eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    mFrameCounter(0),
86b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam    mBufferHasBeenQueued(false),
87b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam    mDefaultBufferFormat(0),
88b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam    mConsumerUsageBits(0),
89b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam    mTransformHint(0)
906b091c53000c843211c218ce40287a7edca9bc63Daniel Lam{
916b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    // Choose a name using the PID and a process-unique ID.
92eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    mConsumerName = String8::format("unnamed-%d-%d", getpid(), createProcessUniqueId());
936b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
946b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ST_LOGV("BufferQueue");
956b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    sp<ISurfaceComposer> composer(ComposerService::getComposerService());
966b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mGraphicBufferAlloc = composer->createGraphicBufferAlloc();
976b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mNextCrop.makeInvalid();
986b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
996b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
1006b091c53000c843211c218ce40287a7edca9bc63Daniel LamBufferQueue::~BufferQueue() {
1016b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ST_LOGV("~BufferQueue");
1026b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
1036b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
1046b091c53000c843211c218ce40287a7edca9bc63Daniel Lamstatus_t BufferQueue::setBufferCountServerLocked(int bufferCount) {
1056b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (bufferCount > NUM_BUFFER_SLOTS)
1066b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return BAD_VALUE;
1076b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
1086b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    // special-case, nothing to do
1096b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (bufferCount == mBufferCount)
1106b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return OK;
1116b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
1126b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (!mClientBufferCount &&
1136b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        bufferCount >= mBufferCount) {
1146b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // easy, we just have more buffers
1156b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mBufferCount = bufferCount;
1166b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mServerBufferCount = bufferCount;
11774ff8c23f44f1546d0c7004302f4c7ba726ff4c0Dave Burke        mDequeueCondition.broadcast();
1186b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    } else {
1196b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // we're here because we're either
1206b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // - reducing the number of available buffers
1216b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // - or there is a client-buffer-count in effect
1226b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
1236b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // less than 2 buffers is never allowed
1246b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if (bufferCount < 2)
1256b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            return BAD_VALUE;
1266b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
1276b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // when there is non client-buffer-count in effect, the client is not
1286b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // allowed to dequeue more than one buffer at a time,
1296b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // so the next time they dequeue a buffer, we know that they don't
1306b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // own one. the actual resizing will happen during the next
1316b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // dequeueBuffer.
1326b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
1336b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mServerBufferCount = bufferCount;
134b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam        mDequeueCondition.broadcast();
1356b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
1366b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    return OK;
1376b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
1386b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
139eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lambool BufferQueue::isSynchronousMode() const {
140eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    Mutex::Autolock lock(mMutex);
141eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    return mSynchronousMode;
142eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam}
143eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
144eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lamvoid BufferQueue::setConsumerName(const String8& name) {
145eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    Mutex::Autolock lock(mMutex);
146eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    mConsumerName = name;
147eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam}
148eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
149b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lamstatus_t BufferQueue::setDefaultBufferFormat(uint32_t defaultFormat) {
150b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam    Mutex::Autolock lock(mMutex);
151b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam    mDefaultBufferFormat = defaultFormat;
152b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam    return OK;
153b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam}
154b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam
155b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lamstatus_t BufferQueue::setConsumerUsageBits(uint32_t usage) {
156b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam    Mutex::Autolock lock(mMutex);
157b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam    mConsumerUsageBits = usage;
158b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam    return OK;
159b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam}
160b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam
161b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lamstatus_t BufferQueue::setTransformHint(uint32_t hint) {
162b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam    Mutex::Autolock lock(mMutex);
163b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam    mTransformHint = hint;
164b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam    return OK;
165b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam}
166b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam
1676b091c53000c843211c218ce40287a7edca9bc63Daniel Lamstatus_t BufferQueue::setBufferCount(int bufferCount) {
1686b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ST_LOGV("setBufferCount: count=%d", bufferCount);
1696b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    Mutex::Autolock lock(mMutex);
1706b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
1716b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (mAbandoned) {
1726b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        ST_LOGE("setBufferCount: SurfaceTexture has been abandoned!");
1736b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return NO_INIT;
1746b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
1756b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (bufferCount > NUM_BUFFER_SLOTS) {
1766b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        ST_LOGE("setBufferCount: bufferCount larger than slots available");
1776b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return BAD_VALUE;
1786b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
1796b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
1806b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    // Error out if the user has dequeued buffers
1816b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    for (int i=0 ; i<mBufferCount ; i++) {
1826b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if (mSlots[i].mBufferState == BufferSlot::DEQUEUED) {
1836b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            ST_LOGE("setBufferCount: client owns some buffers");
1846b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            return -EINVAL;
1856b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        }
1866b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
1876b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
1886b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    const int minBufferSlots = mSynchronousMode ?
1896b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            MIN_SYNC_BUFFER_SLOTS : MIN_ASYNC_BUFFER_SLOTS;
1906b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (bufferCount == 0) {
1916b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mClientBufferCount = 0;
1926b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        bufferCount = (mServerBufferCount >= minBufferSlots) ?
1936b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                mServerBufferCount : minBufferSlots;
1946b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return setBufferCountServerLocked(bufferCount);
1956b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
1966b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
1976b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (bufferCount < minBufferSlots) {
1986b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        ST_LOGE("setBufferCount: requested buffer count (%d) is less than "
1996b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                "minimum (%d)", bufferCount, minBufferSlots);
2006b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return BAD_VALUE;
2016b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
2026b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
2036b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    // here we're guaranteed that the client doesn't have dequeued buffers
2046b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    // and will release all of its buffer references.
2056b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    freeAllBuffersLocked();
2066b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mBufferCount = bufferCount;
2076b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mClientBufferCount = bufferCount;
208eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    mBufferHasBeenQueued = false;
2096b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mQueue.clear();
21074ff8c23f44f1546d0c7004302f4c7ba726ff4c0Dave Burke    mDequeueCondition.broadcast();
2116b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    return OK;
2126b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
2136b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
214b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lamint BufferQueue::query(int what, int* outValue)
215b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam{
2161c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis    ATRACE_CALL();
217b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam    Mutex::Autolock lock(mMutex);
218b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam
219b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam    if (mAbandoned) {
220b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam        ST_LOGE("query: SurfaceTexture has been abandoned!");
221b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam        return NO_INIT;
222b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam    }
223b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam
224b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam    int value;
225b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam    switch (what) {
226b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam    case NATIVE_WINDOW_WIDTH:
227b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam        value = mDefaultWidth;
228b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam        break;
229b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam    case NATIVE_WINDOW_HEIGHT:
230b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam        value = mDefaultHeight;
231b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam        break;
232b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam    case NATIVE_WINDOW_FORMAT:
233b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam        value = mPixelFormat;
234b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam        break;
235b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam    case NATIVE_WINDOW_MIN_UNDEQUEUED_BUFFERS:
236b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam        value = mSynchronousMode ?
237b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam                (MIN_UNDEQUEUED_BUFFERS-1) : MIN_UNDEQUEUED_BUFFERS;
238b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam        break;
239b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam    default:
240b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam        return BAD_VALUE;
241b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam    }
242b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam    outValue[0] = value;
243b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam    return NO_ERROR;
244b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam}
245b856052c00dfef70d0957482c72c2979ffc4733aDaniel Lam
2466b091c53000c843211c218ce40287a7edca9bc63Daniel Lamstatus_t BufferQueue::requestBuffer(int slot, sp<GraphicBuffer>* buf) {
2471c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis    ATRACE_CALL();
2486b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ST_LOGV("requestBuffer: slot=%d", slot);
2496b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    Mutex::Autolock lock(mMutex);
2506b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (mAbandoned) {
2516b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        ST_LOGE("requestBuffer: SurfaceTexture has been abandoned!");
2526b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return NO_INIT;
2536b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
2546b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (slot < 0 || mBufferCount <= slot) {
2556b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        ST_LOGE("requestBuffer: slot index out of range [0, %d]: %d",
2566b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                mBufferCount, slot);
2576b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return BAD_VALUE;
2586b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
2596b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mSlots[slot].mRequestBufferCalled = true;
2606b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    *buf = mSlots[slot].mGraphicBuffer;
2616b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    return NO_ERROR;
2626b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
2636b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
2646b091c53000c843211c218ce40287a7edca9bc63Daniel Lamstatus_t BufferQueue::dequeueBuffer(int *outBuf, uint32_t w, uint32_t h,
2656b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        uint32_t format, uint32_t usage) {
2661c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis    ATRACE_CALL();
2676b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ST_LOGV("dequeueBuffer: w=%d h=%d fmt=%#x usage=%#x", w, h, format, usage);
2686b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
2696b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if ((w && !h) || (!w && h)) {
2706b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        ST_LOGE("dequeueBuffer: invalid size: w=%u, h=%u", w, h);
2716b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return BAD_VALUE;
2726b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
2736b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
2746b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    status_t returnFlags(OK);
2756b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    EGLDisplay dpy = EGL_NO_DISPLAY;
2766b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    EGLSyncKHR fence = EGL_NO_SYNC_KHR;
2776b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
2786b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    { // Scope for the lock
2796b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        Mutex::Autolock lock(mMutex);
2806b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
281b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam        if (format == 0) {
282b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam            format = mDefaultBufferFormat;
283b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam        }
284b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam        // turn on usage bits the consumer requested
285b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam        usage |= mConsumerUsageBits;
286b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam
2876b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        int found = -1;
2886b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        int foundSync = -1;
2896b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        int dequeuedCount = 0;
2906b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        bool tryAgain = true;
2916b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        while (tryAgain) {
2926b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            if (mAbandoned) {
2936b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                ST_LOGE("dequeueBuffer: SurfaceTexture has been abandoned!");
2946b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                return NO_INIT;
2956b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            }
2966b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
2976b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // We need to wait for the FIFO to drain if the number of buffer
2986b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // needs to change.
2996b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            //
3006b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // The condition "number of buffers needs to change" is true if
3016b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // - the client doesn't care about how many buffers there are
3026b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // - AND the actual number of buffer is different from what was
3036b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            //   set in the last setBufferCountServer()
3046b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            //                         - OR -
3056b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            //   setBufferCountServer() was set to a value incompatible with
3066b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            //   the synchronization mode (for instance because the sync mode
3076b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            //   changed since)
3086b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            //
3096b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // As long as this condition is true AND the FIFO is not empty, we
3106b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // wait on mDequeueCondition.
3116b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
3126b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            const int minBufferCountNeeded = mSynchronousMode ?
3136b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                    MIN_SYNC_BUFFER_SLOTS : MIN_ASYNC_BUFFER_SLOTS;
3146b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
3156b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            const bool numberOfBuffersNeedsToChange = !mClientBufferCount &&
3166b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                    ((mServerBufferCount != mBufferCount) ||
3176b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                            (mServerBufferCount < minBufferCountNeeded));
3186b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
3196b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            if (!mQueue.isEmpty() && numberOfBuffersNeedsToChange) {
3206b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                // wait for the FIFO to drain
3216b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                mDequeueCondition.wait(mMutex);
3226b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                // NOTE: we continue here because we need to reevaluate our
3236b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                // whole state (eg: we could be abandoned or disconnected)
3246b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                continue;
3256b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            }
3266b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
3276b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            if (numberOfBuffersNeedsToChange) {
3286b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                // here we're guaranteed that mQueue is empty
3296b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                freeAllBuffersLocked();
3306b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                mBufferCount = mServerBufferCount;
3316b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                if (mBufferCount < minBufferCountNeeded)
3326b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                    mBufferCount = minBufferCountNeeded;
333eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                mBufferHasBeenQueued = false;
3346b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                returnFlags |= ISurfaceTexture::RELEASE_ALL_BUFFERS;
3356b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            }
3366b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
3376b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // look for a free buffer to give to the client
3386b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            found = INVALID_BUFFER_SLOT;
3396b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            foundSync = INVALID_BUFFER_SLOT;
3406b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            dequeuedCount = 0;
3416b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            for (int i = 0; i < mBufferCount; i++) {
3426b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                const int state = mSlots[i].mBufferState;
3436b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                if (state == BufferSlot::DEQUEUED) {
3446b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                    dequeuedCount++;
3456b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                }
3466b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
347eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                // this logic used to be if (FLAG_ALLOW_DEQUEUE_CURRENT_BUFFER)
348eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                // but dequeuing the current buffer is disabled.
349eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                if (false) {
350eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                    // This functionality has been temporarily removed so
351eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                    // BufferQueue and SurfaceTexture can be refactored into
352eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                    // separate objects
3536b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                } else {
3546b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                    if (state == BufferSlot::FREE) {
3556b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                        /* We return the oldest of the free buffers to avoid
3566b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                         * stalling the producer if possible.  This is because
3576b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                         * the consumer may still have pending reads of the
3586b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                         * buffers in flight.
3596b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                         */
3606b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                        bool isOlder = mSlots[i].mFrameNumber <
3616b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                                mSlots[found].mFrameNumber;
3626b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                        if (found < 0 || isOlder) {
3636b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                            foundSync = i;
3646b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                            found = i;
3656b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                        }
3666b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                    }
3676b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                }
3686b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            }
3696b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
3706b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // clients are not allowed to dequeue more than one buffer
3716b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // if they didn't set a buffer count.
3726b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            if (!mClientBufferCount && dequeuedCount) {
3736b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                ST_LOGE("dequeueBuffer: can't dequeue multiple buffers without "
3746b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                        "setting the buffer count");
3756b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                return -EINVAL;
3766b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            }
3776b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
3786b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // See whether a buffer has been queued since the last
3796b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // setBufferCount so we know whether to perform the
3806b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // MIN_UNDEQUEUED_BUFFERS check below.
381eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            if (mBufferHasBeenQueued) {
3826b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                // make sure the client is not trying to dequeue more buffers
3836b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                // than allowed.
3846b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                const int avail = mBufferCount - (dequeuedCount+1);
3856b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                if (avail < (MIN_UNDEQUEUED_BUFFERS-int(mSynchronousMode))) {
3866b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                    ST_LOGE("dequeueBuffer: MIN_UNDEQUEUED_BUFFERS=%d exceeded "
3876b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                            "(dequeued=%d)",
3886b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                            MIN_UNDEQUEUED_BUFFERS-int(mSynchronousMode),
3896b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                            dequeuedCount);
3906b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                    return -EBUSY;
3916b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                }
3926b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            }
3936b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
394c2c1f2f24cd70bdcf1958157bab38467bf0fdc71Daniel Lam            // if no buffer is found, wait for a buffer to be released
395c2c1f2f24cd70bdcf1958157bab38467bf0fdc71Daniel Lam            tryAgain = found == INVALID_BUFFER_SLOT;
3966b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            if (tryAgain) {
3976b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                mDequeueCondition.wait(mMutex);
3986b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            }
3996b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        }
4006b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
4016b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
4026b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if (found == INVALID_BUFFER_SLOT) {
4036b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // This should not happen.
4046b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            ST_LOGE("dequeueBuffer: no available buffer slots");
4056b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            return -EBUSY;
4066b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        }
4076b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
4086b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        const int buf = found;
4096b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        *outBuf = found;
4106b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
411546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian        ATRACE_BUFFER_INDEX(buf);
412546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian
4136b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        const bool useDefaultSize = !w && !h;
4146b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if (useDefaultSize) {
4156b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // use the default size
4166b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            w = mDefaultWidth;
4176b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            h = mDefaultHeight;
4186b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        }
4196b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
4206b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        const bool updateFormat = (format != 0);
4216b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if (!updateFormat) {
4226b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // keep the current (or default) format
4236b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            format = mPixelFormat;
4246b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        }
4256b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
4266b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // buffer is now in DEQUEUED (but can also be current at the same time,
4276b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // if we're in synchronous mode)
4286b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mSlots[buf].mBufferState = BufferSlot::DEQUEUED;
4296b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
4306b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        const sp<GraphicBuffer>& buffer(mSlots[buf].mGraphicBuffer);
4316b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if ((buffer == NULL) ||
4326b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            (uint32_t(buffer->width)  != w) ||
4336b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            (uint32_t(buffer->height) != h) ||
4346b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            (uint32_t(buffer->format) != format) ||
4356b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            ((uint32_t(buffer->usage) & usage) != usage))
4366b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        {
4376b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            usage |= GraphicBuffer::USAGE_HW_TEXTURE;
4386b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            status_t error;
4396b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            sp<GraphicBuffer> graphicBuffer(
4406b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                    mGraphicBufferAlloc->createGraphicBuffer(
4416b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                            w, h, format, usage, &error));
4426b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            if (graphicBuffer == 0) {
4436b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                ST_LOGE("dequeueBuffer: SurfaceComposer::createGraphicBuffer "
4446b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                        "failed");
4456b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                return error;
4466b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            }
4476b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            if (updateFormat) {
4486b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                mPixelFormat = format;
4496b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            }
450eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
451eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            mSlots[buf].mAcquireCalled = false;
4526b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            mSlots[buf].mGraphicBuffer = graphicBuffer;
4536b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            mSlots[buf].mRequestBufferCalled = false;
4546b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            mSlots[buf].mFence = EGL_NO_SYNC_KHR;
455eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            mSlots[buf].mEglDisplay = EGL_NO_DISPLAY;
456eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
457eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
458eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
459eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
4606b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            returnFlags |= ISurfaceTexture::BUFFER_NEEDS_REALLOCATION;
4616b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        }
4626b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
4636b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        dpy = mSlots[buf].mEglDisplay;
4646b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        fence = mSlots[buf].mFence;
4656b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mSlots[buf].mFence = EGL_NO_SYNC_KHR;
466eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    }  // end lock scope
4676b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
4686b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (fence != EGL_NO_SYNC_KHR) {
4696b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        EGLint result = eglClientWaitSyncKHR(dpy, fence, 0, 1000000000);
4706b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // If something goes wrong, log the error, but return the buffer without
4716b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // synchronizing access to it.  It's too late at this point to abort the
4726b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // dequeue operation.
4736b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if (result == EGL_FALSE) {
4746b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            ALOGE("dequeueBuffer: error waiting for fence: %#x", eglGetError());
4756b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        } else if (result == EGL_TIMEOUT_EXPIRED_KHR) {
4766b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            ALOGE("dequeueBuffer: timeout waiting for fence");
4776b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        }
4786b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        eglDestroySyncKHR(dpy, fence);
479eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
4806b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
4816b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
4826b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ST_LOGV("dequeueBuffer: returning slot=%d buf=%p flags=%#x", *outBuf,
4836b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            mSlots[*outBuf].mGraphicBuffer->handle, returnFlags);
4846b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
4856b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    return returnFlags;
4866b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
4876b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
4886b091c53000c843211c218ce40287a7edca9bc63Daniel Lamstatus_t BufferQueue::setSynchronousMode(bool enabled) {
4891c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis    ATRACE_CALL();
4906b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ST_LOGV("setSynchronousMode: enabled=%d", enabled);
4916b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    Mutex::Autolock lock(mMutex);
4926b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
4936b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (mAbandoned) {
4946b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        ST_LOGE("setSynchronousMode: SurfaceTexture has been abandoned!");
4956b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return NO_INIT;
4966b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
4976b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
4986b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    status_t err = OK;
4996b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (!mAllowSynchronousMode && enabled)
5006b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return err;
5016b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
5026b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (!enabled) {
5036b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // going to asynchronous mode, drain the queue
5046b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        err = drainQueueLocked();
5056b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if (err != NO_ERROR)
5066b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            return err;
5076b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
5086b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
5096b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (mSynchronousMode != enabled) {
5106b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // - if we're going to asynchronous mode, the queue is guaranteed to be
5116b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // empty here
5126b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // - if the client set the number of buffers, we're guaranteed that
5136b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        // we have at least 3 (because we don't allow less)
5146b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mSynchronousMode = enabled;
51574ff8c23f44f1546d0c7004302f4c7ba726ff4c0Dave Burke        mDequeueCondition.broadcast();
5166b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
5176b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    return err;
5186b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
5196b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
5206b091c53000c843211c218ce40287a7edca9bc63Daniel Lamstatus_t BufferQueue::queueBuffer(int buf, int64_t timestamp,
5216b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        uint32_t* outWidth, uint32_t* outHeight, uint32_t* outTransform) {
5221c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis    ATRACE_CALL();
523546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian    ATRACE_BUFFER_INDEX(buf);
524546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian
5256b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ST_LOGV("queueBuffer: slot=%d time=%lld", buf, timestamp);
5266b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
527fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    sp<ConsumerListener> listener;
5286b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
5296b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    { // scope for the lock
5306b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        Mutex::Autolock lock(mMutex);
5316b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if (mAbandoned) {
5326b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            ST_LOGE("queueBuffer: SurfaceTexture has been abandoned!");
5336b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            return NO_INIT;
5346b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        }
5356b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if (buf < 0 || buf >= mBufferCount) {
5366b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            ST_LOGE("queueBuffer: slot index out of range [0, %d]: %d",
5376b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                    mBufferCount, buf);
5386b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            return -EINVAL;
5396b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        } else if (mSlots[buf].mBufferState != BufferSlot::DEQUEUED) {
5406b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            ST_LOGE("queueBuffer: slot %d is not owned by the client "
5416b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                    "(state=%d)", buf, mSlots[buf].mBufferState);
5426b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            return -EINVAL;
5436b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        } else if (!mSlots[buf].mRequestBufferCalled) {
5446b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            ST_LOGE("queueBuffer: slot %d was enqueued without requesting a "
5456b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                    "buffer", buf);
5466b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            return -EINVAL;
5476b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        }
5486b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
5496b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if (mSynchronousMode) {
5506b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // In synchronous mode we queue all buffers in a FIFO.
5516b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            mQueue.push_back(buf);
5526b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
5536b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // Synchronous mode always signals that an additional frame should
5546b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // be consumed.
555fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis            listener = mConsumerListener;
5566b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        } else {
5576b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            // In asynchronous mode we only keep the most recent buffer.
5586b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            if (mQueue.empty()) {
5596b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                mQueue.push_back(buf);
5606b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
5616b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                // Asynchronous mode only signals that a frame should be
5626b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                // consumed if no previous frame was pending. If a frame were
5636b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                // pending then the consumer would have already been notified.
564fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                listener = mConsumerListener;
5656b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            } else {
5666b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                Fifo::iterator front(mQueue.begin());
5676b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                // buffer currently queued is freed
5686b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                mSlots[*front].mBufferState = BufferSlot::FREE;
5696b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                // and we record the new buffer index in the queued list
5706b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                *front = buf;
5716b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            }
5726b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        }
5736b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
5746b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mSlots[buf].mBufferState = BufferSlot::QUEUED;
5756b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mSlots[buf].mCrop = mNextCrop;
5766b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mSlots[buf].mTransform = mNextTransform;
5776b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mSlots[buf].mScalingMode = mNextScalingMode;
5786b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mSlots[buf].mTimestamp = timestamp;
5796b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mFrameCounter++;
5806b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mSlots[buf].mFrameNumber = mFrameCounter;
5816b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
582eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        mBufferHasBeenQueued = true;
58374ff8c23f44f1546d0c7004302f4c7ba726ff4c0Dave Burke        mDequeueCondition.broadcast();
5846b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
5856b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        *outWidth = mDefaultWidth;
5866b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        *outHeight = mDefaultHeight;
587b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam        *outTransform = mTransformHint;
5881c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis
5891c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis        ATRACE_INT(mConsumerName.string(), mQueue.size());
5906b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    } // scope for the lock
5916b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
5926b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    // call back without lock held
5936b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (listener != 0) {
5946b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        listener->onFrameAvailable();
5956b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
5966b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    return OK;
5976b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
5986b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
5996b091c53000c843211c218ce40287a7edca9bc63Daniel Lamvoid BufferQueue::cancelBuffer(int buf) {
6001c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis    ATRACE_CALL();
6016b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ST_LOGV("cancelBuffer: slot=%d", buf);
6026b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    Mutex::Autolock lock(mMutex);
6036b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
6046b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (mAbandoned) {
6056b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        ST_LOGW("cancelBuffer: BufferQueue has been abandoned!");
6066b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return;
6076b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
6086b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
6096b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (buf < 0 || buf >= mBufferCount) {
6106b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        ST_LOGE("cancelBuffer: slot index out of range [0, %d]: %d",
6116b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                mBufferCount, buf);
6126b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return;
6136b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    } else if (mSlots[buf].mBufferState != BufferSlot::DEQUEUED) {
6146b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        ST_LOGE("cancelBuffer: slot %d is not owned by the client (state=%d)",
6156b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                buf, mSlots[buf].mBufferState);
6166b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return;
6176b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
6186b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mSlots[buf].mBufferState = BufferSlot::FREE;
6196b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mSlots[buf].mFrameNumber = 0;
62074ff8c23f44f1546d0c7004302f4c7ba726ff4c0Dave Burke    mDequeueCondition.broadcast();
6216b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
6226b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
6236b091c53000c843211c218ce40287a7edca9bc63Daniel Lamstatus_t BufferQueue::setCrop(const Rect& crop) {
6241c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis    ATRACE_CALL();
6256b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ST_LOGV("setCrop: crop=[%d,%d,%d,%d]", crop.left, crop.top, crop.right,
6266b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            crop.bottom);
6276b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
6286b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    Mutex::Autolock lock(mMutex);
6296b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (mAbandoned) {
6306b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        ST_LOGE("setCrop: BufferQueue has been abandoned!");
6316b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return NO_INIT;
6326b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
6336b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mNextCrop = crop;
6346b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    return OK;
6356b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
6366b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
6376b091c53000c843211c218ce40287a7edca9bc63Daniel Lamstatus_t BufferQueue::setTransform(uint32_t transform) {
6381c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis    ATRACE_CALL();
6396b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ST_LOGV("setTransform: xform=%#x", transform);
6406b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    Mutex::Autolock lock(mMutex);
6416b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (mAbandoned) {
6426b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        ST_LOGE("setTransform: BufferQueue has been abandoned!");
6436b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return NO_INIT;
6446b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
6456b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mNextTransform = transform;
6466b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    return OK;
6476b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
6486b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
6496b091c53000c843211c218ce40287a7edca9bc63Daniel Lamstatus_t BufferQueue::setScalingMode(int mode) {
6501c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis    ATRACE_CALL();
6516b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ST_LOGV("setScalingMode: mode=%d", mode);
6526b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
6536b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    switch (mode) {
6546b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        case NATIVE_WINDOW_SCALING_MODE_FREEZE:
6556b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        case NATIVE_WINDOW_SCALING_MODE_SCALE_TO_WINDOW:
6566b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            break;
6576b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        default:
6586b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            ST_LOGE("unknown scaling mode: %d", mode);
6596b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            return BAD_VALUE;
6606b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
6616b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
6626b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    Mutex::Autolock lock(mMutex);
6636b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mNextScalingMode = mode;
6646b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    return OK;
6656b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
6666b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
6676b091c53000c843211c218ce40287a7edca9bc63Daniel Lamstatus_t BufferQueue::connect(int api,
6686b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        uint32_t* outWidth, uint32_t* outHeight, uint32_t* outTransform) {
6691c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis    ATRACE_CALL();
6706b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ST_LOGV("connect: api=%d", api);
6716b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    Mutex::Autolock lock(mMutex);
6726b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
6736b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (mAbandoned) {
6746b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        ST_LOGE("connect: BufferQueue has been abandoned!");
6756b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        return NO_INIT;
6766b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
6776b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
678fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    if (mConsumerListener == NULL) {
679fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        ST_LOGE("connect: BufferQueue has no consumer!");
680fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        return NO_INIT;
681fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    }
682fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
6836b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    int err = NO_ERROR;
6846b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    switch (api) {
6856b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        case NATIVE_WINDOW_API_EGL:
6866b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        case NATIVE_WINDOW_API_CPU:
6876b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        case NATIVE_WINDOW_API_MEDIA:
6886b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        case NATIVE_WINDOW_API_CAMERA:
6896b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            if (mConnectedApi != NO_CONNECTED_API) {
6906b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                ST_LOGE("connect: already connected (cur=%d, req=%d)",
6916b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                        mConnectedApi, api);
6926b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                err = -EINVAL;
6936b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            } else {
6946b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                mConnectedApi = api;
6956b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                *outWidth = mDefaultWidth;
6966b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                *outHeight = mDefaultHeight;
6976b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                *outTransform = 0;
6986b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            }
6996b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            break;
7006b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        default:
7016b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            err = -EINVAL;
7026b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            break;
7036b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
704eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
705eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    mBufferHasBeenQueued = false;
706eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
7076b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    return err;
7086b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
7096b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
7106b091c53000c843211c218ce40287a7edca9bc63Daniel Lamstatus_t BufferQueue::disconnect(int api) {
7111c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis    ATRACE_CALL();
7126b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ST_LOGV("disconnect: api=%d", api);
7136b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
7146b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    int err = NO_ERROR;
715fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    sp<ConsumerListener> listener;
716fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
717fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    { // Scope for the lock
718fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        Mutex::Autolock lock(mMutex);
719fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
720fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        if (mAbandoned) {
721fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis            // it is not really an error to disconnect after the surface
722fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis            // has been abandoned, it should just be a no-op.
723fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis            return NO_ERROR;
724fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        }
725fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
726fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        switch (api) {
727fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis            case NATIVE_WINDOW_API_EGL:
728fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis            case NATIVE_WINDOW_API_CPU:
729fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis            case NATIVE_WINDOW_API_MEDIA:
730fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis            case NATIVE_WINDOW_API_CAMERA:
731fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                if (mConnectedApi == api) {
732fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                    drainQueueAndFreeBuffersLocked();
733fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                    mConnectedApi = NO_CONNECTED_API;
734fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                    mNextCrop.makeInvalid();
735fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                    mNextScalingMode = NATIVE_WINDOW_SCALING_MODE_FREEZE;
736fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                    mNextTransform = 0;
737fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                    mDequeueCondition.broadcast();
738fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                    listener = mConsumerListener;
739fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                } else {
740fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                    ST_LOGE("disconnect: connected to another api (cur=%d, req=%d)",
741fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                            mConnectedApi, api);
742fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                    err = -EINVAL;
743fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                }
744fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                break;
745fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis            default:
746fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                ST_LOGE("disconnect: unknown API %d", api);
7476b091c53000c843211c218ce40287a7edca9bc63Daniel Lam                err = -EINVAL;
748fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis                break;
749fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        }
7506b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
751fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
752fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    if (listener != NULL) {
753fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        listener->onBuffersReleased();
754fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    }
755fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
7566b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    return err;
7576b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
7586b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
759eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lamvoid BufferQueue::dump(String8& result) const
760eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam{
761eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    char buffer[1024];
762eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    BufferQueue::dump(result, "", buffer, 1024);
763eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam}
764eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
765eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lamvoid BufferQueue::dump(String8& result, const char* prefix,
766eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        char* buffer, size_t SIZE) const
767eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam{
768eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    Mutex::Autolock _l(mMutex);
769eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    snprintf(buffer, SIZE,
770eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            "%snext   : {crop=[%d,%d,%d,%d], transform=0x%02x}\n"
771eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            ,prefix, mNextCrop.left, mNextCrop.top, mNextCrop.right,
772eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            mNextCrop.bottom, mNextTransform
773eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    );
774eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    result.append(buffer);
775eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
776eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    String8 fifo;
777eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    int fifoSize = 0;
778eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    Fifo::const_iterator i(mQueue.begin());
779eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    while (i != mQueue.end()) {
780eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam       snprintf(buffer, SIZE, "%02d ", *i++);
781eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam       fifoSize++;
782eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam       fifo.append(buffer);
783eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    }
784eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
785eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    snprintf(buffer, SIZE,
786eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            "%s-BufferQueue mBufferCount=%d, mSynchronousMode=%d, default-size=[%dx%d], "
787eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            "mPixelFormat=%d, FIFO(%d)={%s}\n",
788eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            prefix, mBufferCount, mSynchronousMode, mDefaultWidth,
789eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            mDefaultHeight, mPixelFormat, fifoSize, fifo.string());
790eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    result.append(buffer);
791eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
792eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
793eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    struct {
794eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        const char * operator()(int state) const {
795eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            switch (state) {
796eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                case BufferSlot::DEQUEUED: return "DEQUEUED";
797eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                case BufferSlot::QUEUED: return "QUEUED";
798eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                case BufferSlot::FREE: return "FREE";
799eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                case BufferSlot::ACQUIRED: return "ACQUIRED";
800eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                default: return "Unknown";
801eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            }
802eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        }
803eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    } stateName;
804eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
805eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    for (int i=0 ; i<mBufferCount ; i++) {
806eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        const BufferSlot& slot(mSlots[i]);
807eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        snprintf(buffer, SIZE,
808eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                "%s%s[%02d] "
809eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                "state=%-8s, crop=[%d,%d,%d,%d], "
810eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                "transform=0x%02x, timestamp=%lld",
811eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                prefix, (slot.mBufferState == BufferSlot::ACQUIRED)?">":" ", i,
812eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                stateName(slot.mBufferState),
813eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                slot.mCrop.left, slot.mCrop.top, slot.mCrop.right,
814eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                slot.mCrop.bottom, slot.mTransform, slot.mTimestamp
815eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        );
816eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        result.append(buffer);
817eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
818eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        const sp<GraphicBuffer>& buf(slot.mGraphicBuffer);
819eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        if (buf != NULL) {
820eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            snprintf(buffer, SIZE,
821eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                    ", %p [%4ux%4u:%4u,%3X]",
822eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                    buf->handle, buf->width, buf->height, buf->stride,
823eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                    buf->format);
824eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            result.append(buffer);
825eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        }
826eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        result.append("\n");
827eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    }
828eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam}
829eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
8306b091c53000c843211c218ce40287a7edca9bc63Daniel Lamvoid BufferQueue::freeBufferLocked(int i) {
8316b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mSlots[i].mGraphicBuffer = 0;
8326b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mSlots[i].mBufferState = BufferSlot::FREE;
8336b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    mSlots[i].mFrameNumber = 0;
834eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    mSlots[i].mAcquireCalled = false;
835eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
836eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    // destroy fence as BufferQueue now takes ownership
837eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    if (mSlots[i].mFence != EGL_NO_SYNC_KHR) {
838eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        eglDestroySyncKHR(mSlots[i].mEglDisplay, mSlots[i].mFence);
839eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        mSlots[i].mFence = EGL_NO_SYNC_KHR;
8406b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
8416b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
8426b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
8436b091c53000c843211c218ce40287a7edca9bc63Daniel Lamvoid BufferQueue::freeAllBuffersLocked() {
8446b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ALOGW_IF(!mQueue.isEmpty(),
8456b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            "freeAllBuffersLocked called but mQueue is not empty");
846eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    mQueue.clear();
847eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    mBufferHasBeenQueued = false;
8486b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    for (int i = 0; i < NUM_BUFFER_SLOTS; i++) {
8496b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        freeBufferLocked(i);
8506b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
8516b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
8526b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
853fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennisstatus_t BufferQueue::acquireBuffer(BufferItem *buffer) {
854546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian    ATRACE_CALL();
855eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    Mutex::Autolock _l(mMutex);
856eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    // check if queue is empty
857eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    // In asynchronous mode the list is guaranteed to be one buffer
858eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    // deep, while in synchronous mode we use the oldest buffer.
859eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    if (!mQueue.empty()) {
860eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        Fifo::iterator front(mQueue.begin());
861eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        int buf = *front;
862eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
863546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian        ATRACE_BUFFER_INDEX(buf);
864546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian
865eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        if (mSlots[buf].mAcquireCalled) {
866eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            buffer->mGraphicBuffer = NULL;
867fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        } else {
868eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            buffer->mGraphicBuffer = mSlots[buf].mGraphicBuffer;
869eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        }
870eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        buffer->mCrop = mSlots[buf].mCrop;
871eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        buffer->mTransform = mSlots[buf].mTransform;
872eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        buffer->mScalingMode = mSlots[buf].mScalingMode;
873eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        buffer->mFrameNumber = mSlots[buf].mFrameNumber;
8743fcee50ffaeb745819356e395408b4d7e3239c13Daniel Lam        buffer->mTimestamp = mSlots[buf].mTimestamp;
875eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        buffer->mBuf = buf;
876eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        mSlots[buf].mAcquireCalled = true;
877eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
878eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        mSlots[buf].mBufferState = BufferSlot::ACQUIRED;
879eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        mQueue.erase(front);
88074ff8c23f44f1546d0c7004302f4c7ba726ff4c0Dave Burke        mDequeueCondition.broadcast();
8811c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis
8821c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis        ATRACE_INT(mConsumerName.string(), mQueue.size());
883fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    } else {
884b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam        // should be a better return code?
885b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam        return -EINVAL;
886eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    }
887eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
888eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    return OK;
889eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam}
890eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
891eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lamstatus_t BufferQueue::releaseBuffer(int buf, EGLDisplay display,
892eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        EGLSyncKHR fence) {
893546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian    ATRACE_CALL();
894546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian    ATRACE_BUFFER_INDEX(buf);
895546ed2d7d98ce4f1415647913a231a6b4fc6ca66Mathias Agopian
896eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    Mutex::Autolock _l(mMutex);
897eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
898eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    if (buf == INVALID_BUFFER_SLOT) {
899eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        return -EINVAL;
900eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    }
901eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
902eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    mSlots[buf].mEglDisplay = display;
903eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    mSlots[buf].mFence = fence;
904eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
905eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    // The current buffer becomes FREE if it was still in the queued
906eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    // state. If it has already been given to the client
907eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    // (synchronous mode), then it stays in DEQUEUED state.
908eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    if (mSlots[buf].mBufferState == BufferSlot::QUEUED
909eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam            || mSlots[buf].mBufferState == BufferSlot::ACQUIRED) {
910eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        mSlots[buf].mBufferState = BufferSlot::FREE;
911eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    }
91274ff8c23f44f1546d0c7004302f4c7ba726ff4c0Dave Burke    mDequeueCondition.broadcast();
913eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
914eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    return OK;
915eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam}
916eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
917fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennisstatus_t BufferQueue::consumerConnect(const sp<ConsumerListener>& consumerListener) {
918fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    ST_LOGV("consumerConnect");
919fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    Mutex::Autolock lock(mMutex);
920fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
921fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    if (mAbandoned) {
922fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        ST_LOGE("consumerConnect: BufferQueue has been abandoned!");
923fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        return NO_INIT;
924fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    }
925fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
926fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    mConsumerListener = consumerListener;
927fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
928fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    return OK;
929fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis}
930fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
931eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lamstatus_t BufferQueue::consumerDisconnect() {
932fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    ST_LOGV("consumerDisconnect");
933eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    Mutex::Autolock lock(mMutex);
934b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam
935fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    if (mConsumerListener == NULL) {
936fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        ST_LOGE("consumerDisconnect: No consumer is connected!");
937fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        return -EINVAL;
938fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    }
939b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam
940fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    mAbandoned = true;
941fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    mConsumerListener = NULL;
942b267579ba8dfe3f47d2a481c5a3c2254e3d565a1Daniel Lam    mQueue.clear();
943eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    freeAllBuffersLocked();
94474ff8c23f44f1546d0c7004302f4c7ba726ff4c0Dave Burke    mDequeueCondition.broadcast();
945eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    return OK;
946eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam}
947eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
948fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennisstatus_t BufferQueue::getReleasedBuffers(uint32_t* slotMask) {
949fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    ST_LOGV("getReleasedBuffers");
950fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    Mutex::Autolock lock(mMutex);
951fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
952fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    if (mAbandoned) {
953fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        ST_LOGE("getReleasedBuffers: BufferQueue has been abandoned!");
954fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        return NO_INIT;
955fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    }
956fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
957fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    uint32_t mask = 0;
958fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    for (int i = 0; i < NUM_BUFFER_SLOTS; i++) {
959fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        if (!mSlots[i].mAcquireCalled) {
960fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis            mask |= 1 << i;
961fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        }
962fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    }
963fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    *slotMask = mask;
964fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
965fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    ST_LOGV("getReleasedBuffers: returning mask %#x", mask);
966fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    return NO_ERROR;
967fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis}
968fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
969eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lamstatus_t BufferQueue::setDefaultBufferSize(uint32_t w, uint32_t h)
970eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam{
971eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    ST_LOGV("setDefaultBufferSize: w=%d, h=%d", w, h);
972eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    if (!w || !h) {
973eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        ST_LOGE("setDefaultBufferSize: dimensions cannot be 0 (w=%d, h=%d)",
974eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam                w, h);
975eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam        return BAD_VALUE;
976eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    }
977eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
978eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    Mutex::Autolock lock(mMutex);
979eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    mDefaultWidth = w;
980eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    mDefaultHeight = h;
981eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    return OK;
982eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam}
983eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
984eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lamstatus_t BufferQueue::setBufferCountServer(int bufferCount) {
9851c8e95cf86f2182986385bc1ee85f13f425f3a3aJamie Gennis    ATRACE_CALL();
986eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    Mutex::Autolock lock(mMutex);
987eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    return setBufferCountServerLocked(bufferCount);
988eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam}
989eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam
9906b091c53000c843211c218ce40287a7edca9bc63Daniel Lamvoid BufferQueue::freeAllBuffersExceptHeadLocked() {
9916b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    ALOGW_IF(!mQueue.isEmpty(),
9926b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            "freeAllBuffersExceptCurrentLocked called but mQueue is not empty");
9936b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    int head = -1;
9946b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (!mQueue.empty()) {
9956b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        Fifo::iterator front(mQueue.begin());
9966b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        head = *front;
9976b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
998eae59d2ea77ef57aab203fb185a880ce37ac38d6Daniel Lam    mBufferHasBeenQueued = false;
9996b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    for (int i = 0; i < NUM_BUFFER_SLOTS; i++) {
10006b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if (i != head) {
10016b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            freeBufferLocked(i);
10026b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        }
10036b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
10046b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
10056b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
10066b091c53000c843211c218ce40287a7edca9bc63Daniel Lamstatus_t BufferQueue::drainQueueLocked() {
10076b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    while (mSynchronousMode && !mQueue.isEmpty()) {
10086b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        mDequeueCondition.wait(mMutex);
10096b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if (mAbandoned) {
10106b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            ST_LOGE("drainQueueLocked: BufferQueue has been abandoned!");
10116b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            return NO_INIT;
10126b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        }
10136b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if (mConnectedApi == NO_CONNECTED_API) {
10146b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            ST_LOGE("drainQueueLocked: BufferQueue is not connected!");
10156b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            return NO_INIT;
10166b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        }
10176b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
10186b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    return NO_ERROR;
10196b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
10206b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
10216b091c53000c843211c218ce40287a7edca9bc63Daniel Lamstatus_t BufferQueue::drainQueueAndFreeBuffersLocked() {
10226b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    status_t err = drainQueueLocked();
10236b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    if (err == NO_ERROR) {
10246b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        if (mSynchronousMode) {
10256b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            freeAllBuffersLocked();
10266b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        } else {
10276b091c53000c843211c218ce40287a7edca9bc63Daniel Lam            freeAllBuffersExceptHeadLocked();
10286b091c53000c843211c218ce40287a7edca9bc63Daniel Lam        }
10296b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    }
10306b091c53000c843211c218ce40287a7edca9bc63Daniel Lam    return err;
10316b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}
10326b091c53000c843211c218ce40287a7edca9bc63Daniel Lam
1033fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie GennisBufferQueue::ProxyConsumerListener::ProxyConsumerListener(
1034fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        const wp<BufferQueue::ConsumerListener>& consumerListener):
1035fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        mConsumerListener(consumerListener) {}
1036fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
1037fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie GennisBufferQueue::ProxyConsumerListener::~ProxyConsumerListener() {}
1038fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
1039fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennisvoid BufferQueue::ProxyConsumerListener::onFrameAvailable() {
1040fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    sp<BufferQueue::ConsumerListener> listener(mConsumerListener.promote());
1041fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    if (listener != NULL) {
1042fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        listener->onFrameAvailable();
1043fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    }
1044fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis}
1045fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
1046fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennisvoid BufferQueue::ProxyConsumerListener::onBuffersReleased() {
1047fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    sp<BufferQueue::ConsumerListener> listener(mConsumerListener.promote());
1048fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    if (listener != NULL) {
1049fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis        listener->onBuffersReleased();
1050fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis    }
1051fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis}
1052fa5b40ebb8923133df12dc70591bfe35b3f1c9b3Jamie Gennis
10536b091c53000c843211c218ce40287a7edca9bc63Daniel Lam}; // namespace android
1054