database/sqlite
1
0
Fork 0
mirror of https://github.com/sqlite/sqlite.git synced 2025-07-30 19:03:16 +03:00
Code Activity

Resolve missing SQLITE_LOCKED result code which triggered a new (since last checkin) exception in the OPFS VFS. Improve output of the OPFS contention tester app.

Browse Source 
FossilOrigin-Name: 2debbbca33bd4170a1dc4dbb5eb3e68523e51d289b06c551e5560ac4e32e433b
This commit is contained in:
stephan
2022-11-21 04:12:38 +00:00
parent 27c4cd183d
commit 36d5554c9a
6 changed files with 36 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
ext/wasm/tests/opfs/concurrency/test.js
View File

@ -1,6 +1,6 @@
(async function(self){
const logClass = (function(){
const logCss = (function(){
const mapToString = (v)=>{
switch(typeof v){
case 'number': case 'string': case 'boolean':
@ -20,7 +20,7 @@
};
const normalizeArgs = (args)=>args.map(mapToString);
const logTarget = document.querySelector('#test-output');
const logClass = function(cssClass,...args){
const logCss = function(cssClass,...args){
const ln = document.createElement('div');
if(cssClass){
for(const c of (Array.isArray(cssClass) ? cssClass : [cssClass])){
@ -41,10 +41,10 @@
cbReverse.checked = !!(+localStorage.getItem(cbReverseKey));
}
cbReverseIt();
return logClass;
return logCss;
})();
const stdout = (...args)=>logClass('',...args);
const stderr = (...args)=>logClass('error',...args);
const stdout = (...args)=>logCss('',...args);
const stderr = (...args)=>logCss('error',...args);
const wait = async (ms)=>{
return new Promise((resolve)=>setTimeout(resolve,ms));
@ -67,9 +67,6 @@
const wName = msg.worker;
const prefix = 'Worker ['+wName+']:';
switch(msg.type){
case 'stdout': stdout(prefix,...msg.payload); break;
case 'stderr': stderr(prefix,...msg.payload); break;
case 'error': stderr(prefix,"ERROR:",...msg.payload); break;
case 'loaded':
stdout(prefix,"loaded");
if(++workers.loadedCount === workers.length){
@ -77,7 +74,16 @@
workers.post('run');
}
break;
default: logClass('error',"Unhandled message type:",msg); break;
case 'stdout': stdout(prefix,...msg.payload); break;
case 'stderr': stderr(prefix,...msg.payload); break;
case 'error': stderr(prefix,"ERROR:",...msg.payload); break;
case 'finished':
logCss('tests-pass',prefix,...msg.payload);
break;
case 'failed':
logCss('tests-fail',prefix,"FAILED:",...msg.payload);
break;
default: logCss('error',"Unhandled message type:",msg); break;
}
};