blob: 7d9a1a305302a8042526817072e5bec1bdf0e322 [file] [log] [blame]
// 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.
#ifndef STARBOARD_ANDROID_SHARED_AUDIO_RENDERER_PASSTHROUGH_H_
#define STARBOARD_ANDROID_SHARED_AUDIO_RENDERER_PASSTHROUGH_H_
#include <atomic>
#include <memory>
#include <queue>
#include "starboard/android/shared/audio_decoder.h"
#include "starboard/android/shared/audio_track_bridge.h"
#include "starboard/android/shared/drm_system.h"
#include "starboard/atomic.h"
#include "starboard/common/mutex.h"
#include "starboard/common/ref_counted.h"
#include "starboard/drm.h"
#include "starboard/media.h"
#include "starboard/shared/internal_only.h"
#include "starboard/shared/starboard/media/media_util.h"
#include "starboard/shared/starboard/player/decoded_audio_internal.h"
#include "starboard/shared/starboard/player/filter/audio_renderer_internal.h"
#include "starboard/shared/starboard/player/filter/common.h"
#include "starboard/shared/starboard/player/filter/media_time_provider.h"
#include "starboard/shared/starboard/player/input_buffer_internal.h"
#include "starboard/shared/starboard/player/job_queue.h"
#include "starboard/shared/starboard/player/job_thread.h"
#include "starboard/time.h"
namespace starboard {
namespace android {
namespace shared {
// TODO: The audio receiver often requires some warm up time to switch the
// output to eac3. Consider pushing some silence at the very beginning so
// the sound at the very beginning won't get lost during the switching.
class AudioRendererPassthrough
: public ::starboard::shared::starboard::player::filter::AudioRenderer,
public ::starboard::shared::starboard::player::filter::MediaTimeProvider,
private ::starboard::shared::starboard::player::JobQueue::JobOwner {
public:
typedef ::starboard::shared::starboard::media::AudioStreamInfo
AudioStreamInfo;
AudioRendererPassthrough(const AudioStreamInfo& audio_stream_info,
SbDrmSystem drm_system,
bool enable_audio_device_callback);
~AudioRendererPassthrough() override;
bool is_valid() const { return decoder_ != nullptr; }
// AudioRenderer methods
void Initialize(const ErrorCB& error_cb,
const PrerolledCB& prerolled_cb,
const EndedCB& ended_cb) override;
void WriteSamples(const InputBuffers& input_buffers) override;
void WriteEndOfStream() override;
void SetVolume(double volume) override;
bool IsEndOfStreamWritten() const override;
bool IsEndOfStreamPlayed() const override;
bool CanAcceptMoreData() const override;
// MediaTimeProvider methods
void Play() override;
void Pause() override;
void SetPlaybackRate(double playback_rate) override;
void Seek(SbTime seek_to_time) override;
SbTime GetCurrentMediaTime(bool* is_playing,
bool* is_eos_played,
bool* is_underflow,
double* playback_rate) override;
private:
typedef ::starboard::shared::starboard::player::DecodedAudio DecodedAudio;
typedef ::starboard::shared::starboard::player::JobThread JobThread;
typedef ::starboard::shared::starboard::player::JobQueue::JobToken JobToken;
struct AudioTrackState {
double volume = 1.0;
bool paused = true;
double playback_rate = 1.0;
bool playing() const { return !paused && playback_rate > 0.0; }
};
void CreateAudioTrackAndStartProcessing();
void FlushAudioTrackAndStopProcessing(SbTime seek_to_time);
void UpdateStatusAndWriteData(const AudioTrackState previous_state);
void OnDecoderConsumed();
void OnDecoderOutput();
// The following three variables are set in the ctor.
const AudioStreamInfo audio_stream_info_;
const bool enable_audio_device_callback_;
// The AudioDecoder is used as a decryptor when the stream is encrypted.
// TODO: Revisit to encapsulate the AudioDecoder as a SbDrmSystemPrivate
// instead. This would need to turn SbDrmSystemPrivate::Decrypt() into
// asynchronous, which comes with extra risks.
std::unique_ptr<::starboard::shared::starboard::player::filter::AudioDecoder>
decoder_;
// The following three variables are set in Initialize().
ErrorCB error_cb_;
PrerolledCB prerolled_cb_;
EndedCB ended_cb_;
int frames_per_input_buffer_ = 0; // Set once before all uses.
atomic_bool can_accept_more_data_{true};
atomic_bool prerolled_;
atomic_bool end_of_stream_played_;
bool end_of_stream_written_ = false; // Only accessed on PlayerWorker thread.
Mutex mutex_;
bool stop_called_ = false;
int64_t total_frames_written_ = 0;
int64_t playback_head_position_when_stopped_ = 0;
SbTimeMonotonic stopped_at_ = 0;
SbTime seek_to_time_ = 0;
SbTime first_audio_timestamp_ = -1;
double volume_ = 1.0;
bool paused_ = true;
double playback_rate_ = 1.0;
std::queue<scoped_refptr<DecodedAudio>> decoded_audios_;
// The following variable group is only accessed on |audio_track_thread_|, or
// after |audio_track_thread_| is destroyed (in Seek()).
scoped_refptr<DecodedAudio> decoded_audio_writing_in_progress_;
int decoded_audio_writing_offset_ = 0;
JobToken update_status_and_write_data_token_;
int64_t total_frames_written_on_audio_track_thread_ = 0;
std::atomic_bool audio_track_paused_{true};
// |audio_track_thread_| must be declared after |audio_track_bridge_| to
// ensure the thread completes all tasks before |audio_track_bridge_| is
// invalidated.
std::unique_ptr<AudioTrackBridge> audio_track_bridge_;
std::unique_ptr<JobThread> audio_track_thread_;
};
} // namespace shared
} // namespace android
} // namespace starboard
#endif // STARBOARD_ANDROID_SHARED_AUDIO_RENDERER_PASSTHROUGH_H_