OLD | NEW |
| (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 | |
OLD | NEW |