BufferQueueCore.h revision 399184a4cd728ea1421fb0bc1722274a29e38f4a
1/* 2 * Copyright 2014 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#ifndef ANDROID_GUI_BUFFERQUEUECORE_H 18#define ANDROID_GUI_BUFFERQUEUECORE_H 19 20#include <gui/BufferQueueDefs.h> 21#include <gui/BufferSlot.h> 22 23#include <utils/Condition.h> 24#include <utils/Mutex.h> 25#include <utils/NativeHandle.h> 26#include <utils/RefBase.h> 27#include <utils/String8.h> 28#include <utils/StrongPointer.h> 29#include <utils/Trace.h> 30#include <utils/Vector.h> 31 32#define BQ_LOGV(x, ...) ALOGV("[%s] "x, mConsumerName.string(), ##__VA_ARGS__) 33#define BQ_LOGD(x, ...) ALOGD("[%s] "x, mConsumerName.string(), ##__VA_ARGS__) 34#define BQ_LOGI(x, ...) ALOGI("[%s] "x, mConsumerName.string(), ##__VA_ARGS__) 35#define BQ_LOGW(x, ...) ALOGW("[%s] "x, mConsumerName.string(), ##__VA_ARGS__) 36#define BQ_LOGE(x, ...) ALOGE("[%s] "x, mConsumerName.string(), ##__VA_ARGS__) 37 38#define ATRACE_BUFFER_INDEX(index) \ 39 if (ATRACE_ENABLED()) { \ 40 char ___traceBuf[1024]; \ 41 snprintf(___traceBuf, 1024, "%s: %d", \ 42 mCore->mConsumerName.string(), (index)); \ 43 android::ScopedTrace ___bufTracer(ATRACE_TAG, ___traceBuf); \ 44 } 45 46namespace android { 47 48class BufferItem; 49class IBinder; 50class IConsumerListener; 51class IGraphicBufferAlloc; 52 53class BufferQueueCore : public virtual RefBase { 54 55 friend class BufferQueueProducer; 56 friend class BufferQueueConsumer; 57 58public: 59 // Used as a placeholder slot number when the value isn't pointing to an 60 // existing buffer. 61 enum { INVALID_BUFFER_SLOT = -1 }; // TODO: Extract from IGBC::BufferItem 62 63 // We reserve two slots in order to guarantee that the producer and 64 // consumer can run asynchronously. 65 enum { MAX_MAX_ACQUIRED_BUFFERS = BufferQueueDefs::NUM_BUFFER_SLOTS - 2 }; 66 67 // The default API number used to indicate that no producer is connected 68 enum { NO_CONNECTED_API = 0 }; 69 70 typedef Vector<BufferItem> Fifo; 71 72 // BufferQueueCore manages a pool of gralloc memory slots to be used by 73 // producers and consumers. allocator is used to allocate all the needed 74 // gralloc buffers. 75 BufferQueueCore(const sp<IGraphicBufferAlloc>& allocator = NULL); 76 virtual ~BufferQueueCore(); 77 78private: 79 // Dump our state in a string 80 void dump(String8& result, const char* prefix) const; 81 82 // getMinUndequeuedBufferCountLocked returns the minimum number of buffers 83 // that must remain in a state other than DEQUEUED. The async parameter 84 // tells whether we're in asynchronous mode. 85 int getMinUndequeuedBufferCountLocked(bool async) const; 86 87 // getMinMaxBufferCountLocked returns the minimum number of buffers allowed 88 // given the current BufferQueue state. The async parameter tells whether 89 // we're in asynchonous mode. 90 int getMinMaxBufferCountLocked(bool async) const; 91 92 // getMaxBufferCountLocked returns the maximum number of buffers that can be 93 // allocated at once. This value depends on the following member variables: 94 // 95 // mDequeueBufferCannotBlock 96 // mMaxAcquiredBufferCount 97 // mDefaultMaxBufferCount 98 // mOverrideMaxBufferCount 99 // async parameter 100 // 101 // Any time one of these member variables is changed while a producer is 102 // connected, mDequeueCondition must be broadcast. 103 int getMaxBufferCountLocked(bool async) const; 104 105 // setDefaultMaxBufferCountLocked sets the maximum number of buffer slots 106 // that will be used if the producer does not override the buffer slot 107 // count. The count must be between 2 and NUM_BUFFER_SLOTS, inclusive. The 108 // initial default is 2. 109 status_t setDefaultMaxBufferCountLocked(int count); 110 111 // freeBufferLocked frees the GraphicBuffer and sync resources for the 112 // given slot. 113 void freeBufferLocked(int slot); 114 115 // freeAllBuffersLocked frees the GraphicBuffer and sync resources for 116 // all slots. 117 void freeAllBuffersLocked(); 118 119 // stillTracking returns true iff the buffer item is still being tracked 120 // in one of the slots. 121 bool stillTracking(const BufferItem* item) const; 122 123 // mAllocator is the connection to SurfaceFlinger that is used to allocate 124 // new GraphicBuffer objects. 125 sp<IGraphicBufferAlloc> mAllocator; 126 127 // mMutex is the mutex used to prevent concurrent access to the member 128 // variables of BufferQueueCore objects. It must be locked whenever any 129 // member variable is accessed. 130 mutable Mutex mMutex; 131 132 // mIsAbandoned indicates that the BufferQueue will no longer be used to 133 // consume image buffers pushed to it using the IGraphicBufferProducer 134 // interface. It is initialized to false, and set to true in the 135 // consumerDisconnect method. A BufferQueue that is abandoned will return 136 // the NO_INIT error from all IGraphicBufferProducer methods capable of 137 // returning an error. 138 bool mIsAbandoned; 139 140 // mConsumerControlledByApp indicates whether the connected consumer is 141 // controlled by the application. 142 bool mConsumerControlledByApp; 143 144 // mConsumerName is a string used to identify the BufferQueue in log 145 // messages. It is set by the IGraphicBufferConsumer::setConsumerName 146 // method. 147 String8 mConsumerName; 148 149 // mConsumerListener is used to notify the connected consumer of 150 // asynchronous events that it may wish to react to. It is initially 151 // set to NULL and is written by consumerConnect and consumerDisconnect. 152 sp<IConsumerListener> mConsumerListener; 153 154 // mConsumerUsageBits contains flags that the consumer wants for 155 // GraphicBuffers. 156 uint32_t mConsumerUsageBits; 157 158 // mConnectedApi indicates the producer API that is currently connected 159 // to this BufferQueue. It defaults to NO_CONNECTED_API, and gets updated 160 // by the connect and disconnect methods. 161 int mConnectedApi; 162 163 // mConnectedProducerToken is used to set a binder death notification on 164 // the producer. 165 sp<IBinder> mConnectedProducerToken; 166 167 // mSlots is an array of buffer slots that must be mirrored on the producer 168 // side. This allows buffer ownership to be transferred between the producer 169 // and consumer without sending a GraphicBuffer over Binder. The entire 170 // array is initialized to NULL at construction time, and buffers are 171 // allocated for a slot when requestBuffer is called with that slot's index. 172 BufferQueueDefs::SlotsType mSlots; 173 174 // mQueue is a FIFO of queued buffers used in synchronous mode. 175 Fifo mQueue; 176 177 // mOverrideMaxBufferCount is the limit on the number of buffers that will 178 // be allocated at one time. This value is set by the producer by calling 179 // setBufferCount. The default is 0, which means that the producer doesn't 180 // care about the number of buffers in the pool. In that case, 181 // mDefaultMaxBufferCount is used as the limit. 182 int mOverrideMaxBufferCount; 183 184 // mDequeueCondition is a condition variable used for dequeueBuffer in 185 // synchronous mode. 186 mutable Condition mDequeueCondition; 187 188 // mUseAsyncBuffer indicates whether an extra buffer is used in async mode 189 // to prevent dequeueBuffer from blocking. 190 bool mUseAsyncBuffer; 191 192 // mDequeueBufferCannotBlock indicates whether dequeueBuffer is allowed to 193 // block. This flag is set during connect when both the producer and 194 // consumer are controlled by the application. 195 bool mDequeueBufferCannotBlock; 196 197 // mDefaultBufferFormat can be set so it will override the buffer format 198 // when it isn't specified in dequeueBuffer. 199 uint32_t mDefaultBufferFormat; 200 201 // mDefaultWidth holds the default width of allocated buffers. It is used 202 // in dequeueBuffer if a width and height of 0 are specified. 203 int mDefaultWidth; 204 205 // mDefaultHeight holds the default height of allocated buffers. It is used 206 // in dequeueBuffer if a width and height of 0 are specified. 207 int mDefaultHeight; 208 209 // mDefaultMaxBufferCount is the default limit on the number of buffers that 210 // will be allocated at one time. This default limit is set by the consumer. 211 // The limit (as opposed to the default limit) may be overriden by the 212 // producer. 213 int mDefaultMaxBufferCount; 214 215 // mMaxAcquiredBufferCount is the number of buffers that the consumer may 216 // acquire at one time. It defaults to 1, and can be changed by the consumer 217 // via setMaxAcquiredBufferCount, but this may only be done while no 218 // producer is connected to the BufferQueue. This value is used to derive 219 // the value returned for the MIN_UNDEQUEUED_BUFFERS query to the producer. 220 int mMaxAcquiredBufferCount; 221 222 // mBufferHasBeenQueued is true once a buffer has been queued. It is reset 223 // when something causes all buffers to be freed (e.g., changing the buffer 224 // count). 225 bool mBufferHasBeenQueued; 226 227 // mFrameCounter is the free running counter, incremented on every 228 // successful queueBuffer call and buffer allocation. 229 uint64_t mFrameCounter; 230 231 // mTransformHint is used to optimize for screen rotations. 232 uint32_t mTransformHint; 233 234 // mSidebandStream is a handle to the sideband buffer stream, if any 235 sp<NativeHandle> mSidebandStream; 236 237}; // class BufferQueueCore 238 239} // namespace android 240 241#endif 242