| Index: content/browser/media/android/browser_demuxer_android.cc
|
| diff --git a/content/browser/media/android/browser_demuxer_android.cc b/content/browser/media/android/browser_demuxer_android.cc
|
| index ddaca7efa3cedbe025f748914a01b633141d1621..ed462032fdd7f6ad3d278996d36ae4009370ecca 100644
|
| --- a/content/browser/media/android/browser_demuxer_android.cc
|
| +++ b/content/browser/media/android/browser_demuxer_android.cc
|
| @@ -4,10 +4,7 @@
|
|
|
| #include "content/browser/media/android/browser_demuxer_android.h"
|
|
|
| -#include "base/command_line.h"
|
| #include "content/common/media/media_player_messages_android.h"
|
| -#include "media/base/android/media_codec_player.h"
|
| -#include "media/base/media_switches.h"
|
|
|
| namespace content {
|
|
|
| @@ -55,32 +52,21 @@
|
| };
|
|
|
| BrowserDemuxerAndroid::BrowserDemuxerAndroid()
|
| - : BrowserMessageFilter(MediaPlayerMsgStart) {
|
| - bool enable_media_thread =
|
| - base::CommandLine::ForCurrentProcess()->
|
| - HasSwitch(switches::kEnableMediaThreadForMediaPlayback);
|
| -
|
| - task_runner_ =
|
| - enable_media_thread ?
|
| - media::GetMediaTaskRunner().get() :
|
| - BrowserThread::GetMessageLoopProxyForThread(BrowserThread::UI).get();
|
| -
|
| -}
|
| + : BrowserMessageFilter(MediaPlayerMsgStart) {}
|
|
|
| BrowserDemuxerAndroid::~BrowserDemuxerAndroid() {}
|
|
|
| -base::TaskRunner* BrowserDemuxerAndroid::OverrideTaskRunnerForMessage(
|
| - const IPC::Message& message) {
|
| -
|
| +void BrowserDemuxerAndroid::OverrideThreadForMessage(
|
| + const IPC::Message& message,
|
| + BrowserThread::ID* thread) {
|
| switch (message.type()) {
|
| case MediaPlayerHostMsg_DemuxerReady::ID:
|
| case MediaPlayerHostMsg_ReadFromDemuxerAck::ID:
|
| case MediaPlayerHostMsg_DurationChanged::ID:
|
| case MediaPlayerHostMsg_DemuxerSeekDone::ID:
|
| - return task_runner_;
|
| + *thread = BrowserThread::UI;
|
| + return;
|
| }
|
| -
|
| - return nullptr;
|
| }
|
|
|
| bool BrowserDemuxerAndroid::OnMessageReceived(const IPC::Message& message) {
|
| @@ -109,46 +95,29 @@
|
| media::DemuxerAndroidClient* client) {
|
| DVLOG(1) << __FUNCTION__ << " peer_pid=" << peer_pid()
|
| << " demuxer_client_id=" << demuxer_client_id;
|
| - DCHECK(task_runner_->BelongsToCurrentThread());
|
| -
|
| demuxer_clients_.AddWithID(client, demuxer_client_id);
|
| -
|
| - if (pending_configs_.count(demuxer_client_id)) {
|
| - client->OnDemuxerConfigsAvailable(pending_configs_[demuxer_client_id]);
|
| - pending_configs_.erase(demuxer_client_id);
|
| - }
|
| }
|
|
|
| void BrowserDemuxerAndroid::RemoveDemuxerClient(int demuxer_client_id) {
|
| DVLOG(1) << __FUNCTION__ << " peer_pid=" << peer_pid()
|
| << " demuxer_client_id=" << demuxer_client_id;
|
| - DCHECK(task_runner_->BelongsToCurrentThread());
|
| -
|
| demuxer_clients_.Remove(demuxer_client_id);
|
| }
|
|
|
| void BrowserDemuxerAndroid::OnDemuxerReady(
|
| int demuxer_client_id,
|
| const media::DemuxerConfigs& configs) {
|
| - DCHECK(task_runner_->BelongsToCurrentThread());
|
| -
|
| media::DemuxerAndroidClient* client =
|
| demuxer_clients_.Lookup(demuxer_client_id);
|
| -
|
| if (client)
|
| client->OnDemuxerConfigsAvailable(configs);
|
| - else
|
| - pending_configs_[demuxer_client_id] = configs;
|
| }
|
|
|
| void BrowserDemuxerAndroid::OnReadFromDemuxerAck(
|
| int demuxer_client_id,
|
| const media::DemuxerData& data) {
|
| - DCHECK(task_runner_->BelongsToCurrentThread());
|
| -
|
| media::DemuxerAndroidClient* client =
|
| demuxer_clients_.Lookup(demuxer_client_id);
|
| -
|
| if (client)
|
| client->OnDemuxerDataAvailable(data);
|
| }
|
| @@ -156,26 +125,18 @@
|
| void BrowserDemuxerAndroid::OnDemuxerSeekDone(
|
| int demuxer_client_id,
|
| const base::TimeDelta& actual_browser_seek_time) {
|
| - DCHECK(task_runner_->BelongsToCurrentThread());
|
| -
|
| media::DemuxerAndroidClient* client =
|
| demuxer_clients_.Lookup(demuxer_client_id);
|
| -
|
| if (client)
|
| client->OnDemuxerSeekDone(actual_browser_seek_time);
|
| }
|
|
|
| void BrowserDemuxerAndroid::OnDurationChanged(int demuxer_client_id,
|
| const base::TimeDelta& duration) {
|
| - DCHECK(task_runner_->BelongsToCurrentThread());
|
| -
|
| media::DemuxerAndroidClient* client =
|
| demuxer_clients_.Lookup(demuxer_client_id);
|
| -
|
| if (client)
|
| client->OnDemuxerDurationChanged(duration);
|
| - else
|
| - pending_configs_[demuxer_client_id].duration = duration;
|
| }
|
|
|
| } // namespace content
|
|
|