1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
// Copyright 2020 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef COMPONENTS_CAST_STREAMING_BROWSER_RECEIVER_SESSION_IMPL_H_
#define COMPONENTS_CAST_STREAMING_BROWSER_RECEIVER_SESSION_IMPL_H_
#include "base/memory/raw_ptr.h"
#include "base/memory/weak_ptr.h"
#include "base/sequence_checker.h"
#include "components/cast_streaming/browser/cast_streaming_session.h"
#include "components/cast_streaming/browser/frame/demuxer_stream_data_provider.h"
#include "components/cast_streaming/browser/public/receiver_config.h"
#include "components/cast_streaming/browser/public/receiver_session.h"
#include "components/cast_streaming/common/public/mojom/demuxer_connector.mojom.h"
#include "components/cast_streaming/common/public/mojom/renderer_controller.mojom.h"
#include "media/mojo/mojom/media_types.mojom.h"
#include "mojo/public/cpp/bindings/associated_remote.h"
#include "mojo/public/cpp/bindings/remote.h"
#include "third_party/abseil-cpp/absl/types/optional.h"
namespace cast_streaming {
// Owns the CastStreamingSession and sends buffers to the renderer process via
// a Mojo service.
class ReceiverSessionImpl final
: public cast_streaming::CastStreamingSession::Client,
public ReceiverSession {
public:
// |av_constraints| specifies the supported media codecs and limitations
// surrounding this support.
ReceiverSessionImpl(ReceiverConfig av_constraints,
MessagePortProvider message_port_provider,
ReceiverSession::Client* client);
~ReceiverSessionImpl() override;
ReceiverSessionImpl(const ReceiverSessionImpl&) = delete;
ReceiverSessionImpl& operator=(const ReceiverSessionImpl&) = delete;
// ReceiverSession implementation.
void StartStreamingAsync(mojo::AssociatedRemote<mojom::DemuxerConnector>
demuxer_connector) override;
void StartStreamingAsync(
mojo::AssociatedRemote<mojom::DemuxerConnector> demuxer_connector,
mojo::AssociatedRemote<mojom::RendererController> renderer_controller)
override;
RendererController* GetRendererControls() override;
private:
class RendererControllerImpl : public ReceiverSession::RendererController {
public:
explicit RendererControllerImpl(
base::OnceCallback<void()> on_mojo_disconnect);
~RendererControllerImpl() override;
mojo::PendingReceiver<media::mojom::Renderer> Bind();
// ReceiverSession::RendererController overrides.
bool IsValid() const override;
void SetVolume(float volume) override;
private:
base::OnceCallback<void()> on_mojo_disconnect_;
mojo::Remote<media::mojom::Renderer> renderer_controls_;
};
// Helper function to execute code shared between the two implementations of
// StartStreamingAsync().
void StartStreamingAsyncInternal(
mojo::AssociatedRemote<mojom::DemuxerConnector> demuxer_connector);
void PreloadBuffersAndStartPlayback();
// Handler for |demuxer_connector_| disconnect.
void OnMojoDisconnect();
// Callback for mojom::DemuxerConnector::EnableReceiver()
void OnReceiverEnabled();
// Informs the client of updated configs.
void InformClientOfConfigChange();
// cast_streaming::CastStreamingSession::Client implementation.
void OnSessionInitialization(
StreamingInitializationInfo initialization_info,
absl::optional<mojo::ScopedDataPipeConsumerHandle> audio_pipe_consumer,
absl::optional<mojo::ScopedDataPipeConsumerHandle> video_pipe_consumer)
override;
void OnAudioBufferReceived(media::mojom::DecoderBufferPtr buffer) override;
void OnVideoBufferReceived(media::mojom::DecoderBufferPtr buffer) override;
void OnSessionReinitializationPending() override;
void OnSessionReinitialization(
StreamingInitializationInfo initialization_info,
absl::optional<mojo::ScopedDataPipeConsumerHandle> audio_pipe_consumer,
absl::optional<mojo::ScopedDataPipeConsumerHandle> video_pipe_consumer)
override;
void OnSessionEnded() override;
// Populated in the ctor, and empty following a call to either
// OnReceiverEnabled() or OnMojoDisconnect().
MessagePortProvider message_port_provider_;
ReceiverConfig av_constraints_;
mojo::AssociatedRemote<mojom::DemuxerConnector> demuxer_connector_;
cast_streaming::CastStreamingSession cast_streaming_session_;
std::unique_ptr<AudioDemuxerStreamDataProvider>
audio_demuxer_stream_data_provider_;
std::unique_ptr<VideoDemuxerStreamDataProvider>
video_demuxer_stream_data_provider_;
const raw_ptr<ReceiverSession::Client> client_;
std::unique_ptr<RendererControllerImpl> external_renderer_controls_;
absl::optional<RendererControllerConfig> renderer_control_config_;
base::WeakPtrFactory<ReceiverSessionImpl> weak_factory_;
};
} // namespace cast_streaming
#endif // COMPONENTS_CAST_STREAMING_BROWSER_RECEIVER_SESSION_IMPL_H_
|
