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
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
|
/* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/* vim:set ts=2 sw=2 sts=2 et cindent: */
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
#if !defined(MediaSourceDemuxer_h_)
# define MediaSourceDemuxer_h_
# include "MediaDataDemuxer.h"
# include "MediaResource.h"
# include "MediaSource.h"
# include "TrackBuffersManager.h"
# include "mozilla/Atomics.h"
# include "mozilla/Maybe.h"
# include "mozilla/Mutex.h"
# include "mozilla/TaskQueue.h"
# include "mozilla/dom/MediaDebugInfoBinding.h"
namespace mozilla {
class AbstractThread;
class MediaResult;
class MediaSourceTrackDemuxer;
DDLoggedTypeDeclNameAndBase(MediaSourceDemuxer, MediaDataDemuxer);
DDLoggedTypeNameAndBase(MediaSourceTrackDemuxer, MediaTrackDemuxer);
class MediaSourceDemuxer : public MediaDataDemuxer,
public DecoderDoctorLifeLogger<MediaSourceDemuxer> {
public:
explicit MediaSourceDemuxer(AbstractThread* aAbstractMainThread);
RefPtr<InitPromise> Init() override;
uint32_t GetNumberTracks(TrackInfo::TrackType aType) const override;
already_AddRefed<MediaTrackDemuxer> GetTrackDemuxer(
TrackInfo::TrackType aType, uint32_t aTrackNumber) override;
bool IsSeekable() const override;
UniquePtr<EncryptionInfo> GetCrypto() override;
bool ShouldComputeStartTime() const override { return false; }
/* interface for TrackBuffersManager */
void AttachSourceBuffer(const RefPtr<TrackBuffersManager>& aSourceBuffer);
void DetachSourceBuffer(const RefPtr<TrackBuffersManager>& aSourceBuffer);
TaskQueue* GetTaskQueue() { return mTaskQueue; }
void NotifyInitDataArrived();
// Populates aInfo with info describing the state of the MediaSource internal
// buffered data. Used for debugging purposes.
// aInfo should *not* be accessed until the returned promise has been resolved
// or rejected.
RefPtr<GenericPromise> GetDebugInfo(
dom::MediaSourceDemuxerDebugInfo& aInfo) const;
void AddSizeOfResources(MediaSourceDecoder::ResourceSizes* aSizes);
// Gap allowed between frames.
// Due to inaccuracies in determining buffer end
// frames (Bug 1065207). This value is based on videos seen in the wild.
static constexpr media::TimeUnit EOS_FUZZ =
media::TimeUnit::FromMicroseconds(500000);
// Largest gap allowed between muxed streams with different
// start times. The specs suggest up to a "reasonably short" gap of
// one second, which we use here.
// See: https://www.w3.org/TR/media-source-2/#presentation-start-time
static constexpr media::TimeUnit EOS_FUZZ_START =
media::TimeUnit::FromMicroseconds(1000000);
private:
~MediaSourceDemuxer();
friend class MediaSourceTrackDemuxer;
// Scan source buffers and update information.
bool ScanSourceBuffersForContent();
RefPtr<TrackBuffersManager> GetManager(TrackInfo::TrackType aType)
MOZ_REQUIRES(mMutex);
TrackInfo* GetTrackInfo(TrackInfo::TrackType) MOZ_REQUIRES(mMutex);
void DoAttachSourceBuffer(RefPtr<TrackBuffersManager>&& aSourceBuffer);
void DoDetachSourceBuffer(const RefPtr<TrackBuffersManager>& aSourceBuffer);
bool OnTaskQueue() {
return !GetTaskQueue() || GetTaskQueue()->IsCurrentThreadIn();
}
RefPtr<TaskQueue> mTaskQueue;
// Accessed on mTaskQueue or from destructor
nsTArray<RefPtr<TrackBuffersManager>> mSourceBuffers;
MozPromiseHolder<InitPromise> mInitPromise;
// Mutex to protect members below across multiple threads.
mutable Mutex mMutex;
nsTArray<RefPtr<MediaSourceTrackDemuxer>> mDemuxers MOZ_GUARDED_BY(mMutex);
RefPtr<TrackBuffersManager> mAudioTrack MOZ_GUARDED_BY(mMutex);
RefPtr<TrackBuffersManager> mVideoTrack MOZ_GUARDED_BY(mMutex);
MediaInfo mInfo MOZ_GUARDED_BY(mMutex);
};
class MediaSourceTrackDemuxer
: public MediaTrackDemuxer,
public DecoderDoctorLifeLogger<MediaSourceTrackDemuxer>,
public SingleWriterLockOwner {
public:
MediaSourceTrackDemuxer(MediaSourceDemuxer* aParent,
TrackInfo::TrackType aType,
TrackBuffersManager* aManager)
MOZ_REQUIRES(aParent->mMutex);
bool OnWritingThread() const override { return OnTaskQueue(); }
UniquePtr<TrackInfo> GetInfo() const override;
RefPtr<SeekPromise> Seek(const media::TimeUnit& aTime) override;
RefPtr<SamplesPromise> GetSamples(int32_t aNumSamples = 1) override;
void Reset() override;
nsresult GetNextRandomAccessPoint(media::TimeUnit* aTime) override;
RefPtr<SkipAccessPointPromise> SkipToNextRandomAccessPoint(
const media::TimeUnit& aTimeThreshold) override;
media::TimeIntervals GetBuffered() override;
void BreakCycles() override;
bool GetSamplesMayBlock() const override { return false; }
bool HasManager(TrackBuffersManager* aManager) const;
void DetachManager();
private:
bool OnTaskQueue() const { return mTaskQueue->IsCurrentThreadIn(); }
RefPtr<SeekPromise> DoSeek(const media::TimeUnit& aTime);
RefPtr<SamplesPromise> DoGetSamples(int32_t aNumSamples);
RefPtr<SkipAccessPointPromise> DoSkipToNextRandomAccessPoint(
const media::TimeUnit& aTimeThreadshold);
already_AddRefed<MediaRawData> GetSample(MediaResult& aError);
// Return the timestamp of the next keyframe after mLastSampleIndex.
media::TimeUnit GetNextRandomAccessPoint();
RefPtr<MediaSourceDemuxer> mParent;
const RefPtr<TaskQueue> mTaskQueue;
TrackInfo::TrackType mType;
// Mutex protecting members below accessed from multiple threads.
MutexSingleWriter mMutex;
media::TimeUnit mNextRandomAccessPoint MOZ_GUARDED_BY(mMutex);
// Would be accessed in MFR's demuxer proxy task queue and TaskQueue, and
// only be set on the TaskQueue. It can be accessed while on TaskQueue without
// the need for the lock.
RefPtr<TrackBuffersManager> mManager MOZ_GUARDED_BY(mMutex);
// Only accessed on TaskQueue
Maybe<RefPtr<MediaRawData>> mNextSample;
// Set to true following a reset. Ensure that the next sample demuxed
// is available at position 0.
// Only accessed on TaskQueue
bool mReset;
// Amount of pre-roll time when seeking.
// Set to 80ms if track is Opus.
const media::TimeUnit mPreRoll;
};
} // namespace mozilla
#endif
|
