Lines Matching refs:it

88     auto it = mAcks.find(conId);  in onAck()  local
89 if (it == mAcks.end()) { in onAck()
93 if (isMessageLater(msgId, it->second)) { in onAck()
101 for (auto it = mPendings.begin(); it != mPendings.end();) { in onBufferInvalidated() local
102 if (it->isInvalidated(bufferId)) { in onBufferInvalidated()
104 if (it->mNeedsAck) { in onBufferInvalidated()
111 channel.postInvalidation(msgId, it->mFrom, it->mTo); in onBufferInvalidated()
112 it = mPendings.erase(it); in onBufferInvalidated()
115 ++it; in onBufferInvalidated()
151 for (auto it = mAcks.begin(); it != mAcks.end(); ++it) { in onHandleAck() local
152 if (it->second != mInvalidationId) { in onHandleAck()
153 const std::shared_ptr<IObserver> observer = mObservers[it->first]; in onHandleAck()
155 observers->emplace(it->first, observer); in onHandleAck()
157 (long long)it->first, it->second, mInvalidationId); in onHandleAck()
160 it->second = mInvalidationId; in onHandleAck()
162 ALOGV("bufferpool2 observer died %lld", (long long)it->first); in onHandleAck()
163 deads.insert(it->first); in onHandleAck()
168 for (auto it = deads.begin(); it != deads.end(); ++it) { in onHandleAck() local
169 onClose(*it); in onHandleAck()
486 auto it = mBuffers.find(*freeIt); in cleanUp() local
487 if (it != mBuffers.end() && in cleanUp()
488 it->second->mOwnerCount == 0 && it->second->mTransactionCount == 0) { in cleanUp()
489 mStats.onBufferEvicted(it->second->mAllocSize); in cleanUp()
490 mBuffers.erase(it); in cleanUp()
505 auto it = mBuffers.find(*freeIt); in invalidate() local
506 if (it != mBuffers.end() && in invalidate()
507 it->second->mOwnerCount == 0 && it->second->mTransactionCount == 0) { in invalidate()
508 mStats.onBufferEvicted(it->second->mAllocSize); in invalidate()
509 mBuffers.erase(it); in invalidate()
520 for (auto it = mBuffers.begin(); it != mBuffers.end(); ++it) { in invalidate() local
521 if (isBufferInRange(from, to, it->first)) { in invalidate()
522 it->second->invalidate(); in invalidate()