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
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
|
<!doctype html>
<meta charset=utf-8>
<script src="/resources/testharness.js"></script>
<script src="/resources/testharnessreport.js"></script>
<script>
'use strict';
['audio', 'video'].forEach((kind) => {
// Make sure "ontrack" fires if a prevuously rolled back track is added back.
promise_test(async t => {
const constraints = {};
constraints[kind] = true;
const stream = await navigator.mediaDevices.getUserMedia(constraints);
const [track] = stream.getTracks();
t.add_cleanup(() => track.stop());
const pc1 = new RTCPeerConnection();
t.add_cleanup(() => pc1.close());
const pc2 = new RTCPeerConnection();
t.add_cleanup(() => pc2.close());
pc1.addTrack(track, stream);
pc2.addTrack(track, stream);
const [pc1Transceiver] = pc1.getTransceivers();
const [pc2Transceiver] = pc2.getTransceivers();
let remoteStreamViaOnTrackPromise = getRemoteStreamViaOnTrackPromise(pc2);
// Apply remote offer, but don't complete the entire exchange.
await pc1.setLocalDescription();
await pc2.setRemoteDescription(pc1.localDescription);
// The addTrack-transceiver gets associated, no need for a second
// transceiver.
assert_equals(pc2.getTransceivers().length, 1);
const remoteStream = await remoteStreamViaOnTrackPromise;
assert_equals(remoteStream.id, stream.id);
const onRemoveTrackPromise = new Promise(r => {
remoteStream.onremovetrack = () => { r(); };
});
// Cause track removal due to rollback.
await pc2.setLocalDescription({type:'rollback'});
// The track was removed.
await onRemoveTrackPromise;
// Sanity check that ontrack still fires if we add it back again by applying
// the same remote offer.
remoteStreamViaOnTrackPromise = getRemoteStreamViaOnTrackPromise(pc2);
await pc2.setRemoteDescription(pc1.localDescription);
const revivedRemoteStream = await remoteStreamViaOnTrackPromise;
// This test only expects IDs to be the same. The same stream object should
// also be used, but this should be covered by separate tests.
// TODO(https://crbug.com/1321738): Add MediaStream identity tests.
assert_equals(remoteStream.id, revivedRemoteStream.id);
// No cheating, the same transciever should be used as before.
assert_equals(pc2.getTransceivers().length, 1);
}, `[${kind}] Track with stream: removal due to disassociation in rollback and then add it back again`);
// This is the same test as above, but this time without any remote streams.
// This test could fail if [[FiredDirection]] was not reset in a rollback but
// the above version of the test might still pass due to the track being
// re-added to its stream.
promise_test(async t => {
const constraints = {};
constraints[kind] = true;
const stream = await navigator.mediaDevices.getUserMedia(constraints);
const [track] = stream.getTracks();
t.add_cleanup(() => track.stop());
const pc1 = new RTCPeerConnection();
t.add_cleanup(() => pc1.close());
const pc2 = new RTCPeerConnection();
t.add_cleanup(() => pc2.close());
pc1.addTrack(track);
pc2.addTrack(track);
const [pc1Transceiver] = pc1.getTransceivers();
const [pc2Transceiver] = pc2.getTransceivers();
let remoteTrackPromise = getTrackViaOnTrackPromise(pc2);
// Apply remote offer, but don't complete the entire exchange.
await pc1.setLocalDescription();
await pc2.setRemoteDescription(pc1.localDescription);
// The addTrack-transceiver gets associated, no need for a second
// transceiver.
assert_equals(pc2.getTransceivers().length, 1);
const remoteTrack = await remoteTrackPromise;
assert_not_equals(remoteTrack, null);
// Cause track removal due to rollback.
await pc2.setLocalDescription({type:'rollback'});
// There's nothing equivalent to stream.onremovetrack when you don't have a
// stream, but the track should become muted (if it isn't already).
if (!remoteTrack.muted) {
await new Promise(r => remoteTrack.onmute = () => { r(); });
}
assert_equals(remoteTrack.muted, true);
// Sanity check that ontrack still fires if we add it back again by applying
// the same remote offer.
remoteTrackPromise = getTrackViaOnTrackPromise(pc2);
await pc2.setRemoteDescription(pc1.localDescription);
const revivedRemoteTrack = await remoteTrackPromise;
// We can be sure the same track is used, because the same transceiver is
// used (and transciever.receiver.track has same lifetime as transceiver).
assert_equals(pc2.getTransceivers().length, 1);
assert_equals(remoteTrack, revivedRemoteTrack);
}, `[${kind}] Track without stream: removal due to disassociation in rollback and then add it back`);
// Make sure "ontrack" can fire in a rollback (undo making it inactive).
promise_test(async t => {
const constraints = {};
constraints[kind] = true;
const stream = await navigator.mediaDevices.getUserMedia(constraints);
const [track] = stream.getTracks();
t.add_cleanup(() => track.stop());
const pc1 = new RTCPeerConnection();
t.add_cleanup(() => pc1.close());
const pc2 = new RTCPeerConnection();
t.add_cleanup(() => pc2.close());
pc1.addTrack(track, stream);
const [pc1Transceiver] = pc1.getTransceivers();
let remoteStreamViaOnTrackPromise = getRemoteStreamViaOnTrackPromise(pc2);
// Complete O/A exchange such that the transceiver gets associated.
await pc1.setLocalDescription();
await pc2.setRemoteDescription(pc1.localDescription);
await pc2.setLocalDescription();
await pc1.setRemoteDescription(pc2.localDescription);
const [pc2Transceiver] = pc2.getTransceivers();
assert_equals(pc2Transceiver.direction, 'recvonly');
assert_equals(pc2Transceiver.currentDirection, 'recvonly');
const remoteStream = await remoteStreamViaOnTrackPromise;
assert_equals(remoteStream.id, stream.id);
const onRemoveTrackPromise = new Promise(r => {
remoteStream.onremovetrack = () => { r(); };
});
// Cause track removal.
pc1Transceiver.direction = 'inactive';
await pc1.setLocalDescription();
await pc2.setRemoteDescription(pc1.localDescription);
// The track was removed.
await onRemoveTrackPromise;
// Rolling back the offer revives the track, causing ontrack to fire again.
remoteStreamViaOnTrackPromise = getRemoteStreamViaOnTrackPromise(pc2);
await pc2.setLocalDescription({type:'rollback'});
const revivedRemoteStream = await remoteStreamViaOnTrackPromise;
// This test only expects IDs to be the same. The same stream object should
// also be used, but this should be covered by separate tests.
// TODO(https://crbug.com/1321738): Add MediaStream identity tests.
assert_equals(remoteStream.id, revivedRemoteStream.id);
}, `[${kind}] Track with stream: removal due to direction changing and then add back using rollback`);
// Same test as above but without remote streams.
promise_test(async t => {
const constraints = {};
constraints[kind] = true;
const stream = await navigator.mediaDevices.getUserMedia(constraints);
const [track] = stream.getTracks();
t.add_cleanup(() => track.stop());
const pc1 = new RTCPeerConnection();
t.add_cleanup(() => pc1.close());
const pc2 = new RTCPeerConnection();
t.add_cleanup(() => pc2.close());
pc1.addTrack(track);
const [pc1Transceiver] = pc1.getTransceivers();
let remoteTrackPromise = getTrackViaOnTrackPromise(pc2);
// Complete O/A exchange such that the transceiver gets associated.
await pc1.setLocalDescription();
await pc2.setRemoteDescription(pc1.localDescription);
await pc2.setLocalDescription();
await pc1.setRemoteDescription(pc2.localDescription);
const [pc2Transceiver] = pc2.getTransceivers();
assert_equals(pc2Transceiver.direction, 'recvonly');
assert_equals(pc2Transceiver.currentDirection, 'recvonly');
const remoteTrack = await remoteTrackPromise;
// Cause track removal.
pc1Transceiver.direction = 'inactive';
await pc1.setLocalDescription();
await pc2.setRemoteDescription(pc1.localDescription);
// There's nothing equivalent to stream.onremovetrack when you don't have a
// stream, but the track should become muted (if it isn't already).
if (!remoteTrack.muted) {
await new Promise(r => remoteTrack.onmute = () => { r(); });
}
assert_equals(remoteTrack.muted, true);
// Rolling back the offer revives the track, causing ontrack to fire again.
remoteTrackPromise = getTrackViaOnTrackPromise(pc2);
await pc2.setLocalDescription({type:'rollback'});
const revivedRemoteTrack = await remoteTrackPromise;
// We can be sure the same track is used, because the same transceiver is
// used (and transciever.receiver.track has same lifetime as transceiver).
assert_equals(pc2.getTransceivers().length, 1);
assert_equals(remoteTrack, revivedRemoteTrack);
}, `[${kind}] Track without stream: removal due to direction changing and then add back using rollback`);
});
function getTrackViaOnTrackPromise(pc) {
return new Promise(r => {
pc.ontrack = e => {
pc.ontrack = null;
r(e.track);
};
});
}
function getRemoteStreamViaOnTrackPromise(pc) {
return new Promise(r => {
pc.ontrack = e => {
pc.ontrack = null;
r(e.streams[0]);
};
});
}
</script>
|
