192     return mBufferPool.isValid();  in isValid()
196     std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in flush()
197     mBufferPool.processStatusMessages();  in flush()
198     mBufferPool.flush(ref<Accessor>());  in flush()
206     std::unique_lock<std::mutex> lock(mBufferPool.mMutex);  in allocate()
207     mBufferPool.processStatusMessages();  in allocate()
209     if (!mBufferPool.getFreeBuffer(mAllocator, params, bufferId, handle)) {  in allocate()
216             status = mBufferPool.addNewBuffer(alloc, allocSize, params, bufferId, handle);  in allocate()
223         mBufferPool.handleOwnBuffer(connectionId, *bufferId);  in allocate()
225     mBufferPool.cleanUp();  in allocate()
233     std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in fetch()
234     mBufferPool.processStatusMessages();  in fetch()
235     auto found = mBufferPool.mTransactions.find(transactionId);  in fetch()
236     if (found != mBufferPool.mTransactions.end() &&  in fetch()
237             contains(&mBufferPool.mPendingTransactions,  in fetch()
243             auto bufferIt = mBufferPool.mBuffers.find(bufferId);  in fetch()
244             if (bufferIt != mBufferPool.mBuffers.end()) {  in fetch()
245                 mBufferPool.mStats.onBufferFetched();  in fetch()
251     mBufferPool.cleanUp();  in fetch()
266         std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in connect()
270             status = mBufferPool.mObserver.open(id, statusDescPtr);  in connect()
275                 *pMsgId = mBufferPool.mInvalidation.mInvalidationId;  in connect()
276                 mBufferPool.mConnectionIds.insert(id);  in connect()
277                 mBufferPool.mInvalidationChannel.getDesc(invDescPtr);  in connect()
278                 mBufferPool.mInvalidation.onConnect(id, observer);  in connect()
282         mBufferPool.processStatusMessages();  in connect()
283         mBufferPool.cleanUp();  in connect()
295         std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in close()
296         ALOGV("connection close %lld: %u", (long long)connectionId, mBufferPool.mInvalidation.mId);  in close()
297         mBufferPool.processStatusMessages();  in close()
298         mBufferPool.handleClose(connectionId);  in close()
299         mBufferPool.mObserver.close(connectionId);  in close()
300         mBufferPool.mInvalidation.onClose(connectionId);  in close()
303         mBufferPool.cleanUp(true);  in close()
312     std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in cleanUp()
313     mBufferPool.processStatusMessages();  in cleanUp()
314     mBufferPool.cleanUp(clearCache);  in cleanUp()
321         std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in handleInvalidateAck()
322         mBufferPool.processStatusMessages();  in handleInvalidateAck()
323         mBufferPool.mInvalidation.onHandleAck(&observers, &invalidationId);  in handleInvalidateAck()