| // Copyright 2021 The Cobalt Authors. All Rights Reserved. |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| #include "starboard/android/shared/audio_renderer_passthrough.h" |
| |
| #include <algorithm> |
| #include <utility> |
| |
| #include "starboard/android/shared/audio_decoder_passthrough.h" |
| #include "starboard/android/shared/jni_env_ext.h" |
| #include "starboard/android/shared/jni_utils.h" |
| #include "starboard/common/string.h" |
| #include "starboard/memory.h" |
| |
| namespace starboard { |
| namespace android { |
| namespace shared { |
| namespace { |
| |
| // Soft limit to ensure that the user of AudioRendererPassthrough won't keep |
| // pushing data when there are enough decoded audio buffers. |
| constexpr int kMaxDecodedAudios = 64; |
| |
| constexpr SbTime kAudioTrackUpdateInternal = kSbTimeMillisecond * 5; |
| |
| constexpr int kPreferredBufferSizeInBytes = 16 * 1024; |
| // TODO: Enable passthrough with tunnel mode. |
| constexpr int kTunnelModeAudioSessionId = -1; |
| |
| // C++ rewrite of ExoPlayer function parseAc3SyncframeAudioSampleCount(), it |
| // works for AC-3, E-AC-3, and E-AC-3-JOC. |
| // The ExoPlayer implementation is based on |
| // https://www.etsi.org/deliver/etsi_ts/102300_102399/102366/01.04.01_60/ts_102366v010401p.pdf. |
| int ParseAc3SyncframeAudioSampleCount(const uint8_t* buffer, int size) { |
| SB_DCHECK(buffer); |
| |
| constexpr int kAudioSamplesPerAudioBlock = 256; |
| // Each syncframe has 6 blocks that provide 256 new audio samples. See |
| // subsection 4.1. |
| constexpr int kAc3SyncFrameAudioSampleCount = 6 * kAudioSamplesPerAudioBlock; |
| // Number of audio blocks per E-AC-3 syncframe, indexed by numblkscod. |
| constexpr int kBlocksPerSyncFrameByNumblkscod[] = {1, 2, 3, 6}; |
| |
| if (size < 6) { |
| SB_LOG(WARNING) << "Invalid e/ac3 input buffer size " << size; |
| return kAc3SyncFrameAudioSampleCount; |
| } |
| |
| // Parse the bitstream ID for AC-3 and E-AC-3 (see subsections 4.3, E.1.2 and |
| // E.1.3.1.6). |
| const bool is_eac3 = ((buffer[5] & 0xF8) >> 3) > 10; |
| if (is_eac3) { |
| int fscod = (buffer[4] & 0xC0) >> 6; |
| int numblkscod = fscod == 0x03 ? 3 : (buffer[4] & 0x30) >> 4; |
| return kBlocksPerSyncFrameByNumblkscod[numblkscod] * |
| kAudioSamplesPerAudioBlock; |
| } else { |
| return kAc3SyncFrameAudioSampleCount; |
| } |
| } |
| |
| } // namespace |
| |
| AudioRendererPassthrough::AudioRendererPassthrough( |
| const SbMediaAudioSampleInfo& audio_sample_info, |
| SbDrmSystem drm_system, |
| bool enable_audio_device_callback) |
| : audio_sample_info_(audio_sample_info), |
| enable_audio_device_callback_(enable_audio_device_callback) { |
| SB_DCHECK(audio_sample_info_.codec == kSbMediaAudioCodecAc3 || |
| audio_sample_info_.codec == kSbMediaAudioCodecEac3); |
| if (SbDrmSystemIsValid(drm_system)) { |
| SB_LOG(INFO) << "Creating AudioDecoder as decryptor."; |
| scoped_ptr<AudioDecoder> audio_decoder(new AudioDecoder( |
| audio_sample_info_.codec, audio_sample_info, drm_system)); |
| if (audio_decoder->is_valid()) { |
| decoder_.reset(audio_decoder.release()); |
| } |
| } else { |
| SB_LOG(INFO) << "Creating AudioDecoderPassthrough."; |
| decoder_.reset( |
| new AudioDecoderPassthrough(audio_sample_info_.samples_per_second)); |
| } |
| } |
| |
| AudioRendererPassthrough::~AudioRendererPassthrough() { |
| SB_DCHECK(BelongsToCurrentThread()); |
| |
| if (is_valid()) { |
| SB_LOG(INFO) << "Force a seek to 0 to reset all states before destructing."; |
| Seek(0); |
| } |
| } |
| |
| void AudioRendererPassthrough::Initialize(const ErrorCB& error_cb, |
| const PrerolledCB& prerolled_cb, |
| const EndedCB& ended_cb) { |
| SB_DCHECK(BelongsToCurrentThread()); |
| SB_DCHECK(error_cb); |
| SB_DCHECK(prerolled_cb); |
| SB_DCHECK(ended_cb); |
| SB_DCHECK(!error_cb_); |
| SB_DCHECK(!prerolled_cb_); |
| SB_DCHECK(!ended_cb_); |
| SB_DCHECK(decoder_); |
| |
| error_cb_ = error_cb; |
| prerolled_cb_ = prerolled_cb; |
| ended_cb_ = ended_cb; |
| |
| decoder_->Initialize( |
| std::bind(&AudioRendererPassthrough::OnDecoderOutput, this), error_cb); |
| } |
| |
| void AudioRendererPassthrough::WriteSamples(const InputBuffers& input_buffers) { |
| SB_DCHECK(BelongsToCurrentThread()); |
| SB_DCHECK(!input_buffers.empty()); |
| SB_DCHECK(can_accept_more_data_.load()); |
| |
| if (!audio_track_thread_) { |
| audio_track_thread_.reset( |
| new JobThread("AudioPassthrough", 0, kSbThreadPriorityHigh)); |
| audio_track_thread_->Schedule(std::bind( |
| &AudioRendererPassthrough::CreateAudioTrackAndStartProcessing, this)); |
| } |
| |
| if (frames_per_input_buffer_ == 0) { |
| frames_per_input_buffer_ = ParseAc3SyncframeAudioSampleCount( |
| input_buffers.front()->data(), input_buffers.front()->size()); |
| SB_LOG(INFO) << "Got frames per input buffer " << frames_per_input_buffer_; |
| } |
| |
| can_accept_more_data_.store(false); |
| |
| decoder_->Decode( |
| input_buffers, |
| std::bind(&AudioRendererPassthrough::OnDecoderConsumed, this)); |
| } |
| |
| void AudioRendererPassthrough::WriteEndOfStream() { |
| SB_DCHECK(BelongsToCurrentThread()); |
| |
| if (end_of_stream_written_) { |
| SB_LOG(INFO) << "WriteEndOfStream() ignored as |end_of_stream_written_| is" |
| << " true."; |
| return; |
| } |
| |
| SB_LOG(INFO) << "WriteEndOfStream() called."; |
| |
| end_of_stream_written_ = true; |
| |
| if (audio_track_thread_) { |
| decoder_->WriteEndOfStream(); |
| return; |
| } |
| |
| SB_LOG(INFO) << "Audio eos reached without any samples written."; |
| end_of_stream_played_.store(true); |
| ended_cb_(); |
| } |
| |
| void AudioRendererPassthrough::SetVolume(double volume) { |
| SB_DCHECK(BelongsToCurrentThread()); |
| |
| if (volume_ == volume) { |
| SB_LOG(INFO) << "Volume already at " << volume; |
| return; |
| } |
| |
| SB_LOG(INFO) << "Set volume to " << volume; |
| |
| ScopedLock scoped_lock(mutex_); |
| volume_ = volume; |
| } |
| |
| bool AudioRendererPassthrough::IsEndOfStreamWritten() const { |
| SB_DCHECK(BelongsToCurrentThread()); |
| |
| return end_of_stream_written_; |
| } |
| |
| bool AudioRendererPassthrough::IsEndOfStreamPlayed() const { |
| SB_DCHECK(BelongsToCurrentThread()); |
| |
| return end_of_stream_played_.load(); |
| } |
| |
| bool AudioRendererPassthrough::CanAcceptMoreData() const { |
| SB_DCHECK(BelongsToCurrentThread()); |
| |
| ScopedLock scoped_lock(mutex_); |
| return can_accept_more_data_.load() && |
| decoded_audios_.size() < kMaxDecodedAudios; |
| } |
| |
| void AudioRendererPassthrough::Play() { |
| SB_DCHECK(BelongsToCurrentThread()); |
| |
| if (!paused_) { |
| SB_LOG(INFO) << "Already playing."; |
| return; |
| } |
| |
| SB_LOG(INFO) << "Play."; |
| |
| ScopedLock scoped_lock(mutex_); |
| paused_ = false; |
| } |
| |
| void AudioRendererPassthrough::Pause() { |
| SB_DCHECK(BelongsToCurrentThread()); |
| |
| if (paused_) { |
| SB_LOG(INFO) << "Already paused."; |
| return; |
| } |
| |
| SB_LOG(INFO) << "Pause."; |
| |
| ScopedLock scoped_lock(mutex_); |
| paused_ = true; |
| } |
| |
| void AudioRendererPassthrough::SetPlaybackRate(double playback_rate) { |
| SB_DCHECK(BelongsToCurrentThread()); |
| |
| if (playback_rate > 0.0 && playback_rate != 1.0) { |
| // TODO: Report unsupported playback rate as an error. |
| SB_LOG(WARNING) << "Playback rate " << playback_rate << " is not supported" |
| << " and is set to 1.0."; |
| playback_rate = 1.0; |
| } |
| |
| if (playback_rate_ == playback_rate) { |
| SB_LOG(INFO) << "Playback rate already at " << playback_rate; |
| return; |
| } |
| |
| SB_LOG(INFO) << "Change playback rate from " << playback_rate_ << " to " |
| << playback_rate << "."; |
| |
| ScopedLock scoped_lock(mutex_); |
| playback_rate_ = playback_rate; |
| } |
| |
| void AudioRendererPassthrough::Seek(SbTime seek_to_time) { |
| SB_DCHECK(BelongsToCurrentThread()); |
| |
| SB_LOG(INFO) << "Seek to " << seek_to_time; |
| |
| decoder_->Reset(); |
| |
| bool seek_to_time_set = false; |
| if (audio_track_thread_) { |
| audio_track_thread_->ScheduleAndWait( |
| std::bind(&AudioRendererPassthrough::FlushAudioTrackAndStopProcessing, |
| this, seek_to_time)); |
| // |seek_to_time_| is updated inside FlushAudioTrackAndStopProcessing(), |
| // update the flag so we needn't set it again below. |
| seek_to_time_set = true; |
| // Destroy the audio track thread, it will be re-created during preroll. |
| audio_track_thread_.reset(); |
| } |
| |
| CancelPendingJobs(); |
| |
| ScopedLock scoped_lock(mutex_); |
| |
| can_accept_more_data_.store(true); |
| prerolled_.store(false); |
| end_of_stream_played_.store(false); |
| total_frames_written_ = 0; |
| |
| end_of_stream_written_ = false; |
| |
| stop_called_ = false; |
| playback_head_position_when_stopped_ = 0; |
| stopped_at_ = 0; |
| if (!seek_to_time_set) { |
| seek_to_time_ = seek_to_time; |
| } |
| paused_ = true; |
| decoded_audios_ = std::queue<scoped_refptr<DecodedAudio>>(); // clear it |
| decoded_audio_writing_in_progress_ = nullptr; |
| decoded_audio_writing_offset_ = 0; |
| total_frames_written_on_audio_track_thread_ = 0; |
| } |
| |
| // This function can be called from *any* threads. |
| SbTime AudioRendererPassthrough::GetCurrentMediaTime(bool* is_playing, |
| bool* is_eos_played, |
| bool* is_underflow, |
| double* playback_rate) { |
| SB_DCHECK(is_playing); |
| SB_DCHECK(is_eos_played); |
| SB_DCHECK(is_underflow); |
| SB_DCHECK(playback_rate); |
| |
| ScopedLock scoped_lock(mutex_); |
| *is_playing = !paused_; |
| *is_eos_played = end_of_stream_played_.load(); |
| *is_underflow = false; // TODO: Support underflow |
| *playback_rate = playback_rate_; |
| |
| if (!audio_track_bridge_) { |
| return seek_to_time_; |
| } |
| |
| if (stop_called_) { |
| // When AudioTrackBridge::Stop() is called, the playback will continue until |
| // all the frames written are played, as the AudioTrack in created in |
| // MODE_STREAM. |
| auto now = SbTimeGetMonotonicNow(); |
| SB_DCHECK(now >= stopped_at_); |
| auto time_elapsed = now - stopped_at_; |
| int64_t frames_played = |
| time_elapsed * audio_sample_info_.samples_per_second / kSbTimeSecond; |
| int64_t total_frames_played = |
| frames_played + playback_head_position_when_stopped_; |
| total_frames_played = std::min(total_frames_played, total_frames_written_); |
| return seek_to_time_ + total_frames_played * kSbTimeSecond / |
| audio_sample_info_.samples_per_second; |
| } |
| |
| SbTime updated_at; |
| auto playback_head_position = |
| audio_track_bridge_->GetAudioTimestamp(&updated_at); |
| if (playback_head_position <= 0) { |
| // The playback is warming up, don't adjust the media time by the monotonic |
| // system time. |
| return seek_to_time_; |
| } |
| |
| // TODO: This may cause time regression, because the unadjusted time will be |
| // returned on pause, after an adjusted time has been returned. |
| SbTime playback_time = |
| seek_to_time_ + playback_head_position * kSbTimeSecond / |
| audio_sample_info_.samples_per_second; |
| |
| // When underlying AudioTrack is paused, we use returned playback time |
| // directly. Note that we should not use |paused_| or |playback_rate_| here. |
| // As we sync audio sink state on |audio_track_thread_|, when |paused_| is set |
| // to false, the underlying AudioTrack may still be paused. In that case, the |
| // returned playback time and last frame consumed time would be out of date. |
| // For example, when resume the playback, if we call GetAudioTimestamp() |
| // before calling AudioTrack.Play(), the returned playback time and last frame |
| // consumed time would be the same as at when we pause the video. |
| if (audio_track_paused_) { |
| return playback_time; |
| } |
| |
| // TODO: Cap this to the maximum frames written to the AudioTrack. |
| auto now = SbTimeGetMonotonicNow(); |
| SB_LOG_IF(WARNING, now < updated_at) |
| << "now (" << now << ") is not greater than updated_at (" << updated_at |
| << ")."; |
| SB_LOG_IF(WARNING, now - updated_at > kSbTimeSecond) |
| << "Elapsed time (" << now - updated_at |
| << ") is greater than 1s. (playback_time " << playback_time << ")"; |
| |
| playback_time += std::max<SbTime>(now - updated_at, 0); |
| |
| return playback_time; |
| } |
| |
| void AudioRendererPassthrough::CreateAudioTrackAndStartProcessing() { |
| SB_DCHECK(audio_track_thread_); |
| SB_DCHECK(audio_track_thread_->BelongsToCurrentThread()); |
| SB_DCHECK(error_cb_); |
| |
| if (audio_track_bridge_) { |
| SB_DCHECK(!update_status_and_write_data_token_.is_valid()); |
| AudioTrackState initial_state; |
| update_status_and_write_data_token_ = audio_track_thread_->Schedule( |
| std::bind(&AudioRendererPassthrough::UpdateStatusAndWriteData, this, |
| initial_state)); |
| SB_LOG(INFO) << "|audio_track_bridge_| already created, start processing."; |
| return; |
| } |
| |
| std::unique_ptr<AudioTrackBridge> audio_track_bridge(new AudioTrackBridge( |
| audio_sample_info_.codec == kSbMediaAudioCodecAc3 |
| ? kSbMediaAudioCodingTypeAc3 |
| : kSbMediaAudioCodingTypeDolbyDigitalPlus, |
| optional<SbMediaAudioSampleType>(), // Not required in passthrough mode |
| audio_sample_info_.number_of_channels, |
| audio_sample_info_.samples_per_second, kPreferredBufferSizeInBytes, |
| enable_audio_device_callback_, false /* enable_pcm_content_type_movie */, |
| kTunnelModeAudioSessionId, false /* is_web_audio */)); |
| |
| if (!audio_track_bridge->is_valid()) { |
| error_cb_(kSbPlayerErrorDecode, "Error creating AudioTrackBridge"); |
| return; |
| } |
| |
| { |
| ScopedLock scoped_lock(mutex_); |
| audio_track_bridge_ = std::move(audio_track_bridge); |
| } |
| |
| AudioTrackState initial_state; |
| update_status_and_write_data_token_ = audio_track_thread_->Schedule( |
| std::bind(&AudioRendererPassthrough::UpdateStatusAndWriteData, this, |
| initial_state)); |
| SB_LOG(INFO) << "|audio_track_bridge_| created, start processing."; |
| } |
| |
| void AudioRendererPassthrough::FlushAudioTrackAndStopProcessing( |
| SbTime seek_to_time) { |
| SB_DCHECK(audio_track_thread_); |
| SB_DCHECK(audio_track_thread_->BelongsToCurrentThread()); |
| |
| SB_LOG(INFO) << "Pause audio track and stop processing."; |
| |
| // Flushing of |audio_track_bridge_| and updating of |seek_to_time_| have to |
| // be done together under lock to avoid |seek_to_time_| being added to a stale |
| // playback head or vice versa in GetCurrentMediaTime(). |
| ScopedLock scoped_lock(mutex_); |
| |
| // We have to reuse |audio_track_bridge_| instead of creating a new one, to |
| // reduce output mode switching between PCM and e/ac3. Otherwise a noticeable |
| // silence can be observed after seeking on some audio receivers. |
| // TODO: Consider reusing audio sink for non-passthrough playbacks, to see if |
| // it reduces latency after seeking. |
| if (audio_track_bridge_ && audio_track_bridge_->is_valid()) { |
| audio_track_bridge_->PauseAndFlush(); |
| } |
| seek_to_time_ = seek_to_time; |
| paused_ = true; |
| if (update_status_and_write_data_token_.is_valid()) { |
| audio_track_thread_->RemoveJobByToken(update_status_and_write_data_token_); |
| update_status_and_write_data_token_.ResetToInvalid(); |
| } |
| } |
| |
| void AudioRendererPassthrough::UpdateStatusAndWriteData( |
| const AudioTrackState previous_state) { |
| SB_DCHECK(audio_track_thread_); |
| SB_DCHECK(audio_track_thread_->BelongsToCurrentThread()); |
| SB_DCHECK(error_cb_); |
| SB_DCHECK(audio_track_bridge_); |
| |
| if (enable_audio_device_callback_ && |
| audio_track_bridge_->GetAndResetHasAudioDeviceChanged()) { |
| SB_LOG(INFO) << "Audio device changed, raising a capability changed error " |
| "to restart playback."; |
| error_cb_(kSbPlayerErrorCapabilityChanged, |
| "Audio device capability changed"); |
| audio_track_bridge_->PauseAndFlush(); |
| return; |
| } |
| |
| AudioTrackState current_state; |
| |
| { |
| ScopedLock scoped_lock(mutex_); |
| current_state.volume = volume_; |
| current_state.paused = paused_; |
| current_state.playback_rate = playback_rate_; |
| |
| if (!decoded_audio_writing_in_progress_ && !decoded_audios_.empty()) { |
| decoded_audio_writing_in_progress_ = decoded_audios_.front(); |
| decoded_audios_.pop(); |
| decoded_audio_writing_offset_ = 0; |
| } |
| } |
| |
| if (previous_state.volume != current_state.volume) { |
| audio_track_bridge_->SetVolume(current_state.volume); |
| } |
| if (previous_state.playing() != current_state.playing()) { |
| if (current_state.playing()) { |
| audio_track_bridge_->Play(); |
| audio_track_paused_ = false; |
| SB_LOG(INFO) << "Played on AudioTrack thread."; |
| ScopedLock scoped_lock(mutex_); |
| stop_called_ = false; |
| } else { |
| audio_track_bridge_->Pause(); |
| audio_track_paused_ = true; |
| SB_LOG(INFO) << "Paused on AudioTrack thread."; |
| } |
| } |
| |
| bool fully_written = false; |
| if (decoded_audio_writing_in_progress_) { |
| if (decoded_audio_writing_in_progress_->is_end_of_stream()) { |
| if (!prerolled_.exchange(true)) { |
| SB_LOG(INFO) << "Prerolled due to end of stream."; |
| prerolled_cb_(); |
| } |
| ScopedLock scoped_lock(mutex_); |
| if (current_state.playing() && !stop_called_) { |
| // TODO: Check if we can apply the same stop logic to non-passthrough. |
| audio_track_bridge_->Stop(); |
| stop_called_ = true; |
| playback_head_position_when_stopped_ = |
| audio_track_bridge_->GetAudioTimestamp(&stopped_at_); |
| total_frames_written_ = total_frames_written_on_audio_track_thread_; |
| decoded_audio_writing_in_progress_ = nullptr; |
| SB_LOG(INFO) << "Audio track stopped at " << stopped_at_ |
| << ", playback head: " |
| << playback_head_position_when_stopped_; |
| } |
| } else { |
| auto sample_buffer = decoded_audio_writing_in_progress_->buffer() + |
| decoded_audio_writing_offset_; |
| auto samples_to_write = (decoded_audio_writing_in_progress_->size() - |
| decoded_audio_writing_offset_); |
| // TODO: |sync_time| currently doesn't take partial writes into account. |
| // It is not used in non-tunneled mode so it doesn't matter, but we |
| // should revisit this. |
| auto sync_time = decoded_audio_writing_in_progress_->timestamp(); |
| int samples_written = audio_track_bridge_->WriteSample( |
| sample_buffer, samples_to_write, sync_time); |
| // Error code returned as negative value, like kAudioTrackErrorDeadObject. |
| if (samples_written < 0) { |
| if (samples_written == AudioTrackBridge::kAudioTrackErrorDeadObject) { |
| // Inform the audio end point change. |
| SB_LOG(INFO) |
| << "Write error for dead audio track, audio device capability " |
| "has likely changed. Restarting playback."; |
| error_cb_(kSbPlayerErrorCapabilityChanged, |
| "Audio device capability changed"); |
| } else { |
| // `kSbPlayerErrorDecode` is used for general SbPlayer error, there is |
| // no error code corresponding to audio sink. |
| error_cb_( |
| kSbPlayerErrorDecode, |
| FormatString("Error while writing frames: %d", samples_written)); |
| SB_LOG(INFO) << "Encountered kSbPlayerErrorDecode while writing " |
| "frames, error: " |
| << samples_written; |
| } |
| audio_track_bridge_->PauseAndFlush(); |
| return; |
| } |
| decoded_audio_writing_offset_ += samples_written; |
| |
| if (decoded_audio_writing_offset_ == |
| decoded_audio_writing_in_progress_->size()) { |
| total_frames_written_on_audio_track_thread_ += frames_per_input_buffer_; |
| decoded_audio_writing_in_progress_ = nullptr; |
| decoded_audio_writing_offset_ = 0; |
| fully_written = true; |
| } else if (!prerolled_.exchange(true)) { |
| // The audio sink no longer takes all the samples written to it. Assume |
| // that it has enough samples and preroll is finished. |
| SB_LOG(INFO) << "Prerolled."; |
| prerolled_cb_(); |
| } |
| } |
| } |
| |
| // EOS is handled on this thread instead of in GetCurrentMediaTime(), because |
| // GetCurrentMediaTime() is not guaranteed to be called. |
| if (stop_called_ && !end_of_stream_played_.load()) { |
| auto time_elapsed = SbTimeGetMonotonicNow() - stopped_at_; |
| auto frames_played = |
| time_elapsed * audio_sample_info_.samples_per_second / kSbTimeSecond; |
| if (frames_played + playback_head_position_when_stopped_ >= |
| total_frames_written_on_audio_track_thread_) { |
| end_of_stream_played_.store(true); |
| ended_cb_(); |
| SB_LOG(INFO) << "Audio playback ended, UpdateStatusAndWriteData stopped."; |
| return; |
| } |
| } |
| |
| update_status_and_write_data_token_ = audio_track_thread_->Schedule( |
| std::bind(&AudioRendererPassthrough::UpdateStatusAndWriteData, this, |
| current_state), |
| fully_written ? 0 : kAudioTrackUpdateInternal); |
| } |
| |
| // This function can be called from *any* threads. |
| void AudioRendererPassthrough::OnDecoderConsumed() { |
| auto old_value = can_accept_more_data_.exchange(true); |
| SB_DCHECK(!old_value); |
| } |
| |
| // This function can be called from *any* threads. |
| void AudioRendererPassthrough::OnDecoderOutput() { |
| int decoded_audio_sample_rate; |
| auto decoded_audio = decoder_->Read(&decoded_audio_sample_rate); |
| SB_DCHECK(decoded_audio); |
| |
| ScopedLock scoped_lock(mutex_); |
| decoded_audios_.push(decoded_audio); |
| } |
| |
| } // namespace shared |
| } // namespace android |
| } // namespace starboard |