Lines Matching refs:mNotifyConsumed
529 entry.mNotifyConsumed = notify; in onMessageReceived()
892 entry->mNotifyConsumed->post(); in fillAudioBuffer()
940 if ((entry->mBuffer == nullptr && entry->mNotifyConsumed == nullptr) in drainAudioQueueUntilLastEOS()
941 || (entry->mNotifyConsumed->findInt32("eos", &eos) && eos != 0)) { in drainAudioQueueUntilLastEOS()
951 if (it->mNotifyConsumed == nullptr) { in drainAudioQueueUntilLastEOS()
956 onChangeAudioFormat(it->mMeta, it->mNotifyConsumed); in drainAudioQueueUntilLastEOS()
959 it->mNotifyConsumed->post(); in drainAudioQueueUntilLastEOS()
1010 if (entry->mNotifyConsumed != nullptr) { in onDrainAudioQueue()
1012 onChangeAudioFormat(entry->mMeta, entry->mNotifyConsumed); in onDrainAudioQueue()
1082 entry->mNotifyConsumed->post(); in onDrainAudioQueue()
1370 entry->mNotifyConsumed->setInt64("timestampNs", realTimeUs * 1000ll); in onDrainVideoQueue()
1371 entry->mNotifyConsumed->setInt32("render", !tooLate); in onDrainVideoQueue()
1372 entry->mNotifyConsumed->post(); in onDrainVideoQueue()
1463 entry.mNotifyConsumed = notifyConsumed; in onQueueBuffer()
1506 (*mAudioQueue.begin()).mNotifyConsumed->post(); in onQueueBuffer()
1652 entry->mNotifyConsumed->post(); in flushQueue()
1653 } else if (entry->mNotifyConsumed != nullptr) { in flushQueue()
1655 onChangeAudioFormat(entry->mMeta, entry->mNotifyConsumed); in flushQueue()