remoting_renderer_factory.h 2.8 KB

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