[Chromecast] Cleanup the API for creating MediaPipelineBackend.

chromecast/media/audio/cast_audio_output_stream.cc

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chromecast/media/audio/cast_audio_output_stream.h"
 
 #include "base/bind.h"
 #include "base/synchronization/waitable_event.h"
 #include "base/threading/thread_checker.h"
 #include "chromecast/base/metrics/cast_metrics_helper.h"
+#include "chromecast/base/task_runner_impl.h"
 #include "chromecast/media/audio/cast_audio_manager.h"
 #include "chromecast/media/base/media_message_loop.h"
 #include "chromecast/media/cma/base/cast_decoder_buffer_impl.h"
 #include "chromecast/media/cma/base/decoder_buffer_adapter.h"
 #include "chromecast/media/cma/pipeline/frame_status_cb_impl.h"
 #include "chromecast/public/media/audio_pipeline_device.h"
 #include "chromecast/public/media/decoder_config.h"
 #include "chromecast/public/media/decrypt_context.h"
 #include "chromecast/public/media/media_clock_device.h"
 #include "chromecast/public/media/media_pipeline_backend.h"
+#include "chromecast/public/media/media_pipeline_device_params.h"
 #include "media/base/bind_to_current_loop.h"
 #include "media/base/decoder_buffer.h"
 
 namespace chromecast {
 namespace media {
 
 namespace {
 bool InitClockDevice(MediaClockDevice* clock_device) {
   DCHECK(clock_device);
   DCHECK_EQ(clock_device->GetState(), MediaClockDevice::kStateUninitialized);
@@ skipping 47 matching lines @@
     thread_checker_.DetachFromThread();
   }
   ~Backend() {}
 
   void Open(CastAudioManager* audio_manager,
             bool* success,
             base::WaitableEvent* completion_event) {
     DCHECK(thread_checker_.CalledOnValidThread());
     DCHECK(backend_ == nullptr);
 
+    backend_task_runner_.reset(new TaskRunnerImpl());
+    MediaPipelineDeviceParams device_params(
+        MediaPipelineDeviceParams::kModeIgnorePts, backend_task_runner_.get());
+
     scoped_ptr<MediaPipelineBackend> pipeline_backend =
-        audio_manager->CreateMediaPipelineBackend();
+        audio_manager->CreateMediaPipelineBackend(device_params);
     if (pipeline_backend && InitClockDevice(pipeline_backend->GetClock()) &&
         InitAudioDevice(audio_params_, pipeline_backend->GetAudio())) {
       backend_ = pipeline_backend.Pass();
     }
     *success = backend_ != nullptr;
     completion_event->Signal();
   }
 
   void Close() {
     DCHECK(thread_checker_.CalledOnValidThread());
 
     if (backend_) {
       backend_->GetClock()->SetState(MediaClockDevice::kStateIdle);
       backend_->GetAudio()->SetState(AudioPipelineDevice::kStateIdle);
     }
     backend_.reset();
+    backend_task_runner_.reset();
   }
 
   void Start() {
     DCHECK(thread_checker_.CalledOnValidThread());
 
     MediaClockDevice* clock_device = backend_->GetClock();
     clock_device->SetState(MediaClockDevice::kStateRunning);
     clock_device->SetRate(1.0f);
 
     AudioPipelineDevice* audio_device = backend_->GetAudio();
@@ skipping 34 matching lines @@
   void OnPushFrameStatus(const PushFrameCompletionCallback& completion_cb,
                          MediaComponentDevice::FrameStatus status) {
     DCHECK(thread_checker_.CalledOnValidThread());
     DCHECK_NE(status, MediaComponentDevice::kFramePending);
 
     completion_cb.Run(status == MediaComponentDevice::kFrameSuccess);
   }
 
   const ::media::AudioParameters audio_params_;
   scoped_ptr<MediaPipelineBackend> backend_;
+  scoped_ptr<TaskRunnerImpl> backend_task_runner_;
   base::ThreadChecker thread_checker_;
   DISALLOW_COPY_AND_ASSIGN(Backend);
 };
 
 // CastAudioOutputStream runs on audio thread (AudioManager::GetTaskRunner).
 CastAudioOutputStream::CastAudioOutputStream(
     const ::media::AudioParameters& audio_params,
     CastAudioManager* audio_manager)
     : audio_params_(audio_params),
       audio_manager_(audio_manager),
@@ skipping 156 matching lines @@
   next_push_time_ = now + delay;
 
   audio_task_runner_->PostDelayedTask(
       FROM_HERE,
       base::Bind(&CastAudioOutputStream::PushFrame, weak_factory_.GetWeakPtr()),
       delay);
 }
 
 }  // namespace media
 }  // namespace chromecast