| /aosp12/packages/apps/Camera2/src/com/android/camera/async/ |
| H A D | CountableBufferQueue.java | 44 private final ConcurrentBufferQueue<T> mBufferQueue; field in CountableBufferQueue
57 mBufferQueue = new ConcurrentBufferQueue<T>(new DecrementingProcessor<T>(processor)); in CountableBufferQueue()
83 T result = mBufferQueue.getNext(); in getNext()
91 T result = mBufferQueue.getNext(timeout, unit); in getNext()
98 return mBufferQueue.peekNext(); in peekNext()
103 mBufferQueue.discardNext(); in discardNext()
118 mBufferQueue.update(element); in update()
128 mBufferQueue.close(); in close()
133 return mBufferQueue.isClosed(); in isClosed()
|
| /aosp12/frameworks/av/media/libstagefright/httplive/ |
| H A D | LiveDataSource.cpp | 54 return mBufferQueue.size(); in countQueuedBuffers()
67 for (List<sp<ABuffer> >::iterator it = mBufferQueue.begin(); in readAtNonBlocking()
68 it != mBufferQueue.end(); ++it) { in readAtNonBlocking()
99 while (mBufferQueue.empty() && mFinalResult == OK) { in readAt_l()
103 if (mBufferQueue.empty()) { in readAt_l()
112 sp<ABuffer> buffer = *mBufferQueue.begin(); in readAt_l()
127 mBufferQueue.erase(mBufferQueue.begin()); in readAt_l()
150 mBufferQueue.push_back(buffer); in queueBuffer()
170 mBufferQueue.clear(); in reset()
|
| H A D | LiveDataSource.h | 52 List<sp<ABuffer> > mBufferQueue; member
|
| /aosp12/frameworks/wilhelm/src/itf/ |
| H A D | IOutputMixExt.cpp | 70 if (audioPlayer->mBufferQueue.mClearRequested) { in track_check()
73 audioPlayer->mBufferQueue.mFront = &audioPlayer->mBufferQueue.mArray[0]; in track_check()
74 audioPlayer->mBufferQueue.mRear = &audioPlayer->mBufferQueue.mArray[0]; in track_check()
75 audioPlayer->mBufferQueue.mState.count = 0; in track_check()
76 audioPlayer->mBufferQueue.mState.playIndex = 0; in track_check()
108 oldFront = audioPlayer->mBufferQueue.mFront; in track_check()
109 if (oldFront != audioPlayer->mBufferQueue.mRear) { in track_check()
110 assert(0 < audioPlayer->mBufferQueue.mState.count); in track_check()
135 oldFront = audioPlayer->mBufferQueue.mFront; in track_check()
136 if (oldFront != audioPlayer->mBufferQueue.mRear) { in track_check()
[all …]
|
| H A D | IEngine.cpp | 28 ap->mBufferQueue.mArray = ap->mBufferQueue.mTypical; in initializeBufferQueueMembers()
33 if (ap->mBufferQueue.mNumBuffers >= 256) { in initializeBufferQueueMembers()
36 ap->mBufferQueue.mArray = (BufferHeader *) in initializeBufferQueueMembers()
38 if (NULL == ap->mBufferQueue.mArray) { in initializeBufferQueueMembers()
42 ap->mBufferQueue.mFront = ap->mBufferQueue.mArray; in initializeBufferQueueMembers()
43 ap->mBufferQueue.mRear = ap->mBufferQueue.mArray; in initializeBufferQueueMembers()
501 thiz->mBufferQueue.mNumBuffers = in IEngine_CreateAudioRecorder()
505 thiz->mBufferQueue.mArray = thiz->mBufferQueue.mTypical; in IEngine_CreateAudioRecorder()
514 thiz->mBufferQueue.mArray = (BufferHeader *) malloc((thiz->mBufferQueue. in IEngine_CreateAudioRecorder()
521 thiz->mBufferQueue.mFront = thiz->mBufferQueue.mArray; in IEngine_CreateAudioRecorder()
[all …]
|
| H A D | IPlay.cpp | 59 if ((NULL != audioPlayer) && (audioPlayer->mBufferQueue.mFront != in IPlay_SetPlayState()
60 audioPlayer->mBufferQueue.mRear)) { in IPlay_SetPlayState()
|
| /aosp12/packages/services/Car/tests/CarEvsCameraPreviewApp/src/com/google/android/car/evs/ |
| H A D | CarEvsCameraPreviewActivity.java | 52 private final ArrayList<CarEvsBufferDescriptor> mBufferQueue = new ArrayList<>(); field in CarEvsCameraPreviewActivity
96 synchronized (mBufferQueue) {
97 mBufferQueue.add(buffer);
265 synchronized (mBufferQueue) { in onDestroy()
266 mBufferQueue.clear(); in onDestroy()
313 synchronized (mBufferQueue) { in handleVideoStreamLocked()
314 mBufferQueue.clear(); in handleVideoStreamLocked()
339 synchronized (mBufferQueue) { in getNewFrame()
340 if (mBufferQueue.isEmpty()) { in getNewFrame()
346 CarEvsBufferDescriptor newFrame = mBufferQueue.get(0); in getNewFrame()
[all …]
|
| /aosp12/frameworks/wilhelm/src/android/ |
| H A D | AudioRecorder_to_android.cpp | 328 interface_lock_exclusive(&ar->mBufferQueue); in audioRecorder_callback()
330 if (ar->mBufferQueue.mState.count != 0) { in audioRecorder_callback()
331 assert(ar->mBufferQueue.mFront != ar->mBufferQueue.mRear); in audioRecorder_callback()
349 ar->mBufferQueue.mSizeConsumed = 0; in audioRecorder_callback()
350 if (newFront == &ar->mBufferQueue.mArray[ar->mBufferQueue.mNumBuffers + 1]) { in audioRecorder_callback()
351 newFront = ar->mBufferQueue.mArray; in audioRecorder_callback()
353 ar->mBufferQueue.mFront = newFront; in audioRecorder_callback()
355 ar->mBufferQueue.mState.count--; in audioRecorder_callback()
356 ar->mBufferQueue.mState.playIndex++; in audioRecorder_callback()
360 callback = ar->mBufferQueue.mCallback; in audioRecorder_callback()
[all …]
|
| H A D | AudioPlayer_to_android.cpp | 161 if (ap->mBufferQueue.mState.count != 0) { in adecoder_writeToBufferQueue()
162 assert(ap->mBufferQueue.mFront != ap->mBufferQueue.mRear); in adecoder_writeToBufferQueue()
170 ap->mBufferQueue.mSizeConsumed += size; in adecoder_writeToBufferQueue()
179 ap->mBufferQueue.mSizeConsumed = 0; in adecoder_writeToBufferQueue()
180 if (newFront == &ap->mBufferQueue.mArray[ap->mBufferQueue.mNumBuffers + 1]) { in adecoder_writeToBufferQueue()
181 newFront = ap->mBufferQueue.mArray; in adecoder_writeToBufferQueue()
183 ap->mBufferQueue.mFront = newFront; in adecoder_writeToBufferQueue()
185 ap->mBufferQueue.mState.count--; in adecoder_writeToBufferQueue()
186 ap->mBufferQueue.mState.playIndex++; in adecoder_writeToBufferQueue()
191 callback = ap->mBufferQueue.mCallback; in adecoder_writeToBufferQueue()
[all …]
|
| /aosp12/frameworks/av/cmds/stagefright/ |
| H A D | stream.cpp | 153 List<size_t> mBufferQueue; member
224 while (mBufferQueue.empty()) { in writeData()
228 mCurrentBufferIndex = *mBufferQueue.begin(); in writeData()
231 mBufferQueue.erase(mBufferQueue.begin()); in writeData()
261 mBufferQueue.push_back(index); in onBufferAvailable()
|
| /aosp12/frameworks/wilhelm/src/desktop/ |
| H A D | SndFile.cpp | 171 thiz->mBufferQueue.mNumBuffers = SndFile_NUMBUFS; in SndFile_checkAudioPlayerSourceSink()
194 SLboolean empty = 0 == audioPlayer->mBufferQueue.mState.count; in audioPlayerTransportUpdate()
214 IBufferQueue_Clear(&audioPlayer->mBufferQueue.mItf); in audioPlayerTransportUpdate()
229 SndFile_Callback(&audioPlayer->mBufferQueue.mItf, audioPlayer); in audioPlayerTransportUpdate()
256 SLBufferQueueItf bufferQueue = &thiz->mBufferQueue.mItf; in SndFile_Realize()
|
| H A D | OutputMixExt.h | 38 struct BufferQueue_interface *mBufferQueue; member
|
| /aosp12/frameworks/wilhelm/src/ |
| H A D | classes.h | 43 IBufferQueue mBufferQueue; member
145 IBufferQueue mBufferQueue; member
255 IBufferQueue mBufferQueue; member
|
| H A D | data.cpp | 56 pDataLocator->mBufferQueue = *(SLDataLocator_BufferQueue *)pLocator; in checkDataLocator()
58 if (!((1 <= pDataLocator->mBufferQueue.numBuffers) && in checkDataLocator()
59 (pDataLocator->mBufferQueue.numBuffers <= 255))) { in checkDataLocator()
60 SL_LOGE("%s: numBuffers=%u", name, pDataLocator->mBufferQueue.numBuffers); in checkDataLocator()
232 if (!((1 <= pDataLocator->mBufferQueue.numBuffers) && in checkDataLocator()
233 (pDataLocator->mBufferQueue.numBuffers <= 255))) { in checkDataLocator()
|
| H A D | classes.cpp | 64 {MPH_BUFFERQUEUE, INTERFACE_EXPLICIT, offsetof(CAudioPlayer, mBufferQueue)},
127 {MPH_ANDROIDSIMPLEBUFFERQUEUE, INTERFACE_EXPLICIT, offsetof(CAudioRecorder, mBufferQueue)},
299 {MPH_BUFFERQUEUE, INTERFACE_EXPLICIT_GAME, offsetof(CMidiPlayer, mBufferQueue)},
|
| H A D | data.h | 25 SLDataLocator_BufferQueue mBufferQueue; member
|
| /aosp12/frameworks/av/media/libstagefright/ |
| H A D | MediaCodecSource.cpp | 413 while (output->mBufferQueue.size() == 0 && !output->mEncoderReachedEOS) { in read()
417 *buffer = *output->mBufferQueue.begin(); in read()
418 output->mBufferQueue.erase(output->mBufferQueue.begin()); in read()
656 for (List<MediaBufferBase*>::iterator it = output->mBufferQueue.begin(); in signalEOS()
657 it != output->mBufferQueue.end(); it++) { in signalEOS()
660 output->mBufferQueue.clear(); in signalEOS()
1010 output->mBufferQueue.push_back(mbuf); in onMessageReceived()
|
| /aosp12/frameworks/av/services/audioflinger/ |
| H A D | Tracks.cpp | 1964 if (mBufferQueue.size()) { in write()
1965 pInBuffer = mBufferQueue.itemAt(0); in write()
2011 if (mBufferQueue.size()) { in write()
2012 mBufferQueue.removeAt(0); in write()
2019 (int)mThreadIoHandle, mBufferQueue.size()); in write()
2030 if (mBufferQueue.size() < kMaxOverFlowBuffers) { in write()
2036 mBufferQueue.add(pInBuffer); in write()
2051 if (frames == 0 && mBufferQueue.size() == 0 && mActive) { in write()
2089 size_t size = mBufferQueue.size(); in clearBufferQueue()
2092 Buffer *pBuffer = mBufferQueue.itemAt(i); in clearBufferQueue()
[all …]
|
| H A D | PlaybackTracks.h | 374 bool bufferQueueEmpty() const { return mBufferQueue.size() == 0; } in bufferQueueEmpty()
404 Vector < Buffer* > mBufferQueue; variable
|
| /aosp12/frameworks/av/media/libstagefright/include/media/stagefright/ |
| H A D | MediaCodecSource.h | 155 List<MediaBufferBase*> mBufferQueue; member
|
| /aosp12/frameworks/av/media/codec2/vndk/ |
| H A D | C2AllocatorGralloc.cpp | 849 const bool mBufferQueue; member in android::C2AllocatorGralloc::Impl
861 : mInit(C2_OK), mBufferQueue(bufferQueue) { in Impl()
894 0, 0, mBufferQueue ? ~0 : 0), in newGraphicAllocation()
|