540             entry.mNotifyConsumed = notify;  in onMessageReceived()
903             entry->mNotifyConsumed->post();  in fillAudioBuffer()
951         if ((entry->mBuffer == nullptr && entry->mNotifyConsumed == nullptr)  in drainAudioQueueUntilLastEOS()
952                 || (entry->mNotifyConsumed->findInt32("eos", &eos) && eos != 0)) {  in drainAudioQueueUntilLastEOS()
962                 if (it->mNotifyConsumed == nullptr) {  in drainAudioQueueUntilLastEOS()
967                     onChangeAudioFormat(it->mMeta, it->mNotifyConsumed);  in drainAudioQueueUntilLastEOS()
970                 it->mNotifyConsumed->post();  in drainAudioQueueUntilLastEOS()
1021             if (entry->mNotifyConsumed != nullptr) {  in onDrainAudioQueue()
1023                 onChangeAudioFormat(entry->mMeta, entry->mNotifyConsumed);  in onDrainAudioQueue()
1093             entry->mNotifyConsumed->post();  in onDrainAudioQueue()
1380     entry->mNotifyConsumed->setInt64("timestampNs", realTimeUs * 1000LL);  in onDrainVideoQueue()
1381     entry->mNotifyConsumed->setInt32("render", !tooLate);  in onDrainVideoQueue()
1382     entry->mNotifyConsumed->post();  in onDrainVideoQueue()
1480     entry.mNotifyConsumed = notifyConsumed;  in onQueueBuffer()
1523         (*mAudioQueue.begin()).mNotifyConsumed->post();  in onQueueBuffer()
1685             entry->mNotifyConsumed->post();  in flushQueue()
1686         } else if (entry->mNotifyConsumed != nullptr) {  in flushQueue()
1688             onChangeAudioFormat(entry->mMeta, entry->mNotifyConsumed);  in flushQueue()