| 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 |
|---|
Chromium Code Reviews
Issue 2283493003:
Delete browser MSE implementation. (Closed)
