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
|
<!doctype html>
<meta charset=utf-8>
<title>Timestamps in RTCEncodedFrame metadata</title>
<script src="/resources/testharness.js"></script>
<script src="/resources/testharnessreport.js"></script>
<script src="/webrtc/RTCPeerConnection-helper.js"></script>
<script src="RTCEncodedFrame-timestamps-helper.js"></script>
<script>
'use strict';
function doWorkExpectingCaptureTimestamps() {
onrtctransform = async e => {
const reader = e.transformer.readable.getReader();
const writer = e.transformer.writable.getWriter();
let oldCaptureTime = -1;
let oldReceiveTime = -1;
for (let i = 0; i<10; i++) {
const frameOrDone = await reader.read();
if (frameOrDone.done) {
self.postMessage("Unexpected end of stream");
return;
}
const metadata = frameOrDone.value.getMetadata();
if (metadata.captureTime > metadata.receiveTime ||
metadata.captureTime < 0 ||
metadata.captureTime < oldCaptureTime) {
self.postMessage("Unexpected captureTime");
return;
}
if (metadata.receiveTime > performance.now() ||
metadata.receiveTime < metadata.captureTime ||
metadata.receiveTime < oldReceiveTime) {
self.postMessage("Unexpected receiveTime");
return;
}
if (metadata.senderCaptureTimeOffset != 0) {
self.postMessage("Unexpected senderReceiveTimeOffset");
return;
}
oldCaptureTime = metadata.captureTime;
oldReceiveTime = metadata.receiveTime;
await writer.write(frameOrDone.value);
}
self.postMessage("OK");
};
}
function doWorkExpectingNoCaptureTimestamps() {
onrtctransform = async e => {
const reader = e.transformer.readable.getReader();
const writer = e.transformer.writable.getWriter();
let oldReceiveTime = -1;
for (let i = 0; i<10; i++) {
const frameOrDone = await reader.read();
if (frameOrDone.done) {
self.postMessage("Unexpected end of stream");
return;
}
const metadata = frameOrDone.value.getMetadata();
if ("captureTime" in metadata) {
self.postMessage("Unexpected captureTime");
return;
}
if ("senderCaptureTimeOffset" in metadata) {
self.postMessage("Unexpected senderReceiveTimeOffset");
return;
}
if (metadata.receiveTime > performance.now() ||
metadata.receiveTime < oldReceiveTime) {
self.postMessage("Unexpected receiveTime");
return;
}
oldReceiveTime = metadata.receiveTime;
await writer.write(frameOrDone.value);
}
self.postMessage("OK");
};
}
promise_test(async t => {
const worker = new Worker(`data:text/javascript,(${doWorkExpectingCaptureTimestamps.toString()})()`);
const workerPromise = new Promise((resolve, reject) => {
worker.onmessage = t.step_func(message => {
if (message.data == "OK") {
resolve();
} else {
reject(message.data);
}
});
});
await initiateCall(
t, /*streamOptions=*/{audio: true, video: false},
/*enableAbsCaptureTime=*/true, worker, /*enableSenderTransform=*/false,
/*enableReceiverTransform=*/true);
return workerPromise;
}, 'captureTime and senderCaptureTimeOffset present in audio receiver if extension is used');
promise_test(async t => {
const worker = new Worker(`data:text/javascript,(${doWorkExpectingNoCaptureTimestamps.toString()})()`);
const workerPromise = new Promise((resolve, reject) => {
worker.onmessage = t.step_func(message => {
if (message.data == "OK") {
resolve();
} else {
reject(message.data);
}
});
});
await initiateCall(
t, /*streamOptions=*/{audio: true, video: false},
/*enableAbsCaptureTime=*/false, worker, /*enableSenderTransform=*/false,
/*enableReceiverTransform=*/true);
return workerPromise;
}, 'captureTime and senderCaptureTimeOffset not present in audio receiver if extension not used');
promise_test(async t => {
const worker = new Worker(`data:text/javascript,(${doWorkExpectingCaptureTimestamps.toString()})()`);
const workerPromise = new Promise((resolve, reject) => {
worker.onmessage = t.step_func(message => {
if (message.data == "OK") {
resolve();
} else {
reject(message.data);
}
});
});
await initiateCall(
t, /*streamOptions=*/{audio: false, video: true},
/*enableAbsCaptureTime=*/true, worker, /*enableSenderTransform=*/false,
/*enableReceiverTransform=*/true);
return workerPromise;
}, 'captureTime and senderCaptureTimeOffset present in video receiver if extension is used');
promise_test(async t => {
const worker = new Worker(`data:text/javascript,(${doWorkExpectingNoCaptureTimestamps.toString()})()`);
const workerPromise = new Promise((resolve, reject) => {
worker.onmessage = t.step_func(message => {
if (message.data == "OK") {
resolve();
} else {
reject(message.data);
}
});
});
await initiateCall(
t, /*streamOptions=*/{audio: false, video: true},
/*enableAbsCaptureTime=*/false, worker, /*enableSenderTransform=*/false,
/*enableReceiverTransform=*/true);
return workerPromise;
}, 'captureTime and senderCaptureTimeOffset not present in video receiver if extension not used');
</script>
|
