93     if (isMessageLater(msgId, it->second)) {  in onAck()
152             if (it->second != mInvalidationId) {  in onHandleAck()
157                           (long long)it->first, it->second, mInvalidationId);  in onHandleAck()
160                     it->second = mInvalidationId;  in onHandleAck()
185         iter->second->mOwnerCount++;  in handleOwnBuffer()
196         iter->second->mOwnerCount--;  in handleReleaseBuffer()
197         if (iter->second->mOwnerCount == 0 &&  in handleReleaseBuffer()
198                 iter->second->mTransactionCount == 0) {  in handleReleaseBuffer()
199             if (!iter->second->mInvalidated) {  in handleReleaseBuffer()
200                 mStats.onBufferUnused(iter->second->mAllocSize);  in handleReleaseBuffer()
203                 mStats.onBufferUnused(iter->second->mAllocSize);  in handleReleaseBuffer()
204                 mStats.onBufferEvicted(iter->second->mAllocSize);  in handleReleaseBuffer()
232         found->second->mSender = message.connectionId;  in handleTransferTo()
233         found->second->mSenderValidated = true;  in handleTransferTo()
248     bufferIter->second->mTransactionCount++;  in handleTransferTo()
263         bufferIter->second->mTransactionCount++;  in handleTransferFrom()
265         if (message.connectionId == found->second->mReceiver) {  in handleTransferFrom()
266             found->second->mStatus = BufferStatus::TRANSFER_FROM;  in handleTransferFrom()
278             if (!found->second->mSenderValidated) {  in handleTransferResult()
285             bufferIter->second->mTransactionCount--;  in handleTransferResult()
286             if (bufferIter->second->mOwnerCount == 0  in handleTransferResult()
287                 && bufferIter->second->mTransactionCount == 0) {  in handleTransferResult()
288                 if (!bufferIter->second->mInvalidated) {  in handleTransferResult()
289                     mStats.onBufferUnused(bufferIter->second->mAllocSize);  in handleTransferResult()
292                     mStats.onBufferUnused(bufferIter->second->mAllocSize);  in handleTransferResult()
293                     mStats.onBufferEvicted(bufferIter->second->mAllocSize);  in handleTransferResult()
359         for (const BufferId& bufferId : buffers->second) {  in handleClose()
363                 bufferIter->second->mOwnerCount--;  in handleClose()
364                 if (bufferIter->second->mOwnerCount == 0 &&  in handleClose()
365                         bufferIter->second->mTransactionCount == 0) {  in handleClose()
367                     if (!bufferIter->second->mInvalidated) {  in handleClose()
368                         mStats.onBufferUnused(bufferIter->second->mAllocSize);  in handleClose()
371                         mStats.onBufferUnused(bufferIter->second->mAllocSize);  in handleClose()
372                         mStats.onBufferEvicted(bufferIter->second->mAllocSize);  in handleClose()
385         for (const TransactionId& transactionId : pending->second) {  in handleClose()
388                 if (!iter->second->mSenderValidated) {  in handleClose()
391                 BufferId bufferId = iter->second->mBufferId;  in handleClose()
393                 bufferIter->second->mTransactionCount--;  in handleClose()
394                 if (bufferIter->second->mOwnerCount == 0 &&  in handleClose()
395                     bufferIter->second->mTransactionCount == 0) {  in handleClose()
397                     if (!bufferIter->second->mInvalidated) {  in handleClose()
398                         mStats.onBufferUnused(bufferIter->second->mAllocSize);  in handleClose()
401                         mStats.onBufferUnused(bufferIter->second->mAllocSize);  in handleClose()
402                         mStats.onBufferEvicted(bufferIter->second->mAllocSize);  in handleClose()
455         if (res.second) {  in addNewBuffer()
488                     it->second->mOwnerCount == 0 && it->second->mTransactionCount == 0) {  in cleanUp()
489                 mStats.onBufferEvicted(it->second->mAllocSize);  in cleanUp()
507                 it->second->mOwnerCount == 0 && it->second->mTransactionCount == 0) {  in invalidate()
508                 mStats.onBufferEvicted(it->second->mAllocSize);  in invalidate()
522             it->second->invalidate();  in invalidate()