Lines Matching refs:seq

241                         mConsumeTimes.emplace(mMsg.header.seq, systemTime(SYSTEM_TIME_MONOTONIC));  in consume()
243 mMsg.header.seq); in consume()
246 ATRACE_ASYNC_BEGIN(mProcessingTraceTag.c_str(), /*cookie=*/mMsg.header.seq); in consume()
269 *outSeq = mMsg.header.seq; in consume()
293 sendFinishedSignal(msg.header.seq, false); in consume()
332 *outSeq = mMsg.header.seq; in consume()
355 *outSeq = mMsg.header.seq; in consume()
365 *outSeq = mMsg.header.seq; in consume()
375 *outSeq = mMsg.header.seq; in consume()
385 *outSeq = mMsg.header.seq; in consume()
443 seqChain.seq = msg.header.seq; in consumeSamples()
450 chain = msg.header.seq; in consumeSamples()
702 status_t InputConsumer::sendFinishedSignal(uint32_t seq, bool handled) { in sendFinishedSignal() argument
705 mChannel->getName().c_str(), seq, toString(handled)); in sendFinishedSignal()
707 if (!seq) { in sendFinishedSignal()
715 uint32_t currentSeq = seq; in sendFinishedSignal()
721 if (seqChain.seq == currentSeq) { in sendFinishedSignal()
736 seqChain.seq = chainIndex != 0 ? chainSeqs[chainIndex - 1] : seq; in sendFinishedSignal()
747 return sendUnchainedFinishedSignal(seq, handled); in sendFinishedSignal()
761 msg.header.seq = 0; in sendTimeline()
767 nsecs_t InputConsumer::getConsumeTime(uint32_t seq) const { in getConsumeTime()
768 auto it = mConsumeTimes.find(seq); in getConsumeTime()
772 seq); in getConsumeTime()
776 void InputConsumer::popConsumeTime(uint32_t seq) { in popConsumeTime() argument
777 mConsumeTimes.erase(seq); in popConsumeTime()
780 status_t InputConsumer::sendUnchainedFinishedSignal(uint32_t seq, bool handled) { in sendUnchainedFinishedSignal() argument
783 msg.header.seq = seq; in sendUnchainedFinishedSignal()
785 msg.body.finished.consumeTime = getConsumeTime(seq); in sendUnchainedFinishedSignal()
791 popConsumeTime(seq); in sendUnchainedFinishedSignal()
794 ATRACE_ASYNC_END(mProcessingTraceTag.c_str(), /*cookie=*/seq); in sendUnchainedFinishedSignal()
874 out += android::base::StringPrintf(" Message %" PRIu32 ": %s ", msg.header.seq, in dump()
945 out += android::base::StringPrintf(" chain: seq = %" PRIu32 " chain=%" PRIu32, chain.seq, in dump()
952 for (const auto& [seq, consumeTime] : mConsumeTimes) { in dump()
953 out += android::base::StringPrintf(" seq = %" PRIu32 " consumeTime = %" PRId64, seq, in dump()