-
Notifications
You must be signed in to change notification settings - Fork 3.3k
/
Copy pathRTCPeerConnection-getStats.https.html
280 lines (252 loc) · 11.9 KB
/
RTCPeerConnection-getStats.https.html
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
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
<!doctype html>
<meta charset=utf-8>
<meta name="timeout" content="long">
<title>RTCPeerConnection.prototype.getStats</title>
<script src="/resources/testharness.js"></script>
<script src="/resources/testharnessreport.js"></script>
<script src="RTCPeerConnection-helper.js"></script>
<script>
'use strict';
// Test is based on the following editor draft:
// webrtc-pc 20171130
// webrtc-stats 20171122
// The following helper function is called from RTCPeerConnection-helper.js
// getTrackFromUserMedia
// The following helper function is called from RTCPeerConnection-helper.js
// exchangeIceCandidates
// exchangeOfferAnswer
/*
8.2. getStats
1. Let selectorArg be the method's first argument.
2. Let connection be the RTCPeerConnection object on which the method was invoked.
3. If selectorArg is null, let selector be null.
4. If selectorArg is a MediaStreamTrack let selector be an RTCRtpSender
or RTCRtpReceiver on connection which track member matches selectorArg.
If no such sender or receiver exists, or if more than one sender or
receiver fit this criteria, return a promise rejected with a newly
created InvalidAccessError.
5. Let p be a new promise.
6. Run the following steps in parallel:
1. Gather the stats indicated by selector according to the stats selection algorithm.
2. Resolve p with the resulting RTCStatsReport object, containing the gathered stats.
*/
promise_test(t => {
const pc = new RTCPeerConnection();
t.add_cleanup(() => pc.close());
return pc.getStats();
}, 'getStats() with no argument should succeed');
promise_test(t => {
const pc = new RTCPeerConnection();
t.add_cleanup(() => pc.close());
return pc.getStats(null);
}, 'getStats(null) should succeed');
/*
8.2. getStats
4. If selectorArg is a MediaStreamTrack let selector be an RTCRtpSender
or RTCRtpReceiver on connection which track member matches selectorArg.
If no such sender or receiver exists, or if more than one sender or
receiver fit this criteria, return a promise rejected with a newly
created InvalidAccessError.
*/
promise_test(t => {
const pc = new RTCPeerConnection();
t.add_cleanup(() => pc.close());
return getTrackFromUserMedia('audio')
.then(([track, mediaStream]) => {
return promise_rejects_dom(t, 'InvalidAccessError', pc.getStats(track));
});
}, 'getStats() with track not added to connection should reject with InvalidAccessError');
promise_test(t => {
const pc = new RTCPeerConnection();
t.add_cleanup(() => pc.close());
return getTrackFromUserMedia('audio')
.then(([track, mediaStream]) => {
pc.addTrack(track, mediaStream);
return pc.getStats(track);
});
}, 'getStats() with track added via addTrack should succeed');
promise_test(async t => {
const pc = new RTCPeerConnection();
t.add_cleanup(() => pc.close());
const stream = await getNoiseStream({audio: true});
t.add_cleanup(() => stream.getTracks().forEach(track => track.stop()));
const [track] = stream.getTracks();
pc.addTransceiver(track);
return pc.getStats(track);
}, 'getStats() with track added via addTransceiver should succeed');
promise_test(t => {
const pc = new RTCPeerConnection();
t.add_cleanup(() => pc.close());
const transceiver1 = pc.addTransceiver('audio');
// Create another transceiver that resends what
// is being received, kind of like echo
const transceiver2 = pc.addTransceiver(transceiver1.receiver.track);
assert_equals(transceiver1.receiver.track, transceiver2.sender.track);
return promise_rejects_dom(t, 'InvalidAccessError', pc.getStats(transceiver1.receiver.track));
}, 'getStats() with track associated with both sender and receiver should reject with InvalidAccessError');
/*
8.5. The stats selection algorithm
2. If selector is null, gather stats for the whole connection, add them to result,
return result, and abort these steps.
*/
promise_test(t => {
const pc = new RTCPeerConnection();
t.add_cleanup(() => pc.close());
return pc.getStats()
.then(statsReport => {
assert_true(!![...statsReport.values()].find(({type}) => type === 'peer-connection'));
});
}, 'getStats() with no argument should return stats report containing peer-connection stats on an empty PC');
promise_test(async t => {
const pc = createPeerConnectionWithCleanup(t);
const pc2 = createPeerConnectionWithCleanup(t);
const [sendtrack, mediaStream] = await getTrackFromUserMedia('audio');
pc.addTrack(sendtrack, mediaStream);
exchangeIceCandidates(pc, pc2);
await Promise.all([
exchangeOfferAnswer(pc, pc2),
new Promise(r => pc2.ontrack = e => e.track.onunmute = r)
]);
const statsReport = await pc.getStats();
assert_true(!![...statsReport.values()].find(({type}) => type === 'peer-connection'));
assert_true(!![...statsReport.values()].find(({type}) => type === 'outbound-rtp'));
}, 'getStats() track with stream returns peer-connection and outbound-rtp stats');
promise_test(async t => {
const pc = createPeerConnectionWithCleanup(t);
const pc2 = createPeerConnectionWithCleanup(t);
const [sendtrack, mediaStream] = await getTrackFromUserMedia('audio');
pc.addTrack(sendtrack);
exchangeIceCandidates(pc, pc2);
await Promise.all([
exchangeOfferAnswer(pc, pc2),
new Promise(r => pc2.ontrack = e => e.track.onunmute = r)
]);
const statsReport = await pc.getStats();
assert_true(!![...statsReport.values()].find(({type}) => type === 'peer-connection'));
assert_true(!![...statsReport.values()].find(({type}) => type === 'outbound-rtp'));
}, 'getStats() track without stream returns peer-connection and outbound-rtp stats');
promise_test(async t => {
const pc = createPeerConnectionWithCleanup(t);
const pc2 = createPeerConnectionWithCleanup(t);
const [sendtrack, mediaStream] = await getTrackFromUserMedia('audio');
pc.addTrack(sendtrack, mediaStream);
exchangeIceCandidates(pc, pc2);
await Promise.all([
exchangeOfferAnswer(pc, pc2),
new Promise(r => pc2.ontrack = e => e.track.onunmute = r)
]);
const statsReport = await pc.getStats();
assert_true(!![...statsReport.values()].find(({type}) => type === 'outbound-rtp'));
}, 'getStats() audio contains outbound-rtp stats');
promise_test(async t => {
const pc = createPeerConnectionWithCleanup(t);
const pc2 = createPeerConnectionWithCleanup(t);
const [sendtrack, mediaStream] = await getTrackFromUserMedia('video');
pc.addTrack(sendtrack, mediaStream);
exchangeIceCandidates(pc, pc2);
await Promise.all([
exchangeOfferAnswer(pc, pc2),
new Promise(r => pc2.ontrack = e => e.track.onunmute = r)
]);
const statsReport = await pc.getStats();
assert_true(!![...statsReport.values()].find(({type}) => type === 'outbound-rtp'));
}, 'getStats() video contains outbound-rtp stats');
/*
8.5. The stats selection algorithm
3. If selector is an RTCRtpSender, gather stats for and add the following objects
to result:
- All RTCOutboundRtpStreamStats objects corresponding to selector.
- All stats objects referenced directly or indirectly by the RTCOutboundRtpStreamStats
objects added.
*/
promise_test(async t => {
const pc = createPeerConnectionWithCleanup(t);
const pc2 = createPeerConnectionWithCleanup(t);
let [sendtrack, mediaStream] = await getTrackFromUserMedia('audio');
pc.addTrack(sendtrack, mediaStream);
exchangeIceCandidates(pc, pc2);
await Promise.all([
exchangeOfferAnswer(pc, pc2),
new Promise(r => pc2.ontrack = e => e.track.onunmute = r)
]);
const statsReport = await pc.getStats(sendtrack);
assert_true(!![...statsReport.values()].find(({type}) => type === 'outbound-rtp'));
}, `getStats() on track associated with RTCRtpSender should return stats report containing outbound-rtp stats`);
/*
8.5. The stats selection algorithm
4. If selector is an RTCRtpReceiver, gather stats for and add the following objects
to result:
- All RTCInboundRtpStreamStats objects corresponding to selector.
- All stats objects referenced directly or indirectly by the RTCInboundRtpStreamStats
added.
*/
promise_test(async t => {
const pc = createPeerConnectionWithCleanup(t);
const pc2 = createPeerConnectionWithCleanup(t);
let [track, mediaStream] = await getTrackFromUserMedia('audio');
pc.addTrack(track, mediaStream);
exchangeIceCandidates(pc, pc2);
await exchangeOfferAnswer(pc, pc2);
// Wait for unmute if the track is not already unmuted.
// According to spec, it should be muted when being created, but this
// is not what this test is testing, so allow it to be unmuted.
if (pc2.getReceivers()[0].track.muted) {
await new Promise(resolve => {
pc2.getReceivers()[0].track.addEventListener('unmute', resolve);
});
}
const statsReport = await pc2.getStats(pc2.getReceivers()[0].track);
assert_true(!![...statsReport.values()].find(({type}) => type === 'inbound-rtp'));
}, `getStats() on track associated with RTCRtpReceiver should return stats report containing inbound-rtp stats`);
promise_test(async t => {
const pc = createPeerConnectionWithCleanup(t);
const pc2 = createPeerConnectionWithCleanup(t);
let [track, mediaStream] = await getTrackFromUserMedia('audio');
pc.addTrack(track, mediaStream);
exchangeIceCandidates(pc, pc2);
await exchangeOfferAnswer(pc, pc2);
// Wait for unmute if the track is not already unmuted.
// According to spec, it should be muted when being created, but this
// is not what this test is testing, so allow it to be unmuted.
if (pc2.getReceivers()[0].track.muted) {
await new Promise(resolve => {
pc2.getReceivers()[0].track.addEventListener('unmute', resolve);
});
}
const statsReport = await pc2.getStats(pc2.getReceivers()[0].track);
assert_true(!![...statsReport.values()].find(({type}) => type === 'inbound-rtp'));
}, `getStats() audio contains inbound-rtp stats`);
promise_test(async t => {
const pc = new RTCPeerConnection();
t.add_cleanup(() => pc.close());
const [track, mediaStream] = await getTrackFromUserMedia('audio');
pc.addTransceiver(track);
pc.addTransceiver(track);
await promise_rejects_dom(t, 'InvalidAccessError', pc.getStats(track));
}, `getStats(track) should not work if multiple senders have the same track`);
promise_test(async t => {
const kMinimumTimeElapsedBetweenGetStatsCallsMs = 500;
const pc = new RTCPeerConnection();
t.add_cleanup(() => pc.close());
const t0 = Math.floor(performance.now());
const t0Stats = [...(await pc.getStats()).values()].find(({type}) => type === 'peer-connection');
await new Promise(
r => t.step_timeout(r, kMinimumTimeElapsedBetweenGetStatsCallsMs));
const t1Stats = [...(await pc.getStats()).values()].find(({type}) => type === 'peer-connection');
const t1 = Math.ceil(performance.now());
const maximumTimeElapsedBetweenGetStatsCallsMs = t1 - t0;
const deltaTimestampMs = t1Stats.timestamp - t0Stats.timestamp;
// The delta must be at least the time we waited between calls.
assert_greater_than_equal(deltaTimestampMs,
kMinimumTimeElapsedBetweenGetStatsCallsMs);
// The delta must be at most the time elapsed before the first getStats()
// call and after the second getStats() call.
assert_less_than_equal(deltaTimestampMs,
maximumTimeElapsedBetweenGetStatsCallsMs);
}, `RTCStats.timestamp increases with time passing`);
promise_test(async t => {
const pc1 = new RTCPeerConnection();
pc1.close();
await pc1.getStats();
}, 'getStats succeeds on a closed peerconnection');
</script>