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

Side by Side Diff: content/browser/media/android/browser_demuxer_android.cc

Issue 2283493003: Delete browser MSE implementation. (Closed)
Patch Set: Actually delete MSP. Cleanse references. Remove AudioTrack usage. Created 4 years, 2 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 unified diff | Download patch
OLDNEW
(Empty)
1 // Copyright 2013 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "content/browser/media/android/browser_demuxer_android.h"
6
7 #include "base/macros.h"
8 #include "content/common/media/media_player_messages_android.h"
9 #include "media/base/media_switches.h"
10
11 namespace content {
12
13 class BrowserDemuxerAndroid::Internal : public media::DemuxerAndroid {
14 public:
15 Internal(const scoped_refptr<BrowserDemuxerAndroid>& demuxer,
16 int demuxer_client_id)
17 : demuxer_(demuxer),
18 demuxer_client_id_(demuxer_client_id) {}
19
20 ~Internal() override {
21 DCHECK(ClientIDExists()) << demuxer_client_id_;
22 demuxer_->RemoveDemuxerClient(demuxer_client_id_);
23 }
24
25 // media::DemuxerAndroid implementation.
26 void Initialize(media::DemuxerAndroidClient* client) override {
27 DCHECK(!ClientIDExists()) << demuxer_client_id_;
28 demuxer_->AddDemuxerClient(demuxer_client_id_, client);
29 }
30
31 void RequestDemuxerData(media::DemuxerStream::Type type) override {
32 DCHECK(ClientIDExists()) << demuxer_client_id_;
33 demuxer_->Send(new MediaPlayerMsg_ReadFromDemuxer(
34 demuxer_client_id_, type));
35 }
36
37 void RequestDemuxerSeek(const base::TimeDelta& time_to_seek,
38 bool is_browser_seek) override {
39 DCHECK(ClientIDExists()) << demuxer_client_id_;
40 demuxer_->Send(new MediaPlayerMsg_DemuxerSeekRequest(
41 demuxer_client_id_, time_to_seek, is_browser_seek));
42 }
43
44 private:
45 // Helper for DCHECKing that the ID is still registered.
46 bool ClientIDExists() {
47 return demuxer_->demuxer_clients_.Lookup(demuxer_client_id_);
48 }
49
50 scoped_refptr<BrowserDemuxerAndroid> demuxer_;
51 int demuxer_client_id_;
52
53 DISALLOW_COPY_AND_ASSIGN(Internal);
54 };
55
56 BrowserDemuxerAndroid::BrowserDemuxerAndroid()
57 : BrowserMessageFilter(MediaPlayerMsgStart),
58 task_runner_(
59 BrowserThread::GetTaskRunnerForThread(BrowserThread::UI).get()) {}
60
61 BrowserDemuxerAndroid::~BrowserDemuxerAndroid() {}
62
63 base::TaskRunner* BrowserDemuxerAndroid::OverrideTaskRunnerForMessage(
64 const IPC::Message& message) {
65
66 switch (message.type()) {
67 case MediaPlayerHostMsg_DemuxerReady::ID:
68 case MediaPlayerHostMsg_ReadFromDemuxerAck::ID:
69 case MediaPlayerHostMsg_DurationChanged::ID:
70 case MediaPlayerHostMsg_DemuxerSeekDone::ID:
71 return task_runner_;
72 }
73
74 return nullptr;
75 }
76
77 bool BrowserDemuxerAndroid::OnMessageReceived(const IPC::Message& message) {
78 bool handled = true;
79 IPC_BEGIN_MESSAGE_MAP(BrowserDemuxerAndroid, message)
80 IPC_MESSAGE_HANDLER(MediaPlayerHostMsg_DemuxerReady, OnDemuxerReady)
81 IPC_MESSAGE_HANDLER(MediaPlayerHostMsg_ReadFromDemuxerAck,
82 OnReadFromDemuxerAck)
83 IPC_MESSAGE_HANDLER(MediaPlayerHostMsg_DurationChanged,
84 OnDurationChanged)
85 IPC_MESSAGE_HANDLER(MediaPlayerHostMsg_DemuxerSeekDone,
86 OnDemuxerSeekDone)
87 IPC_MESSAGE_UNHANDLED(handled = false)
88 IPC_END_MESSAGE_MAP()
89 return handled;
90 }
91
92 std::unique_ptr<media::DemuxerAndroid> BrowserDemuxerAndroid::CreateDemuxer(
93 int demuxer_client_id) {
94 return std::unique_ptr<media::DemuxerAndroid>(
95 new Internal(this, demuxer_client_id));
96 }
97
98 void BrowserDemuxerAndroid::AddDemuxerClient(
99 int demuxer_client_id,
100 media::DemuxerAndroidClient* client) {
101 DVLOG(1) << __FUNCTION__ << " peer_pid=" << peer_pid()
102 << " demuxer_client_id=" << demuxer_client_id;
103 DCHECK(task_runner_->BelongsToCurrentThread());
104
105 demuxer_clients_.AddWithID(client, demuxer_client_id);
106
107 if (pending_configs_.count(demuxer_client_id)) {
108 client->OnDemuxerConfigsAvailable(pending_configs_[demuxer_client_id]);
109 pending_configs_.erase(demuxer_client_id);
110 }
111 }
112
113 void BrowserDemuxerAndroid::RemoveDemuxerClient(int demuxer_client_id) {
114 DVLOG(1) << __FUNCTION__ << " peer_pid=" << peer_pid()
115 << " demuxer_client_id=" << demuxer_client_id;
116 DCHECK(task_runner_->BelongsToCurrentThread());
117
118 demuxer_clients_.Remove(demuxer_client_id);
119 }
120
121 void BrowserDemuxerAndroid::OnDemuxerReady(
122 int demuxer_client_id,
123 const media::DemuxerConfigs& configs) {
124 DCHECK(task_runner_->BelongsToCurrentThread());
125
126 media::DemuxerAndroidClient* client =
127 demuxer_clients_.Lookup(demuxer_client_id);
128
129 if (client)
130 client->OnDemuxerConfigsAvailable(configs);
131 else
132 pending_configs_[demuxer_client_id] = configs;
133 }
134
135 void BrowserDemuxerAndroid::OnReadFromDemuxerAck(
136 int demuxer_client_id,
137 const media::DemuxerData& data) {
138 DCHECK(task_runner_->BelongsToCurrentThread());
139
140 media::DemuxerAndroidClient* client =
141 demuxer_clients_.Lookup(demuxer_client_id);
142
143 if (client)
144 client->OnDemuxerDataAvailable(data);
145 }
146
147 void BrowserDemuxerAndroid::OnDemuxerSeekDone(
148 int demuxer_client_id,
149 const base::TimeDelta& actual_browser_seek_time) {
150 DCHECK(task_runner_->BelongsToCurrentThread());
151
152 media::DemuxerAndroidClient* client =
153 demuxer_clients_.Lookup(demuxer_client_id);
154
155 if (client)
156 client->OnDemuxerSeekDone(actual_browser_seek_time);
157 }
158
159 void BrowserDemuxerAndroid::OnDurationChanged(int demuxer_client_id,
160 const base::TimeDelta& duration) {
161 DCHECK(task_runner_->BelongsToCurrentThread());
162
163 media::DemuxerAndroidClient* client =
164 demuxer_clients_.Lookup(demuxer_client_id);
165
166 if (client)
167 client->OnDemuxerDurationChanged(duration);
168 else
169 pending_configs_[demuxer_client_id].duration = duration;
170 }
171
172 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698