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
|
// 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_RENDERER_FRAME_FRAME_INJECTING_DEMUXER_H_
#define COMPONENTS_CAST_STREAMING_RENDERER_FRAME_FRAME_INJECTING_DEMUXER_H_
#include <optional>
#include "base/memory/raw_ptr.h"
#include "base/task/sequenced_task_runner.h"
#include "components/cast_streaming/common/public/mojom/demuxer_connector.mojom.h"
#include "media/base/demuxer.h"
namespace cast_streaming {
class StreamTimestampOffsetTracker;
class FrameInjectingAudioDemuxerStream;
class FrameInjectingVideoDemuxerStream;
class DemuxerConnector;
// media::Demuxer implementation for a Cast Streaming Receiver.
// This object is instantiated on the main thread, whose task runner is stored
// as |original_task_runner_|. OnStreamsInitialized() is the only method called
// on the main thread. Every other method is called on the media thread, whose
// task runner is |media_task_runner_|.
// TODO(crbug.com/40131115): Simplify the FrameInjectingDemuxer initialization
// sequence when the DemuxerConnector Component has been implemented.
class FrameInjectingDemuxer final : public media::Demuxer {
public:
FrameInjectingDemuxer(
DemuxerConnector* demuxer_connector,
scoped_refptr<base::SequencedTaskRunner> media_task_runner);
~FrameInjectingDemuxer() override;
FrameInjectingDemuxer(const FrameInjectingDemuxer&) = delete;
FrameInjectingDemuxer& operator=(const FrameInjectingDemuxer&) = delete;
void OnStreamsInitialized(
mojom::AudioStreamInitializationInfoPtr audio_stream_info,
mojom::VideoStreamInitializationInfoPtr video_stream_info);
private:
void OnStreamsInitializedOnMediaThread(
mojom::AudioStreamInitializationInfoPtr audio_stream_info,
mojom::VideoStreamInitializationInfoPtr video_stream_info);
void OnStreamInitializationComplete();
// media::Demuxer implementation.
std::vector<media::DemuxerStream*> GetAllStreams() override;
std::string GetDisplayName() const override;
media::DemuxerType GetDemuxerType() const override;
void Initialize(media::DemuxerHost* host,
media::PipelineStatusCallback status_cb) override;
void AbortPendingReads() override;
void StartWaitingForSeek(base::TimeDelta seek_time) override;
void CancelPendingSeek(base::TimeDelta seek_time) override;
void Seek(base::TimeDelta time,
media::PipelineStatusCallback status_cb) override;
bool IsSeekable() const override;
void Stop() override;
base::TimeDelta GetStartTime() const override;
base::Time GetTimelineOffset() const override;
int64_t GetMemoryUsage() const override;
std::optional<media::container_names::MediaContainerName>
GetContainerForMetrics() const override;
void OnTracksChanged(media::DemuxerStream::Type track_type,
std::optional<media::MediaTrack::Id> track_id,
base::TimeDelta curr_time,
TrackChangeCB change_completed_cb) override;
void SetPlaybackRate(double rate) override {}
// The number of initialized streams that have yet to call
// OnStreamInitializationComplete().
int pending_stream_initialization_callbacks_ = 0;
scoped_refptr<base::SequencedTaskRunner> media_task_runner_;
scoped_refptr<base::SequencedTaskRunner> original_task_runner_;
raw_ptr<media::DemuxerHost> host_ = nullptr;
scoped_refptr<StreamTimestampOffsetTracker> timestamp_tracker_;
std::unique_ptr<FrameInjectingAudioDemuxerStream> audio_stream_;
std::unique_ptr<FrameInjectingVideoDemuxerStream> video_stream_;
// Set to true if the Demuxer was successfully initialized.
bool was_initialization_successful_ = false;
media::PipelineStatusCallback initialized_cb_;
const raw_ptr<DemuxerConnector> demuxer_connector_;
base::WeakPtrFactory<FrameInjectingDemuxer> weak_factory_;
};
} // namespace cast_streaming
#endif // COMPONENTS_CAST_STREAMING_RENDERER_FRAME_FRAME_INJECTING_DEMUXER_H_
|
