| Index: chromecast/media/cma/pipeline/av_pipeline_impl.cc
|
| diff --git a/chromecast/media/cma/pipeline/av_pipeline_impl.cc b/chromecast/media/cma/pipeline/av_pipeline_impl.cc
|
| index 9ff88e992256dbfb2dc9c178aac5358dcc4adb10..b8730b894bba07a8e93310b9365ca38e3864818f 100644
|
| --- a/chromecast/media/cma/pipeline/av_pipeline_impl.cc
|
| +++ b/chromecast/media/cma/pipeline/av_pipeline_impl.cc
|
| @@ -6,8 +6,9 @@
|
|
|
| #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"
|
| @@ -124,9 +125,8 @@ bool AvPipelineImpl::StartPlayingFrom(
|
|
|
| // 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;
|
| }
|
| @@ -226,9 +226,8 @@ void AvPipelineImpl::OnNewFrame(
|
| 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() {
|
| @@ -237,7 +236,7 @@ void AvPipelineImpl::ProcessPendingBuffer() {
|
|
|
| // 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;
|
| @@ -307,9 +306,8 @@ void AvPipelineImpl::OnFramePushed(MediaComponentDevice::FrameStatus status) {
|
| 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() {
|
|
|