215 bool BufferPool::handleTransferTo(const BufferStatusMessage &message) {  in handleTransferTo()  argument
217             message.transactionId);  in handleTransferTo()
224     auto bufferIter = mBuffers.find(message.bufferId);  in handleTransferTo()
226             !contains(&mUsingBuffers, message.connectionId, FromAidl(message.bufferId))) {  in handleTransferTo()
229     auto found = mTransactions.find(message.transactionId);  in handleTransferTo()
232         found->second->mSender = message.connectionId;  in handleTransferTo()
236     if (mConnectionIds.find(message.targetConnectionId) == mConnectionIds.end()) {  in handleTransferTo()
239               this, (long long)message.targetConnectionId);  in handleTransferTo()
244             message.transactionId,  in handleTransferTo()
245             std::make_unique<TransactionStatus>(message, mTimestampMs)));  in handleTransferTo()
246     insert(&mPendingTransactions, message.targetConnectionId,  in handleTransferTo()
247            FromAidl(message.transactionId));  in handleTransferTo()
252 bool BufferPool::handleTransferFrom(const BufferStatusMessage &message) {  in handleTransferFrom()  argument
253     auto found = mTransactions.find(message.transactionId);  in handleTransferFrom()
258                 message.transactionId,  in handleTransferFrom()
259                 std::make_unique<TransactionStatus>(message, mTimestampMs)));  in handleTransferFrom()
260         insert(&mPendingTransactions, message.connectionId,  in handleTransferFrom()
261                FromAidl(message.transactionId));  in handleTransferFrom()
262         auto bufferIter = mBuffers.find(message.bufferId);  in handleTransferFrom()
265         if (message.connectionId == found->second->mReceiver) {  in handleTransferFrom()
272 bool BufferPool::handleTransferResult(const BufferStatusMessage &message) {  in handleTransferResult()  argument
273     auto found = mTransactions.find(message.transactionId);  in handleTransferResult()
275         bool deleted = erase(&mPendingTransactions, message.connectionId,  in handleTransferResult()
276                              FromAidl(message.transactionId));  in handleTransferResult()
279                 mCompletedTransactions.insert(message.transactionId);  in handleTransferResult()
281             auto bufferIter = mBuffers.find(message.bufferId);  in handleTransferResult()
282             if (message.status == BufferStatus::TRANSFER_OK) {  in handleTransferResult()
283                 handleOwnBuffer(message.connectionId, message.bufferId);  in handleTransferResult()
290                     mFreeBuffers.insert(message.bufferId);  in handleTransferResult()
295                     mInvalidation.onBufferInvalidated(message.bufferId, mInvalidationChannel);  in handleTransferResult()
300         ALOGV("transfer finished %llu %u - %d", (unsigned long long)message.transactionId,  in handleTransferResult()
301               message.bufferId, deleted);  in handleTransferResult()
304     ALOGV("transfer not found %llu %u", (unsigned long long)message.transactionId,  in handleTransferResult()
305           message.bufferId);  in handleTransferResult()
313     for (BufferStatusMessage& message: messages) {  in processStatusMessages()
315         switch (message.status) {  in processStatusMessages()
318                         message.connectionId, message.bufferId);  in processStatusMessages()
324                 ret = handleTransferTo(message);  in processStatusMessages()
327                 ret = handleTransferFrom(message);  in processStatusMessages()
340                 ret = handleTransferResult(message);  in processStatusMessages()
343                 mInvalidation.onAck(message.connectionId, message.bufferId);  in processStatusMessages()
349                   message.status, (long long)message.connectionId);  in processStatusMessages()