| Index: remoting/client/audio_decode_scheduler.cc
|
| diff --git a/remoting/client/audio_decode_scheduler.cc b/remoting/client/audio_decode_scheduler.cc
|
| index 3f0e46660024c9af504985d7a42d82663a361c35..3a5279b221390b31e2fa8defc5c44ec3bcb252f4 100644
|
| --- a/remoting/client/audio_decode_scheduler.cc
|
| +++ b/remoting/client/audio_decode_scheduler.cc
|
| @@ -10,7 +10,7 @@
|
| #include "base/location.h"
|
| #include "base/macros.h"
|
| #include "base/single_thread_task_runner.h"
|
| -#include "remoting/client/audio_player.h"
|
| +#include "remoting/client/audio_consumer.h"
|
| #include "remoting/codec/audio_decoder.h"
|
| #include "remoting/proto/audio.pb.h"
|
|
|
| @@ -20,7 +20,7 @@ class AudioDecodeScheduler::Core : public base::RefCountedThreadSafe<Core> {
|
| public:
|
| Core(scoped_refptr<base::SingleThreadTaskRunner> main_task_runner,
|
| scoped_refptr<base::SingleThreadTaskRunner> audio_decode_task_runner,
|
| - std::unique_ptr<AudioPlayer> audio_player);
|
| + AudioConsumer* audio_consumer);
|
|
|
| void Initialize(const protocol::SessionConfig& config);
|
| void ProcessAudioPacket(std::unique_ptr<AudioPacket> packet,
|
| @@ -45,7 +45,7 @@ class AudioDecodeScheduler::Core : public base::RefCountedThreadSafe<Core> {
|
| scoped_refptr<base::SingleThreadTaskRunner> main_task_runner_;
|
| scoped_refptr<base::SingleThreadTaskRunner> audio_decode_task_runner_;
|
| std::unique_ptr<AudioDecoder> decoder_;
|
| - std::unique_ptr<AudioPlayer> audio_player_;
|
| + AudioConsumer* audio_consumer_;
|
|
|
| DISALLOW_COPY_AND_ASSIGN(Core);
|
| };
|
| @@ -53,10 +53,10 @@ class AudioDecodeScheduler::Core : public base::RefCountedThreadSafe<Core> {
|
| AudioDecodeScheduler::Core::Core(
|
| scoped_refptr<base::SingleThreadTaskRunner> main_task_runner,
|
| scoped_refptr<base::SingleThreadTaskRunner> audio_decode_task_runner,
|
| - std::unique_ptr<AudioPlayer> audio_player)
|
| + AudioConsumer* audio_consumer)
|
| : main_task_runner_(main_task_runner),
|
| audio_decode_task_runner_(audio_decode_task_runner),
|
| - audio_player_(std::move(audio_player)) {}
|
| + audio_consumer_(audio_consumer) {}
|
|
|
| AudioDecodeScheduler::Core::~Core() {}
|
|
|
| @@ -77,7 +77,6 @@ void AudioDecodeScheduler::Core::ProcessAudioPacket(
|
|
|
| void AudioDecodeScheduler::Core::Detach() {
|
| DCHECK(main_task_runner_->BelongsToCurrentThread());
|
| - audio_player_.reset();
|
| }
|
|
|
| void AudioDecodeScheduler::Core::DecodePacket(
|
| @@ -97,18 +96,20 @@ void AudioDecodeScheduler::Core::ProcessDecodedPacket(
|
| const base::Closure& done) {
|
| DCHECK(main_task_runner_->BelongsToCurrentThread());
|
| // Only process |packet| if it is non-null.
|
| - if (packet.get() && audio_player_.get())
|
| - audio_player_->ProcessAudioPacket(std::move(packet));
|
| + if (packet.get() && audio_consumer_) {
|
| + audio_consumer_->AddAudioPacket(std::move(packet));
|
| + }
|
| done.Run();
|
| }
|
|
|
| AudioDecodeScheduler::AudioDecodeScheduler(
|
| scoped_refptr<base::SingleThreadTaskRunner> main_task_runner,
|
| scoped_refptr<base::SingleThreadTaskRunner> audio_decode_task_runner,
|
| - std::unique_ptr<AudioPlayer> audio_player)
|
| + AudioConsumer* audio_consumer)
|
| : core_(new Core(main_task_runner,
|
| audio_decode_task_runner,
|
| - std::move(audio_player))) {}
|
| + audio_consumer)) {
|
| +}
|
|
|
| AudioDecodeScheduler::~AudioDecodeScheduler() {
|
| core_->Detach();
|
|
|