146         std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in connect()
150             status = mBufferPool.mObserver.open(id, fmqDescPtr);  in connect()
155                 mBufferPool.mConnectionIds.insert(id);  in connect()
163         mBufferPool.processStatusMessages();  in connect()
164         mBufferPool.cleanUp();  in connect()
170     std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in close()
171     mBufferPool.processStatusMessages();  in close()
172     mBufferPool.handleClose(connectionId);  in close()
173     mBufferPool.mObserver.close(connectionId);  in close()
176     mBufferPool.cleanUp(true);  in close()
183     std::unique_lock<std::mutex> lock(mBufferPool.mMutex);  in allocate()
184     mBufferPool.processStatusMessages();  in allocate()
186     if (!mBufferPool.getFreeBuffer(mAllocator, params, bufferId, handle)) {  in allocate()
193             status = mBufferPool.addNewBuffer(alloc, allocSize, params, bufferId, handle);  in allocate()
200         mBufferPool.handleOwnBuffer(connectionId, *bufferId);  in allocate()
202     mBufferPool.cleanUp();  in allocate()
209     std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in fetch()
210     mBufferPool.processStatusMessages();  in fetch()
211     auto found = mBufferPool.mTransactions.find(transactionId);  in fetch()
212     if (found != mBufferPool.mTransactions.end() &&  in fetch()
213             contains(&mBufferPool.mPendingTransactions,  in fetch()
219             auto bufferIt = mBufferPool.mBuffers.find(bufferId);  in fetch()
220             if (bufferIt != mBufferPool.mBuffers.end()) {  in fetch()
221                 mBufferPool.mStats.onBufferFetched();  in fetch()
227     mBufferPool.cleanUp();  in fetch()
233     std::lock_guard<std::mutex> lock(mBufferPool.mMutex);  in cleanUp()
234     mBufferPool.processStatusMessages();  in cleanUp()
235     mBufferPool.cleanUp(clearCache);  in cleanUp()