chromecast/media/cma/pipeline/video_pipeline_impl.h

   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 CHROMECAST_MEDIA_CMA_BASE_VIDEO_PIPELINE_IMPL_H_
   6 #define CHROMECAST_MEDIA_CMA_BASE_VIDEO_PIPELINE_IMPL_H_
   7
   8 #include <vector>
   9
  10 #include "base/callback.h"
  11 #include "base/memory/ref_counted.h"
  12 #include "base/memory/weak_ptr.h"
  13 #include "base/threading/thread_checker.h"
  14 #include "chromecast/media/cma/pipeline/video_pipeline.h"
  15 #include "chromecast/media/cma/pipeline/video_pipeline_client.h"
  16 #include "chromecast/public/media/stream_id.h"
  17 #include "chromecast/public/media/video_pipeline_device.h"
  18
  19 namespace media {
  20 class AudioDecoderConfig;
  21 class VideoDecoderConfig;
  22 }
  23
  24 namespace chromecast {
  25 struct Size;
  26 namespace media {
  27 class AvPipelineImpl;
  28 class BrowserCdmCast;
  29 class BufferingState;
  30 class CodedFrameProvider;
  31 class VideoPipelineDevice;
  32
  33 class VideoPipelineImpl : public VideoPipeline {
  34  public:
  35   // |buffering_controller| can be NULL.
  36   explicit VideoPipelineImpl(VideoPipelineDevice* video_device);
  37   ~VideoPipelineImpl() override;
  38
  39   // Input port of the pipeline.
  40   void SetCodedFrameProvider(scoped_ptr<CodedFrameProvider> frame_provider);
  41
  42   // Provide the CDM to use to decrypt samples.
  43   void SetCdm(BrowserCdmCast* media_keys);
  44
  45   // Functions to control the state of the audio pipeline.
  46   void Initialize(
  47       const std::vector<::media::VideoDecoderConfig>& configs,
  48       scoped_ptr<CodedFrameProvider> frame_provider,
  49       const ::media::PipelineStatusCB& status_cb);
  50   bool StartPlayingFrom(base::TimeDelta time,
  51                         const scoped_refptr<BufferingState>& buffering_state);
  52   void Flush(const ::media::PipelineStatusCB& status_cb);
  53   void Stop();
  54
  55   // Update the playback statistics for this video stream.
  56   void UpdateStatistics();
  57
  58   // VideoPipeline implementation.
  59   void SetClient(const VideoPipelineClient& client) override;
  60
  61  private:
  62   class DeviceClientImpl;
  63   friend class DeviceClientImpl;
  64
  65   void OnFlushDone(const ::media::PipelineStatusCB& status_cb);
  66   void OnUpdateConfig(StreamId id,
  67                       const ::media::AudioDecoderConfig& audio_config,
  68                       const ::media::VideoDecoderConfig& video_config);
  69   void OnNaturalSizeChanged(const Size& size);
  70
  71   VideoPipelineDevice* video_device_;
  72
  73   scoped_ptr<AvPipelineImpl> av_pipeline_impl_;
  74   VideoPipelineClient video_client_;
  75
  76   ::media::PipelineStatistics previous_stats_;
  77
  78   base::WeakPtr<VideoPipelineImpl> weak_this_;
  79   base::WeakPtrFactory<VideoPipelineImpl> weak_factory_;
  80
  81   DISALLOW_COPY_AND_ASSIGN(VideoPipelineImpl);
  82 };
  83
  84 }  // namespace media
  85 }  // namespace chromecast
  86
  87 #endif  // CHROMECAST_MEDIA_CMA_BASE_VIDEO_PIPELINE_IMPL_H_