Lines Matching refs:mActive
110 } mActive; member in aidl::android::hardware::media::bufferpool2::implementation::ClientManager::Impl
129 std::lock_guard<std::mutex> lock(mActive.mMutex); in registerSender()
131 if (mActive.mClients.find(pRegistration->connectionId) in registerSender()
132 != mActive.mClients.end()) { in registerSender()
162 std::lock_guard<std::mutex> lock(mActive.mMutex); in registerSender()
163 mActive.mClients.insert(std::make_pair(conId, client)); in registerSender()
188 std::lock_guard<std::mutex> lock(mActive.mMutex); in registerSender()
189 auto it = mActive.mClients.find(senderId); in registerSender()
190 if (it == mActive.mClients.end()) { in registerSender()
242 std::lock_guard<std::mutex> lock(mActive.mMutex); in create()
243 mActive.mClients.insert(std::make_pair(conId, client)); in create()
253 std::unique_lock<std::mutex> lock2(mActive.mMutex); in close()
254 auto it = mActive.mClients.find(connectionId); in close()
255 if (it != mActive.mClients.end()) { in close()
259 mActive.mClients.erase(connectionId); in close()
280 std::lock_guard<std::mutex> lock(mActive.mMutex); in flush()
281 auto it = mActive.mClients.find(connectionId); in flush()
282 if (it == mActive.mClients.end()) { in flush()
295 std::lock_guard<std::mutex> lock(mActive.mMutex); in allocate()
296 auto it = mActive.mClients.find(connectionId); in allocate()
297 if (it == mActive.mClients.end()) { in allocate()
325 std::lock_guard<std::mutex> lock(mActive.mMutex); in receive()
326 auto it = mActive.mClients.find(connectionId); in receive()
327 if (it == mActive.mClients.end()) { in receive()
356 std::lock_guard<std::mutex> lock(mActive.mMutex); in postSend()
357 auto it = mActive.mClients.find(connectionId); in postSend()
358 if (it == mActive.mClients.end()) { in postSend()
370 std::lock_guard<std::mutex> lock(mActive.mMutex); in getAccessor()
371 auto it = mActive.mClients.find(connectionId); in getAccessor()
372 if (it == mActive.mClients.end()) { in getAccessor()
385 std::lock_guard<std::mutex> lock2(mActive.mMutex); in cleanUp()
387 for (auto it = mActive.mClients.begin(); it != mActive.mClients.end();) { in cleanUp()
392 it = mActive.mClients.erase(it); in cleanUp()