Source code
Revision control
Copy as Markdown
Other Tools
Test Info: Warnings
- This test has a WPT meta file that expects 2 subtest issues.
- This WPT test may be referenced by the following Test IDs:
- /mediacapture-insertable-streams/MediaStreamTrackProcessor-maxBufferSize.worker.html - WPT Dashboard Interop Dashboard
// META: title=MediaStreamTrackProcessor maxBufferSize
importScripts("/resources/testharness.js");
function makeVideoFrame(timestamp) {
const canvas = new OffscreenCanvas(100, 100);
const ctx = canvas.getContext('2d');
return new VideoFrame(canvas, {timestamp});
}
promise_test(async t => {
// The generator will be used as the source for the processor to
// produce frames in a controlled manner.
const generator = new VideoTrackGenerator();
t.add_cleanup(() => generator.track.stop());
// Use a larger maxBufferSize than the default to ensure no frames
// will be dropped.
const processor = new MediaStreamTrackProcessor({track: generator.track, maxBufferSize:10});
const reader = processor.readable.getReader();
const writer = generator.writable.getWriter();
let numReads = 0;
let resolve = null;
const promise = new Promise(r => resolve = r);
const numOperations = 4;
// Issue reads without waiting for the frames to arrive.
for (let i = 0; i < numOperations; i++) {
reader.read().then(dv=> {
dv.value.close();
if (++numReads == numOperations)
resolve();
});
}
// Write video frames in different tasks to "slowly" settle the pending read
// requests.
for (let i = 0; i<numOperations; i++) {
await writer.write(makeVideoFrame(i));
await new Promise(r=>t.step_timeout(r, 0));
}
return promise;
}, "Tests that multiple read requests are eventually settled");
promise_test(async t => {
// The generator will be used as the source for the processor to
// produce frames in a controlled manner.
const generator = new VideoTrackGenerator();
t.add_cleanup(() => generator.track.stop());
// Use a larger maxBufferSize than the default to ensure no frames
// will be dropped.
const processor = new MediaStreamTrackProcessor({track: generator.track, maxBufferSize:10});
const reader = processor.readable.getReader();
const writer = generator.writable.getWriter();
const numOperations = 4;
// Write video frames as fast as we can with "slower" reads.
// requests.
for (let i = 0; i<numOperations; i++) {
await writer.write(makeVideoFrame(i));
}
let numReads = 0;
let resolve = null;
const promise = new Promise(r => resolve = r);
// Issue reads without waiting for the frames to arrive.
for (let i = 0; i < numOperations; i++) {
await new Promise(r=>t.step_timeout(r, 50));
reader.read().then(dv=> {
dv.value.close();
if (++numReads == numOperations)
resolve();
});
}
return promise;
}, "Tests that multiple write requests are buffered");
done();