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