mirror of
https://github.com/encounter/dawn-cmake.git
synced 2025-05-14 11:21:40 +00:00
b6c150d6e0
Adds the duration of WebGPU CTS tests to the payload sent to the test harness so that it can be reported to ResultDB. Bug: chromium:1336333 Change-Id: I06e16be2c51807c8fbe37730008ed2bd68f82f6c Reviewed-on: https://dawn-review.googlesource.com/c/dawn/+/94520 Auto-Submit: Brian Sheedy <bsheedy@google.com> Commit-Queue: Austin Eng <enga@chromium.org> Commit-Queue: Brian Sheedy <bsheedy@google.com> Reviewed-by: Austin Eng <enga@chromium.org>
102 lines
3.5 KiB
JavaScript
102 lines
3.5 KiB
JavaScript
// Copyright 2022 The Dawn Authors
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
import { DefaultTestFileLoader } from '../third_party/webgpu-cts/src/common/internal/file_loader.js';
|
|
import { prettyPrintLog } from '../third_party/webgpu-cts/src/common/internal/logging/log_message.js';
|
|
import { Logger } from '../third_party/webgpu-cts/src/common/internal/logging/logger.js';
|
|
import { parseQuery } from '../third_party/webgpu-cts/src/common/internal/query/parseQuery.js';
|
|
|
|
import { TestWorker } from '../third_party/webgpu-cts/src/common/runtime/helper/test_worker.js';
|
|
|
|
// The Python-side websockets library has a max payload size of 72638. Set the
|
|
// max allowable logs size in a single payload to a bit less than that.
|
|
const LOGS_MAX_BYTES = 72000;
|
|
|
|
var socket;
|
|
|
|
function byteSize(s) {
|
|
return new Blob([s]).size;
|
|
}
|
|
|
|
async function setupWebsocket(port) {
|
|
socket = new WebSocket('ws://127.0.0.1:' + port)
|
|
socket.addEventListener('message', runCtsTestViaSocket);
|
|
}
|
|
|
|
async function runCtsTestViaSocket(event) {
|
|
let input = JSON.parse(event.data);
|
|
runCtsTest(input['q'], input['w']);
|
|
}
|
|
|
|
async function runCtsTest(query, use_worker) {
|
|
const workerEnabled = use_worker;
|
|
const worker = workerEnabled ? new TestWorker(false) : undefined;
|
|
|
|
const loader = new DefaultTestFileLoader();
|
|
const filterQuery = parseQuery(query);
|
|
const testcases = await loader.loadCases(filterQuery);
|
|
|
|
const expectations = [];
|
|
|
|
const log = new Logger();
|
|
|
|
for (const testcase of testcases) {
|
|
const name = testcase.query.toString();
|
|
|
|
const wpt_fn = async () => {
|
|
const [rec, res] = log.record(name);
|
|
if (worker) {
|
|
await worker.run(rec, name, expectations);
|
|
} else {
|
|
await testcase.run(rec, expectations);
|
|
}
|
|
|
|
let fullLogs = (res.logs ?? []).map(prettyPrintLog);
|
|
fullLogs = fullLogs.join('\n\n\n');
|
|
let logPieces = [fullLogs]
|
|
// Split the log pieces until they all are guaranteed to fit into a
|
|
// websocket payload.
|
|
while (true) {
|
|
let tempLogPieces = []
|
|
for (const piece of logPieces) {
|
|
if (byteSize(piece) > LOGS_MAX_BYTES) {
|
|
let midpoint = Math.floor(piece.length / 2);
|
|
tempLogPieces.push(piece.substring(0, midpoint));
|
|
tempLogPieces.push(piece.substring(midpoint));
|
|
} else {
|
|
tempLogPieces.push(piece)
|
|
}
|
|
}
|
|
// Didn't make any changes - all pieces are under the size limit.
|
|
if (logPieces.every((value, index) => value == tempLogPieces[index])) {
|
|
break;
|
|
}
|
|
logPieces = tempLogPieces;
|
|
}
|
|
|
|
logPieces.forEach((piece, index, arr) => {
|
|
let isFinal = index == arr.length - 1;
|
|
socket.send(JSON.stringify({'s': res.status,
|
|
'l': piece,
|
|
'final': isFinal,
|
|
'js_duration_ms': res.timems}));
|
|
});
|
|
};
|
|
await wpt_fn();
|
|
}
|
|
}
|
|
|
|
window.runCtsTest = runCtsTest;
|
|
window.setupWebsocket = setupWebsocket
|