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
|
<!doctype html>
<meta charset=utf-8>
<meta name="timeout" content="long">
<title>RTCPeerConnection-transceivers.https.html</title>
<script src="/resources/testharness.js"></script>
<script src="/resources/testharnessreport.js"></script>
<script src="RTCPeerConnection-helper.js"></script>
<script>
'use strict';
async function waitForTimeout(t, timeout_ms = 5000) {
return new Promise(r => t.step_timeout(r, timeout_ms));
}
// The following helper functions are called from RTCPeerConnection-helper.js:
// exchangeOffer
// exchangeOfferAndListenToOntrack
// exchangeAnswer
// exchangeAnswerAndListenToOntrack
// addEventListenerPromise
// createPeerConnectionWithCleanup
// createTrackAndStreamWithCleanup
// findTransceiverForSender
promise_test(async t => {
const pc1 = createPeerConnectionWithCleanup(t);
pc1.addTrack(... await createTrackAndStreamWithCleanup(t));
const pc2 = createPeerConnectionWithCleanup(t);
exchangeIceCandidates(pc1, pc2);
let muteWatcher;
let unmutePromise;
// The unmuting it timing sensitive so we hook up to the event directly
// instead of wrapping it in an EventWatcher which uses promises.
pc2.ontrack = t.step_func(e => {
assert_true(e.track.muted, 'track is muted in ontrack');
muteWatcher = new EventWatcher(t, e.track, ['unmute'],
() => waitForTimeout(t));
unmutePromise = muteWatcher.wait_for('unmute');
pc2.ontrack = t.step_func(e => {
assert_unreached('ontrack fired unexpectedly');
});
});
await exchangeOfferAnswer(pc1, pc2);
await unmutePromise;
}, 'ontrack: track goes from muted to unmuted');
promise_test(async t => {
const pc1 = createPeerConnectionWithCleanup(t);
const pc1Sender = pc1.addTrack(... await createTrackAndStreamWithCleanup(t));
const localTransceiver = findTransceiverForSender(pc1, pc1Sender);
const pc2 = createPeerConnectionWithCleanup(t);
exchangeIceCandidates(pc1, pc2);
let muteWatcher;
let unmutePromise;
pc2.ontrack = t.step_func(e => {
muteWatcher = new EventWatcher(t, e.track, ['mute', 'unmute'],
() => waitForTimeout(t));
unmutePromise = muteWatcher.wait_for('unmute');
});
await exchangeOfferAnswer(pc1, pc2);
// Need to wait for the initial unmute event before renegotiating, otherwise
// there will be no transition from unmuted->muted.
await unmutePromise;
const mutePromise = muteWatcher.wait_for('mute');
localTransceiver.direction = 'inactive';
await exchangeOfferAnswer(pc1, pc2);
await mutePromise;
}, 'Changing transceiver direction to \'inactive\' mutes the remote track');
promise_test(async t => {
const pc1 = createPeerConnectionWithCleanup(t);
const pc1Sender = pc1.addTrack(... await createTrackAndStreamWithCleanup(t));
const localTransceiver = findTransceiverForSender(pc1, pc1Sender);
const pc2 = createPeerConnectionWithCleanup(t);
exchangeIceCandidates(pc1, pc2);
let muteWatcher;
let unmutePromise;
pc2.ontrack = t.step_func(e => {
muteWatcher = new EventWatcher(t, e.track, ['mute', 'unmute'],
() => waitForTimeout(t));
unmutePromise = muteWatcher.wait_for('unmute');
});
await exchangeOfferAnswer(pc1, pc2);
await unmutePromise;
const mutePromise = muteWatcher.wait_for('mute');
localTransceiver.direction = 'inactive';
await exchangeOfferAnswer(pc1, pc2);
await mutePromise;
unmutePromise = muteWatcher.wait_for('unmute');
localTransceiver.direction = 'sendrecv';
await exchangeOfferAnswer(pc1, pc2);
await unmutePromise;
}, 'Changing transceiver direction to \'sendrecv\' unmutes the remote track');
promise_test(async t => {
const pc1 = createPeerConnectionWithCleanup(t);
const pc1Sender = pc1.addTrack(... await createTrackAndStreamWithCleanup(t));
const localTransceiver = findTransceiverForSender(pc1, pc1Sender);
const pc2 = createPeerConnectionWithCleanup(t);
exchangeIceCandidates(pc1, pc2);
let muteWatcher;
let unmutePromise;
pc2.ontrack = t.step_func(e => {
muteWatcher = new EventWatcher(t, e.track, ['mute', 'unmute'],
() => waitForTimeout(t));
unmutePromise = muteWatcher.wait_for('unmute');
});
await exchangeOfferAnswer(pc1, pc2);
// Need to wait for the initial unmute event before closing, otherwise
// there will be no transition from unmuted->muted.
await unmutePromise;
// This will send an RTCP BYE which causes the remote side to mute.
const mutePromise = muteWatcher.wait_for('mute');
localTransceiver.stop();
await mutePromise;
}, 'transceiver.stop() on one side (without renegotiation) causes mute events on the other');
promise_test(async t => {
const pc1 = createPeerConnectionWithCleanup(t);
const pc1Sender = pc1.addTrack(...await createTrackAndStreamWithCleanup(t));
const localTransceiver = findTransceiverForSender(pc1, pc1Sender);
const pc2 = createPeerConnectionWithCleanup(t);
exchangeIceCandidates(pc1, pc2);
let muteWatcher;
let unmutePromise;
pc2.ontrack = t.step_func(e => {
muteWatcher = new EventWatcher(t, e.track, ['mute', 'unmute'],
() => waitForTimeout(t));
unmutePromise = muteWatcher.wait_for('unmute');
});
await exchangeOfferAnswer(pc1, pc2);
// Need to wait for the initial unmute event before closing, otherwise
// there will be no transition from unmuted->muted.
await unmutePromise;
const mutePromise = muteWatcher.wait_for('mute');
pc1.close();
await mutePromise;
}, 'pc.close() on one side causes mute events on the other');
</script>
|
