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
|
/* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*-*/
/* 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/. */
#include "MediaStreamListener.h"
#include "AudioSegment.h"
#include "VideoSegment.h"
#include "StreamTracks.h"
namespace mozilla {
#ifdef LOG
#undef LOG
#endif
#define LOG(type, msg) MOZ_LOG(gMediaStreamGraphLog, type, msg)
void
DirectMediaStreamTrackListener::MirrorAndDisableSegment(AudioSegment& aFrom,
AudioSegment& aTo)
{
aTo.Clear();
aTo.AppendNullData(aFrom.GetDuration());
}
void
DirectMediaStreamTrackListener::MirrorAndDisableSegment(VideoSegment& aFrom,
VideoSegment& aTo,
DisabledTrackMode aMode)
{
aTo.Clear();
if (aMode == DisabledTrackMode::SILENCE_BLACK) {
for (VideoSegment::ChunkIterator it(aFrom); !it.IsEnded(); it.Next()) {
aTo.AppendFrame(do_AddRef(it->mFrame.GetImage()),
it->GetDuration(),
it->mFrame.GetIntrinsicSize(),
it->GetPrincipalHandle(),
true);
}
} else if (aMode == DisabledTrackMode::SILENCE_FREEZE) {
aTo.AppendNullData(aFrom.GetDuration());
}
}
void
DirectMediaStreamTrackListener::NotifyRealtimeTrackDataAndApplyTrackDisabling(MediaStreamGraph* aGraph,
StreamTime aTrackOffset,
MediaSegment& aMedia)
{
if (mDisabledFreezeCount == 0 && mDisabledBlackCount == 0) {
NotifyRealtimeTrackData(aGraph, aTrackOffset, aMedia);
return;
}
DisabledTrackMode mode = mDisabledBlackCount > 0
? DisabledTrackMode::SILENCE_BLACK
: DisabledTrackMode::SILENCE_FREEZE;
if (!mMedia) {
mMedia = aMedia.CreateEmptyClone();
}
if (aMedia.GetType() == MediaSegment::AUDIO) {
MirrorAndDisableSegment(static_cast<AudioSegment&>(aMedia),
static_cast<AudioSegment&>(*mMedia));
} else if (aMedia.GetType() == MediaSegment::VIDEO) {
MirrorAndDisableSegment(static_cast<VideoSegment&>(aMedia),
static_cast<VideoSegment&>(*mMedia),
mode);
} else {
MOZ_CRASH("Unsupported media type");
}
NotifyRealtimeTrackData(aGraph, aTrackOffset, *mMedia);
}
void
DirectMediaStreamTrackListener::IncreaseDisabled(DisabledTrackMode aMode)
{
if (aMode == DisabledTrackMode::SILENCE_FREEZE) {
++mDisabledFreezeCount;
} else if (aMode == DisabledTrackMode::SILENCE_BLACK) {
++mDisabledBlackCount;
} else {
MOZ_ASSERT(false, "Unknown disabled mode");
}
LOG(LogLevel::Debug, ("DirectMediaStreamTrackListener %p increased disabled "
"mode %s. Current counts are: freeze=%d, black=%d",
this,
aMode == DisabledTrackMode::SILENCE_FREEZE ? "freeze" : "black",
int32_t(mDisabledFreezeCount),
int32_t(mDisabledBlackCount)));
}
void
DirectMediaStreamTrackListener::DecreaseDisabled(DisabledTrackMode aMode)
{
if (aMode == DisabledTrackMode::SILENCE_FREEZE) {
--mDisabledFreezeCount;
MOZ_ASSERT(mDisabledFreezeCount >= 0, "Double decrease");
} else if (aMode == DisabledTrackMode::SILENCE_BLACK) {
--mDisabledBlackCount;
MOZ_ASSERT(mDisabledBlackCount >= 0, "Double decrease");
} else {
MOZ_ASSERT(false, "Unknown disabled mode");
}
LOG(LogLevel::Debug, ("DirectMediaStreamTrackListener %p decreased disabled "
"mode %s. Current counts are: freeze=%d, black=%d",
this,
aMode == DisabledTrackMode::SILENCE_FREEZE ? "freeze" : "black",
int32_t(mDisabledFreezeCount),
int32_t(mDisabledBlackCount)));
}
} // namespace mozilla
|
