Chromecast: MessageLoopProxy cleanup --> SingleThreadTaskRunner.

chromecast/media/cma/pipeline/av_pipeline_impl.cc

 // Copyright 2014 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/cma/pipeline/av_pipeline_impl.h"
 
 #include "base/bind.h"
 #include "base/location.h"
-#include "base/message_loop/message_loop_proxy.h"
+#include "base/single_thread_task_runner.h"
 #include "base/strings/string_number_conversions.h"
+#include "base/thread_task_runner_handle.h"
 #include "chromecast/media/base/decrypt_context.h"
 #include "chromecast/media/cdm/browser_cdm_cast.h"
 #include "chromecast/media/cma/backend/media_clock_device.h"
 #include "chromecast/media/cma/backend/media_component_device.h"
 #include "chromecast/media/cma/base/buffering_frame_provider.h"
 #include "chromecast/media/cma/base/buffering_state.h"
 #include "chromecast/media/cma/base/cma_logging.h"
 #include "chromecast/media/cma/base/coded_frame_provider.h"
 #include "chromecast/media/cma/base/decoder_buffer_base.h"
 #include "chromecast/media/cma/pipeline/decrypt_util.h"
@@ skipping 96 matching lines @@
   DCHECK(frame_provider_);
   buffering_state_ = buffering_state;
   if (buffering_state_.get())
     buffering_state_->SetMediaTime(time);
 
   if (!media_component_device_->SetState(MediaComponentDevice::kStateRunning))
     return false;
 
   // Start feeding the pipeline.
   enable_feeding_ = true;
-  base::MessageLoopProxy::current()->PostTask(
-      FROM_HERE,
-      base::Bind(&AvPipelineImpl::FetchBufferIfNeeded, weak_this_));
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
+      FROM_HERE, base::Bind(&AvPipelineImpl::FetchBufferIfNeeded, weak_this_));
 
   return true;
 }
 
 void AvPipelineImpl::Flush(const base::Closure& done_cb) {
   DCHECK(thread_checker_.CalledOnValidThread());
   DCHECK_EQ(state_, kFlushing);
   DCHECK_EQ(
       media_component_device_->GetState(), MediaComponentDevice::kStateRunning);
   // Note: returning to idle state aborts any pending frame push.
@@ skipping 79 matching lines @@
     const ::media::VideoDecoderConfig& video_config) {
   DCHECK(thread_checker_.CalledOnValidThread());
   pending_read_ = false;
 
   if (audio_config.IsValidConfig() || video_config.IsValidConfig())
     update_config_cb_.Run(audio_config, video_config);
 
   pending_buffer_ = buffer;
   ProcessPendingBuffer();
 
-  base::MessageLoopProxy::current()->PostTask(
-      FROM_HERE,
-      base::Bind(&AvPipelineImpl::FetchBufferIfNeeded, weak_this_));
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
+      FROM_HERE, base::Bind(&AvPipelineImpl::FetchBufferIfNeeded, weak_this_));
 }
 
 void AvPipelineImpl::ProcessPendingBuffer() {
   if (!enable_feeding_)
     return;
 
   // Initiate a read if there isn't already one.
   if (!pending_buffer_.get() && !pending_read_) {
-    base::MessageLoopProxy::current()->PostTask(
+    base::ThreadTaskRunnerHandle::Get()->PostTask(
         FROM_HERE,
         base::Bind(&AvPipelineImpl::FetchBufferIfNeeded, weak_this_));
     return;
   }
 
   if (!pending_buffer_.get() || pending_push_)
     return;
 
   // Break the feeding loop when the end of stream is reached.
   if (pending_buffer_->end_of_stream()) {
@@ skipping 49 matching lines @@
 
 void AvPipelineImpl::OnFramePushed(MediaComponentDevice::FrameStatus status) {
   DCHECK(thread_checker_.CalledOnValidThread());
   pending_push_ = false;
   if (status == MediaComponentDevice::kFrameFailed) {
     LOG(WARNING) << "AvPipelineImpl: PushFrame failed";
     enable_feeding_ = false;
     state_ = kError;
     return;
   }
-  base::MessageLoopProxy::current()->PostTask(
-      FROM_HERE,
-      base::Bind(&AvPipelineImpl::ProcessPendingBuffer, weak_this_));
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
+      FROM_HERE, base::Bind(&AvPipelineImpl::ProcessPendingBuffer, weak_this_));
 }
 
 void AvPipelineImpl::OnCdmStateChanged() {
   DCHECK(thread_checker_.CalledOnValidThread());
 
   // Update the buffering state if needed.
   if (buffering_state_.get())
     UpdatePlayableFrames();
 
   // Process the pending buffer in case the CDM now has the frame key id.
@@ skipping 55 matching lines @@
       }
     }
 
     // The frame is playable: remove it from the list of non playable frames.
     non_playable_frames_.pop_front();
   }
 }
 
 }  // namespace media
 }  // namespace chromecast