Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(675)

Unified Diff: content/browser/media/android/browser_demuxer_android.cc

Issue 1132973002: Revert of Added stub MediaSourcePlayer for developing behind the flag (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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
« no previous file with comments | « content/browser/media/android/browser_demuxer_android.h ('k') | content/browser/media/android/browser_media_player_manager.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698