600             entry.mNotifyConsumed = notify;  in onMessageReceived()
995             entry->mNotifyConsumed->post();  in fillAudioBuffer()
1043         if ((entry->mBuffer == nullptr && entry->mNotifyConsumed == nullptr)  in drainAudioQueueUntilLastEOS()
1044                 || (entry->mNotifyConsumed->findInt32("eos", &eos) && eos != 0)) {  in drainAudioQueueUntilLastEOS()
1054                 if (it->mNotifyConsumed == nullptr) {  in drainAudioQueueUntilLastEOS()
1059                     onChangeAudioFormat(it->mMeta, it->mNotifyConsumed);  in drainAudioQueueUntilLastEOS()
1062                 it->mNotifyConsumed->post();  in drainAudioQueueUntilLastEOS()
1113             if (entry->mNotifyConsumed != nullptr) {  in onDrainAudioQueue()
1115                 onChangeAudioFormat(entry->mMeta, entry->mNotifyConsumed);  in onDrainAudioQueue()
1185             entry->mNotifyConsumed->post();  in onDrainAudioQueue()
1478     entry->mNotifyConsumed->setInt64("timestampNs", realTimeUs * 1000LL);  in onDrainVideoQueue()
1479     entry->mNotifyConsumed->setInt32("render", !tooLate);  in onDrainVideoQueue()
1480     entry->mNotifyConsumed->post();  in onDrainVideoQueue()
1580     entry.mNotifyConsumed = notifyConsumed;  in onQueueBuffer()
1623         (*mAudioQueue.begin()).mNotifyConsumed->post();  in onQueueBuffer()
1782             entry->mNotifyConsumed->post();  in flushQueue()
1783         } else if (entry->mNotifyConsumed != nullptr) {  in flushQueue()
1785             onChangeAudioFormat(entry->mMeta, entry->mNotifyConsumed);  in flushQueue()