diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 19:33:14 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 19:33:14 +0000 |
commit | 36d22d82aa202bb199967e9512281e9a53db42c9 (patch) | |
tree | 105e8c98ddea1c1e4784a60a5a6410fa416be2de /dom/canvas/test/webgl-conf/checkout/extra/getbuffersubdata-nonblocking-benchmark.html | |
parent | Initial commit. (diff) | |
download | firefox-esr-36d22d82aa202bb199967e9512281e9a53db42c9.tar.xz firefox-esr-36d22d82aa202bb199967e9512281e9a53db42c9.zip |
Adding upstream version 115.7.0esr.upstream/115.7.0esrupstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'dom/canvas/test/webgl-conf/checkout/extra/getbuffersubdata-nonblocking-benchmark.html')
-rw-r--r-- | dom/canvas/test/webgl-conf/checkout/extra/getbuffersubdata-nonblocking-benchmark.html | 223 |
1 files changed, 223 insertions, 0 deletions
diff --git a/dom/canvas/test/webgl-conf/checkout/extra/getbuffersubdata-nonblocking-benchmark.html b/dom/canvas/test/webgl-conf/checkout/extra/getbuffersubdata-nonblocking-benchmark.html new file mode 100644 index 0000000000..e6233ea83f --- /dev/null +++ b/dom/canvas/test/webgl-conf/checkout/extra/getbuffersubdata-nonblocking-benchmark.html @@ -0,0 +1,223 @@ +<!-- +Copyright (c) 2019 The Khronos Group Inc. +Use of this source code is governed by an MIT-style license that can be +found in the LICENSE.txt file. +--> + +<!DOCTYPE html> +<html> +<head> +<meta charset="utf-8"> +<title>getBufferSubData non-blocking test</title> +<link rel="stylesheet" href="../resources/js-test-style.css"/> +<script src="../js/js-test-pre.js"></script> +<script src="../js/webgl-test-utils.js"> </script> +</head> +<body> +<div id="description"></div> +<div id="console"></div> +<script> +"use strict"; +description("Test that getBufferSubData is non-blocking when used with fenceSync"); + +var wtu = WebGLTestUtils; + +var gl = wtu.create3DContext(undefined, undefined, 2); + +const srcData = new Uint8Array([ 1.0, 2.0, 3.0, 4.0, 5.0, 6.0, 7.0, 8.0 ]); +const zeroData = new Uint8Array(8); + +const srcBuffer = gl.createBuffer(); +gl.bindBuffer(gl.COPY_READ_BUFFER, srcBuffer); +gl.bufferData(gl.COPY_READ_BUFFER, srcData, gl.STATIC_DRAW); + +const readbackBuffer = gl.createBuffer(); +gl.bindBuffer(gl.COPY_WRITE_BUFFER, readbackBuffer); +gl.bufferData(gl.COPY_WRITE_BUFFER, 8, gl.STREAM_READ); + +// unrelated buffers for tests +gl.bindBuffer(gl.ARRAY_BUFFER, gl.createBuffer()); // used as copy dst +gl.bufferData(gl.ARRAY_BUFFER, 8, gl.STATIC_DRAW); +gl.bindBuffer(gl.UNIFORM_BUFFER, gl.createBuffer()); // used as copy src +gl.bufferData(gl.UNIFORM_BUFFER, 8, gl.STATIC_DRAW); + +const dest = new Uint8Array(8); + +// Makes a new "resolvable" Promise +function resolvable() { + let resolve; + const promise = new Promise(res => { resolve = res; }); + promise.resolve = resolve; + return promise; +} + +function fence() { + const promise = resolvable(); + + const sync = gl.fenceSync(gl.SYNC_GPU_COMMANDS_COMPLETE, 0); + gl.flush(); + function check() { + const status = gl.clientWaitSync(sync, 0, 0); + if (status == gl.ALREADY_SIGNALED || status == gl.CONDITION_SATISFIED) { + gl.deleteSync(sync); + promise.resolve(); + } else { + setTimeout(check, 0); + } + } + setTimeout(check, 0); + + return promise; +} + +function writeToReadbackBuffer() { + gl.copyBufferSubData(gl.COPY_READ_BUFFER, gl.COPY_WRITE_BUFFER, 0, 0, 8); +} + +function timedGetBufferSubData() { + dest.fill(0); + const t0 = performance.now(); + gl.getBufferSubData(gl.COPY_WRITE_BUFFER, 0, dest); + return (performance.now() - t0); +} + +function timeBlockingReadback() { + const promise = resolvable(); + setTimeout(() => { + writeToReadbackBuffer(); + const tBlocking = timedGetBufferSubData(); + const tLatency = tBlocking; + promise.resolve({latency: tLatency, blocking: tBlocking}); + }, 0); + return promise; +} + +function timeNonblockingReadback() { + writeToReadbackBuffer(); + const tLatency0 = performance.now(); + return fence().then(() => { + const tBlocking = timedGetBufferSubData(); + const tLatency = performance.now() - tLatency0; + return {latency: tLatency, blocking: tBlocking}; + }); +} + +function timeReadbackWithUnrelatedCopy() { + writeToReadbackBuffer(); + const tLatency0 = performance.now(); + const f = fence(); + // copy to a buffer unrelated to the readback + gl.copyBufferSubData(gl.COPY_READ_BUFFER, gl.ARRAY_BUFFER, 0, 0, 8); + return f.then(() => { + const tBlocking = timedGetBufferSubData(); + const tLatency = performance.now() - tLatency0; + return {latency: tLatency, blocking: tBlocking}; + }); +} + +function timeReadbackInterrupted() { + writeToReadbackBuffer(); + const tLatency0 = performance.now(); + const f = fence(); + // interrupt the readback by inserting another write + gl.copyBufferSubData(gl.UNIFORM_BUFFER, gl.COPY_WRITE_BUFFER, 0, 0, 8); + return f.then(() => { + const tBlocking = timedGetBufferSubData(); + const tLatency = performance.now() - tLatency0; + return {latency: tLatency, blocking: tBlocking}; + }); +} + +function computeMean(timings) { + let total = 0; + for (let i = 0; i < timings.length; ++i) { + total += timings[i]; + } + return total / timings.length; +} + +function measureMean(fn, iterations) { + const timingsLatency = Array(iterations); + const timingsBlocking = Array(iterations); + + // Chain together `iterations` promises to call `fn` sequentially. + let promise = Promise.resolve(); + for (let i = 0; i < iterations; ++i) { + promise = promise + .then(fn) + .then(t => { + timingsLatency[i] = t.latency; + timingsBlocking[i] = t.blocking; + }); + } + + return promise.then(() => { + const meanLatency = computeMean(timingsLatency); + const meanBlocking = computeMean(timingsBlocking); + return { latency: meanLatency, blocking: meanBlocking }; + }); +} + +let t_blocking, t_nonblocking; +let t_unrelated; +let t_interrupted; +Promise.resolve() + .then(() => { + let iterations = 500; + debug(`blocking readback: mean over ${iterations} iterations...`); + return measureMean(timeBlockingReadback, iterations); + }) + .then(t => { + t_blocking = t; + debug(`... latency = ${t.latency}ms, blocking = ${t.blocking}ms`); + }) + .then(() => shouldBeTrue("areArraysEqual(dest, srcData)")) + + .then(() => debug("")) + .then(() => { + let iterations = 500; + debug(`nonblocking readback: mean over ${iterations} iterations...`); + return measureMean(timeNonblockingReadback, iterations); + }) + .then(t => { + t_nonblocking = t; + debug(`... latency = ${t.latency}ms, blocking = ${t.blocking}ms`); + }) + .then(() => shouldBeTrue("areArraysEqual(dest, srcData)")) + + .then(() => debug("")) + .then(() => { + let iterations = 500; + debug(`readback interrupted by unrelated read from copy source: mean over ${iterations} iterations...`); + return measureMean(timeReadbackWithUnrelatedCopy, iterations); + }) + .then(t => { + t_unrelated = t; + debug(`... latency = ${t.latency}ms, blocking = ${t.blocking}ms`); + }) + .then(() => shouldBeTrue("areArraysEqual(dest, srcData)")) + + .then(() => debug("")) + .then(() => { + let iterations = 500; + debug(`readback interrupted by write to readback source: mean over ${iterations} iterations...`); + return measureMean(timeReadbackInterrupted, iterations); + }) + .then(t => { + t_interrupted = t; + debug(`... latency = ${t.latency}ms, blocking = ${t.blocking}ms`); + }) + .then(() => shouldBeTrue("areArraysEqual(dest, zeroData)")) + + .then(() => { + debug(""); + shouldBeTrue("t_nonblocking.blocking < t_blocking.blocking"); + shouldBeTrue("t_unrelated.blocking < t_blocking.blocking"); + shouldBeTrue("t_nonblocking.blocking < t_interrupted.blocking"); + }) + .then(finishTest); + +var successfullyParsed = true; +</script> +</body> +</html> |