media/remoting/remoting_renderer_factory.h

   1 // Copyright 2020 The Chromium Authors
   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_REMOTING_REMOTING_RENDERER_FACTORY_H_
   6 #define MEDIA_REMOTING_REMOTING_RENDERER_FACTORY_H_
   7
   8 #include "base/memory/raw_ptr.h"
   9 #include "base/task/sequenced_task_runner.h"
  10 #include "media/base/renderer_factory.h"
  11 #include "media/mojo/mojom/remoting.mojom.h"
  12 #include "mojo/public/cpp/bindings/pending_remote.h"
  13 #include "third_party/openscreen/src/cast/streaming/rpc_messenger.h"
  14
  15 namespace media {
  16 namespace remoting {
  17
  18 class Receiver;
  19 class ReceiverController;
  20
  21 class RemotingRendererFactory : public RendererFactory {
  22  public:
  23   RemotingRendererFactory(
  24       mojo::PendingRemote<mojom::Remotee> remotee,
  25       std::unique_ptr<RendererFactory> renderer_factory,
  26       const scoped_refptr<base::SequencedTaskRunner>& media_task_runner);
  27   ~RemotingRendererFactory() override;
  28
  29   // RendererFactory implementation
  30   std::unique_ptr<Renderer> CreateRenderer(
  31       const scoped_refptr<base::SequencedTaskRunner>& media_task_runner,
  32       const scoped_refptr<base::TaskRunner>& worker_task_runner,
  33       AudioRendererSink* audio_renderer_sink,
  34       VideoRendererSink* video_renderer_sink,
  35       RequestOverlayInfoCB request_overlay_info_cb,
  36       const gfx::ColorSpace& target_color_space) override;
  37
  38  private:
  39   // Callback function when RPC message is received.
  40   void OnReceivedRpc(std::unique_ptr<openscreen::cast::RpcMessage> message);
  41   void OnAcquireRenderer(std::unique_ptr<openscreen::cast::RpcMessage> message);
  42   void OnAcquireRendererDone(int receiver_rpc_handle);
  43
  44   // Indicates whether RPC_ACQUIRE_RENDERER_DONE is sent or not.
  45   bool is_acquire_renderer_done_sent_ = false;
  46
  47   const raw_ptr<ReceiverController> receiver_controller_;
  48
  49   const raw_ptr<openscreen::cast::RpcMessenger> rpc_messenger_;
  50
  51   // The RPC handle used by all Receiver instances created by |this|. Sent only
  52   // once to the sender side, through RPC_ACQUIRE_RENDERER_DONE, regardless of
  53   // how many times CreateRenderer() is called."
  54   const int renderer_handle_ = openscreen::cast::RpcMessenger::kInvalidHandle;
  55
  56   // The RPC handle of the CourierRenderer on the sender side. Will be received
  57   // once, via an RPC_ACQUIRE_RENDERER message"
  58   int remote_renderer_handle_ = openscreen::cast::RpcMessenger::kInvalidHandle;
  59
  60   // Used to set remote handle if receiving RPC_ACQUIRE_RENDERER after
  61   // CreateRenderer() is called.
  62   base::WeakPtr<Receiver> waiting_for_remote_handle_receiver_;
  63   std::unique_ptr<RendererFactory> real_renderer_factory_;
  64
  65   // Used to instantiate |receiver_|.
  66   const scoped_refptr<base::SequencedTaskRunner> media_task_runner_;
  67   base::WeakPtrFactory<RemotingRendererFactory> weak_factory_{this};
  68 };
  69
  70 }  // namespace remoting
  71 }  // namespace media
  72
  73 #endif  // MEDIA_REMOTING_REMOTING_RENDERER_FACTORY_H_