Lines Matching refs:message
73 TransactionStatus(const BufferStatusMessage &message, int64_t timestampUs) { in TransactionStatus()
74 mId = message.transactionId; in TransactionStatus()
75 mBufferId = message.bufferId; in TransactionStatus()
76 mStatus = message.newStatus; in TransactionStatus()
79 mSender = message.connectionId; in TransactionStatus()
80 mReceiver = message.targetConnectionId; in TransactionStatus()
84 mReceiver = message.connectionId; in TransactionStatus()
287 bool Accessor::Impl::BufferPool::handleTransferTo(const BufferStatusMessage &message) { in handleTransferTo() argument
289 message.transactionId); in handleTransferTo()
296 auto bufferIter = mBuffers.find(message.bufferId); in handleTransferTo()
298 !contains(&mUsingBuffers, message.connectionId, message.bufferId)) { in handleTransferTo()
301 auto found = mTransactions.find(message.transactionId); in handleTransferTo()
304 found->second->mSender = message.connectionId; in handleTransferTo()
311 message.transactionId, in handleTransferTo()
312 std::make_unique<TransactionStatus>(message, mTimestampUs))); in handleTransferTo()
313 insert(&mPendingTransactions, message.targetConnectionId, in handleTransferTo()
314 message.transactionId); in handleTransferTo()
319 bool Accessor::Impl::BufferPool::handleTransferFrom(const BufferStatusMessage &message) { in handleTransferFrom() argument
320 auto found = mTransactions.find(message.transactionId); in handleTransferFrom()
325 message.transactionId, in handleTransferFrom()
326 std::make_unique<TransactionStatus>(message, mTimestampUs))); in handleTransferFrom()
327 insert(&mPendingTransactions, message.connectionId, in handleTransferFrom()
328 message.transactionId); in handleTransferFrom()
329 auto bufferIter = mBuffers.find(message.bufferId); in handleTransferFrom()
332 if (message.connectionId == found->second->mReceiver) { in handleTransferFrom()
339 bool Accessor::Impl::BufferPool::handleTransferResult(const BufferStatusMessage &message) { in handleTransferResult() argument
340 auto found = mTransactions.find(message.transactionId); in handleTransferResult()
342 bool deleted = erase(&mPendingTransactions, message.connectionId, in handleTransferResult()
343 message.transactionId); in handleTransferResult()
346 mCompletedTransactions.insert(message.transactionId); in handleTransferResult()
348 auto bufferIter = mBuffers.find(message.bufferId); in handleTransferResult()
349 if (message.newStatus == BufferStatus::TRANSFER_OK) { in handleTransferResult()
350 handleOwnBuffer(message.connectionId, message.bufferId); in handleTransferResult()
356 mFreeBuffers.insert(message.bufferId); in handleTransferResult()
360 ALOGV("transfer finished %llu %u - %d", (unsigned long long)message.transactionId, in handleTransferResult()
361 message.bufferId, deleted); in handleTransferResult()
364 ALOGV("transfer not found %llu %u", (unsigned long long)message.transactionId, in handleTransferResult()
365 message.bufferId); in handleTransferResult()
373 for (BufferStatusMessage& message: messages) { in processStatusMessages()
375 switch (message.newStatus) { in processStatusMessages()
378 message.connectionId, message.bufferId); in processStatusMessages()
384 ret = handleTransferTo(message); in processStatusMessages()
387 ret = handleTransferFrom(message); in processStatusMessages()
400 ret = handleTransferResult(message); in processStatusMessages()
405 message.newStatus, (long long)message.connectionId); in processStatusMessages()