Home | History | Annotate | Download | only in services 
      1 // Copyright 2014 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 #ifndef MEDIA_MOJO_SERVICES_MOJO_DEMUXER_STREAM_ADAPTER_H_
      6 #define MEDIA_MOJO_SERVICES_MOJO_DEMUXER_STREAM_ADAPTER_H_
      7 
      8 #include <queue>
      9 
     10 #include "base/memory/weak_ptr.h"
     11 #include "media/base/audio_decoder_config.h"
     12 #include "media/base/demuxer_stream.h"
     13 #include "media/base/video_decoder_config.h"
     14 #include "media/mojo/interfaces/demuxer_stream.mojom.h"
     15 
     16 namespace media {
     17 
     18 // This class acts as a MojoRendererService-side stub for a real
     19 // media::DemuxerStream that is part of a media::Pipeline in a remote
     20 // application. Roughly speaking, it takes a mojo::DemuxerStreamPtr and exposes
     21 // it as a media::DemuxerStream for use by media components.
     22 class MojoDemuxerStreamAdapter : public media::DemuxerStream,
     23                                  public mojo::DemuxerStreamClient {
     24  public:
     25   // |demuxer_stream| is connected to the mojo::DemuxerStream that |this| will
     26   //     become the client of.
     27   // |stream_ready_cb| will be invoked when |stream| has fully initialized
     28   //     and |this| is ready for use.
     29   // NOTE: Illegal to call any methods until |stream_ready_cb| is invoked.
     30   MojoDemuxerStreamAdapter(mojo::DemuxerStreamPtr demuxer_stream,
     31                            const base::Closure& stream_ready_cb);
     32   virtual ~MojoDemuxerStreamAdapter();
     33 
     34   // media::DemuxerStream implementation.
     35   virtual void Read(const ReadCB& read_cb) OVERRIDE;
     36   virtual AudioDecoderConfig audio_decoder_config() OVERRIDE;
     37   virtual VideoDecoderConfig video_decoder_config() OVERRIDE;
     38   virtual Type type() OVERRIDE;
     39   virtual void EnableBitstreamConverter() OVERRIDE;
     40   virtual bool SupportsConfigChanges() OVERRIDE;
     41   virtual VideoRotation video_rotation() OVERRIDE;
     42 
     43   // mojo::DemuxerStreamClient implementation.
     44   virtual void OnStreamReady(mojo::ScopedDataPipeConsumerHandle pipe) OVERRIDE;
     45   virtual void OnAudioDecoderConfigChanged(
     46       mojo::AudioDecoderConfigPtr config) OVERRIDE;
     47 
     48  private:
     49   // The callback from |demuxer_stream_| that a read operation has completed.
     50   // |read_cb| is a callback from the client who invoked Read() on |this|.
     51   void OnBufferReady(mojo::DemuxerStream::Status status,
     52                      mojo::MediaDecoderBufferPtr buffer);
     53 
     54   // See constructor for descriptions.
     55   mojo::DemuxerStreamPtr demuxer_stream_;
     56   base::Closure stream_ready_cb_;
     57 
     58   // The last ReadCB received through a call to Read().
     59   // Used to store the results of OnBufferReady() in the event it is called
     60   // with DemuxerStream::Status::kConfigChanged and we don't have an up to
     61   // date AudioDecoderConfig yet. In that case we can't forward the results
     62   // on to the caller of Read() until OnAudioDecoderConfigChanged is observed.
     63   DemuxerStream::ReadCB read_cb_;
     64 
     65   // The front of the queue is the current config. We pop when we observe
     66   // DemuxerStatus::CONFIG_CHANGED.
     67   std::queue<media::AudioDecoderConfig> config_queue_;
     68 
     69   base::WeakPtrFactory<MojoDemuxerStreamAdapter> weak_factory_;
     70   DISALLOW_COPY_AND_ASSIGN(MojoDemuxerStreamAdapter);
     71 };
     72 
     73 }  // namespace media
     74 
     75 #endif  // MEDIA_MOJO_SERVICES_MOJO_DEMUXER_STREAM_ADAPTER_H_
     76