Lines Matching refs:mNotifyConsumed
553 entry.mNotifyConsumed = notify; in onMessageReceived()
916 entry->mNotifyConsumed->post(); in fillAudioBuffer()
964 if ((entry->mBuffer == nullptr && entry->mNotifyConsumed == nullptr) in drainAudioQueueUntilLastEOS()
965 || (entry->mNotifyConsumed->findInt32("eos", &eos) && eos != 0)) { in drainAudioQueueUntilLastEOS()
975 if (it->mNotifyConsumed == nullptr) { in drainAudioQueueUntilLastEOS()
980 onChangeAudioFormat(it->mMeta, it->mNotifyConsumed); in drainAudioQueueUntilLastEOS()
983 it->mNotifyConsumed->post(); in drainAudioQueueUntilLastEOS()
1034 if (entry->mNotifyConsumed != nullptr) { in onDrainAudioQueue()
1036 onChangeAudioFormat(entry->mMeta, entry->mNotifyConsumed); in onDrainAudioQueue()
1106 entry->mNotifyConsumed->post(); in onDrainAudioQueue()
1394 entry->mNotifyConsumed->setInt64("timestampNs", realTimeUs * 1000LL); in onDrainVideoQueue()
1395 entry->mNotifyConsumed->setInt32("render", !tooLate); in onDrainVideoQueue()
1396 entry->mNotifyConsumed->post(); in onDrainVideoQueue()
1494 entry.mNotifyConsumed = notifyConsumed; in onQueueBuffer()
1537 (*mAudioQueue.begin()).mNotifyConsumed->post(); in onQueueBuffer()
1691 entry->mNotifyConsumed->post(); in flushQueue()
1692 } else if (entry->mNotifyConsumed != nullptr) { in flushQueue()
1694 onChangeAudioFormat(entry->mMeta, entry->mNotifyConsumed); in flushQueue()