169         std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in connect()
173             status = mBufferPool.mObserver.open(id, statusDescPtr);  in connect()
178                 *pMsgId = mBufferPool.mInvalidation.mInvalidationId;  in connect()
179                 mBufferPool.mConnectionIds.insert(id);  in connect()
180                 mBufferPool.mInvalidationChannel.getDesc(invDescPtr);  in connect()
181                 mBufferPool.mInvalidation.onConnect(id, observer);  in connect()
190         mBufferPool.processStatusMessages();  in connect()
191         mBufferPool.cleanUp();  in connect()
198     std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in close()
199     ALOGV("connection close %lld: %u", (long long)connectionId, mBufferPool.mInvalidation.mId);  in close()
200     mBufferPool.processStatusMessages();  in close()
201     mBufferPool.handleClose(connectionId);  in close()
202     mBufferPool.mObserver.close(connectionId);  in close()
203     mBufferPool.mInvalidation.onClose(connectionId);  in close()
206     mBufferPool.cleanUp(true);  in close()
214     std::unique_lock<std::mutex> lock(mBufferPool.mMutex);  in allocate()
215     mBufferPool.processStatusMessages();  in allocate()
217     if (!mBufferPool.getFreeBuffer(mAllocator, params, bufferId, handle)) {  in allocate()
224             status = mBufferPool.addNewBuffer(alloc, allocSize, params, bufferId, handle);  in allocate()
231         mBufferPool.handleOwnBuffer(connectionId, *bufferId);  in allocate()
233     mBufferPool.cleanUp();  in allocate()
241     std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in fetch()
242     mBufferPool.processStatusMessages();  in fetch()
243     auto found = mBufferPool.mTransactions.find(transactionId);  in fetch()
244     if (found != mBufferPool.mTransactions.end() &&  in fetch()
245             contains(&mBufferPool.mPendingTransactions,  in fetch()
251             auto bufferIt = mBufferPool.mBuffers.find(bufferId);  in fetch()
252             if (bufferIt != mBufferPool.mBuffers.end()) {  in fetch()
253                 mBufferPool.mStats.onBufferFetched();  in fetch()
259     mBufferPool.cleanUp();  in fetch()
266     std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in cleanUp()
267     mBufferPool.processStatusMessages();  in cleanUp()
268     mBufferPool.cleanUp(clearCache);  in cleanUp()
272     std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in flush()
273     mBufferPool.processStatusMessages();  in flush()
274     mBufferPool.flush(shared_from_this());  in flush()
281         std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in handleInvalidateAck()
282         mBufferPool.processStatusMessages();  in handleInvalidateAck()
283         mBufferPool.mInvalidation.onHandleAck(&observers, &invalidationId);  in handleInvalidateAck()
302     return mBufferPool.isValid();  in isValid()