chromecast/renderer/media/video_pipeline_proxy.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_RENDERER_MEDIA_VIDEO_PIPELINE_PROXY_H_
   6 #define CHROMECAST_RENDERER_MEDIA_VIDEO_PIPELINE_PROXY_H_
   7
   8 #include "base/macros.h"
   9 #include "base/memory/ref_counted.h"
  10 #include "base/memory/scoped_ptr.h"
  11 #include "base/memory/weak_ptr.h"
  12 #include "base/threading/thread_checker.h"
  13 #include "chromecast/media/cma/pipeline/video_pipeline.h"
  14 #include "media/base/pipeline_status.h"
  15
  16 namespace base {
  17 class MessageLoopProxy;
  18 class SharedMemory;
  19 }
  20
  21 namespace media {
  22 class VideoDecoderConfig;
  23 }
  24
  25 namespace chromecast {
  26 namespace media {
  27 struct AvPipelineClient;
  28 class AvStreamerProxy;
  29 class CodedFrameProvider;
  30 class VideoPipelineProxyInternal;
  31 class MediaChannelProxy;
  32
  33 class VideoPipelineProxy : public VideoPipeline {
  34  public:
  35   VideoPipelineProxy(
  36       scoped_refptr<base::MessageLoopProxy> io_message_loop_proxy,
  37       scoped_refptr<MediaChannelProxy> media_channel_proxy);
  38   ~VideoPipelineProxy() override;
  39
  40   void Initialize(const ::media::VideoDecoderConfig& config,
  41                   scoped_ptr<CodedFrameProvider> frame_provider,
  42                   const ::media::PipelineStatusCB& status_cb);
  43   void StartFeeding();
  44   void Flush(const base::Closure& done_cb);
  45   void Stop();
  46
  47   // VideoPipeline implementation.
  48   void SetClient(const VideoPipelineClient& video_client) override;
  49
  50  private:
  51   base::ThreadChecker thread_checker_;
  52
  53   void OnAvPipeCreated(
  54       const ::media::VideoDecoderConfig& config,
  55       const ::media::PipelineStatusCB& status_cb,
  56       scoped_ptr<base::SharedMemory> shared_memory);
  57   void OnPipeWrite();
  58   void OnPipeRead();
  59
  60   scoped_refptr<base::MessageLoopProxy> io_message_loop_proxy_;
  61
  62   // |proxy_| main goal is to convert function calls to IPC messages.
  63   scoped_ptr<VideoPipelineProxyInternal> proxy_;
  64
  65   scoped_ptr<AvStreamerProxy> video_streamer_;
  66
  67   base::WeakPtr<VideoPipelineProxy> weak_this_;
  68   base::WeakPtrFactory<VideoPipelineProxy> weak_factory_;
  69
  70   DISALLOW_COPY_AND_ASSIGN(VideoPipelineProxy);
  71 };
  72
  73 }  // namespace media
  74 }  // namespace chromecast
  75
  76 #endif  // CHROMECAST_RENDERER_MEDIA_VIDEO_PIPELINE_PROXY_H_