content/browser/media/android/browser_demuxer_android.cc

   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 "content/common/media/media_player_messages_android.h"
   8
   9 namespace content {
  10
  11 class BrowserDemuxerAndroid::Internal : public media::DemuxerAndroid {
  12  public:
  13   Internal(const scoped_refptr<BrowserDemuxerAndroid>& demuxer,
  14            int demuxer_client_id)
  15       : demuxer_(demuxer),
  16         demuxer_client_id_(demuxer_client_id) {}
  17
  18   ~Internal() override {
  19     DCHECK(ClientIDExists()) << demuxer_client_id_;
  20     demuxer_->RemoveDemuxerClient(demuxer_client_id_);
  21   }
  22
  23   // media::DemuxerAndroid implementation.
  24   void Initialize(media::DemuxerAndroidClient* client) override {
  25     DCHECK(!ClientIDExists()) << demuxer_client_id_;
  26     demuxer_->AddDemuxerClient(demuxer_client_id_, client);
  27   }
  28
  29   void RequestDemuxerData(media::DemuxerStream::Type type) override {
  30     DCHECK(ClientIDExists()) << demuxer_client_id_;
  31     demuxer_->Send(new MediaPlayerMsg_ReadFromDemuxer(
  32         demuxer_client_id_, type));
  33   }
  34
  35   void RequestDemuxerSeek(const base::TimeDelta& time_to_seek,
  36                           bool is_browser_seek) override {
  37     DCHECK(ClientIDExists()) << demuxer_client_id_;
  38     demuxer_->Send(new MediaPlayerMsg_DemuxerSeekRequest(
  39         demuxer_client_id_, time_to_seek, is_browser_seek));
  40   }
  41
  42  private:
  43   // Helper for DCHECKing that the ID is still registered.
  44   bool ClientIDExists() {
  45     return demuxer_->demuxer_clients_.Lookup(demuxer_client_id_);
  46   }
  47
  48   scoped_refptr<BrowserDemuxerAndroid> demuxer_;
  49   int demuxer_client_id_;
  50
  51   DISALLOW_COPY_AND_ASSIGN(Internal);
  52 };
  53
  54 BrowserDemuxerAndroid::BrowserDemuxerAndroid()
  55     : BrowserMessageFilter(MediaPlayerMsgStart) {}
  56
  57 BrowserDemuxerAndroid::~BrowserDemuxerAndroid() {}
  58
  59 void BrowserDemuxerAndroid::OverrideThreadForMessage(
  60     const IPC::Message& message,
  61     BrowserThread::ID* thread) {
  62   switch (message.type()) {
  63     case MediaPlayerHostMsg_DemuxerReady::ID:
  64     case MediaPlayerHostMsg_ReadFromDemuxerAck::ID:
  65     case MediaPlayerHostMsg_DurationChanged::ID:
  66     case MediaPlayerHostMsg_DemuxerSeekDone::ID:
  67       *thread = BrowserThread::UI;
  68       return;
  69   }
  70 }
  71
  72 bool BrowserDemuxerAndroid::OnMessageReceived(const IPC::Message& message) {
  73   bool handled = true;
  74   IPC_BEGIN_MESSAGE_MAP(BrowserDemuxerAndroid, message)
  75     IPC_MESSAGE_HANDLER(MediaPlayerHostMsg_DemuxerReady, OnDemuxerReady)
  76     IPC_MESSAGE_HANDLER(MediaPlayerHostMsg_ReadFromDemuxerAck,
  77                         OnReadFromDemuxerAck)
  78     IPC_MESSAGE_HANDLER(MediaPlayerHostMsg_DurationChanged,
  79                         OnDurationChanged)
  80     IPC_MESSAGE_HANDLER(MediaPlayerHostMsg_DemuxerSeekDone,
  81                         OnDemuxerSeekDone)
  82     IPC_MESSAGE_UNHANDLED(handled = false)
  83   IPC_END_MESSAGE_MAP()
  84   return handled;
  85 }
  86
  87 scoped_ptr<media::DemuxerAndroid> BrowserDemuxerAndroid::CreateDemuxer(
  88     int demuxer_client_id) {
  89   return scoped_ptr<media::DemuxerAndroid>(
  90       new Internal(this, demuxer_client_id));
  91 }
  92
  93 void BrowserDemuxerAndroid::AddDemuxerClient(
  94     int demuxer_client_id,
  95     media::DemuxerAndroidClient* client) {
  96   DVLOG(1) << __FUNCTION__ << " peer_pid=" << peer_pid()
  97            << " demuxer_client_id=" << demuxer_client_id;
  98   demuxer_clients_.AddWithID(client, demuxer_client_id);
  99 }
 100
 101 void BrowserDemuxerAndroid::RemoveDemuxerClient(int demuxer_client_id) {
 102   DVLOG(1) << __FUNCTION__ << " peer_pid=" << peer_pid()
 103            << " demuxer_client_id=" << demuxer_client_id;
 104   demuxer_clients_.Remove(demuxer_client_id);
 105 }
 106
 107 void BrowserDemuxerAndroid::OnDemuxerReady(
 108     int demuxer_client_id,
 109     const media::DemuxerConfigs& configs) {
 110   media::DemuxerAndroidClient* client =
 111       demuxer_clients_.Lookup(demuxer_client_id);
 112   if (client)
 113     client->OnDemuxerConfigsAvailable(configs);
 114 }
 115
 116 void BrowserDemuxerAndroid::OnReadFromDemuxerAck(
 117     int demuxer_client_id,
 118     const media::DemuxerData& data) {
 119   media::DemuxerAndroidClient* client =
 120       demuxer_clients_.Lookup(demuxer_client_id);
 121   if (client)
 122     client->OnDemuxerDataAvailable(data);
 123 }
 124
 125 void BrowserDemuxerAndroid::OnDemuxerSeekDone(
 126     int demuxer_client_id,
 127     const base::TimeDelta& actual_browser_seek_time) {
 128   media::DemuxerAndroidClient* client =
 129       demuxer_clients_.Lookup(demuxer_client_id);
 130   if (client)
 131     client->OnDemuxerSeekDone(actual_browser_seek_time);
 132 }
 133
 134 void BrowserDemuxerAndroid::OnDurationChanged(int demuxer_client_id,
 135                                               const base::TimeDelta& duration) {
 136   media::DemuxerAndroidClient* client =
 137       demuxer_clients_.Lookup(demuxer_client_id);
 138   if (client)
 139     client->OnDemuxerDurationChanged(duration);
 140 }
 141
 142 }  // namespace content