Lines Matching refs:mNotifyConsumed
528 entry.mNotifyConsumed = notify; in onMessageReceived()
891 entry->mNotifyConsumed->post(); in fillAudioBuffer()
939 if ((entry->mBuffer == nullptr && entry->mNotifyConsumed == nullptr) in drainAudioQueueUntilLastEOS()
940 || (entry->mNotifyConsumed->findInt32("eos", &eos) && eos != 0)) { in drainAudioQueueUntilLastEOS()
950 if (it->mNotifyConsumed == nullptr) { in drainAudioQueueUntilLastEOS()
955 onChangeAudioFormat(it->mMeta, it->mNotifyConsumed); in drainAudioQueueUntilLastEOS()
958 it->mNotifyConsumed->post(); in drainAudioQueueUntilLastEOS()
1009 if (entry->mNotifyConsumed != nullptr) { in onDrainAudioQueue()
1011 onChangeAudioFormat(entry->mMeta, entry->mNotifyConsumed); in onDrainAudioQueue()
1081 entry->mNotifyConsumed->post(); in onDrainAudioQueue()
1369 entry->mNotifyConsumed->setInt64("timestampNs", realTimeUs * 1000ll); in onDrainVideoQueue()
1370 entry->mNotifyConsumed->setInt32("render", !tooLate); in onDrainVideoQueue()
1371 entry->mNotifyConsumed->post(); in onDrainVideoQueue()
1462 entry.mNotifyConsumed = notifyConsumed; in onQueueBuffer()
1505 (*mAudioQueue.begin()).mNotifyConsumed->post(); in onQueueBuffer()
1658 entry->mNotifyConsumed->post(); in flushQueue()
1659 } else if (entry->mNotifyConsumed != nullptr) { in flushQueue()
1661 onChangeAudioFormat(entry->mMeta, entry->mNotifyConsumed); in flushQueue()