aboutsummaryrefslogtreecommitdiff
path: root/ext/wasm/tests/opfs/concurrency/worker.js
diff options
context:
space:
mode:
authorstephan <stephan@noemail.net>2022-11-21 04:12:38 +0000
committerstephan <stephan@noemail.net>2022-11-21 04:12:38 +0000
commit36d5554c9abaa3080e85e3b7b517605c6106587d (patch)
treea4fc23360bf7aaa42ef7f6dcd669624a2bece552 /ext/wasm/tests/opfs/concurrency/worker.js
parent27c4cd183d91d09e34e310d6349cda2b33c255ba (diff)
downloadsqlite-36d5554c9abaa3080e85e3b7b517605c6106587d.tar.gz
sqlite-36d5554c9abaa3080e85e3b7b517605c6106587d.zip
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.
FossilOrigin-Name: 2debbbca33bd4170a1dc4dbb5eb3e68523e51d289b06c551e5560ac4e32e433b
Diffstat (limited to 'ext/wasm/tests/opfs/concurrency/worker.js')
-rw-r--r--ext/wasm/tests/opfs/concurrency/worker.js12
1 files changed, 8 insertions, 4 deletions
diff --git a/ext/wasm/tests/opfs/concurrency/worker.js b/ext/wasm/tests/opfs/concurrency/worker.js
index 7ba15bf8c..9aaa2f4c7 100644
--- a/ext/wasm/tests/opfs/concurrency/worker.js
+++ b/ext/wasm/tests/opfs/concurrency/worker.js
@@ -26,7 +26,7 @@ self.sqlite3InitModule().then(async function(sqlite3){
wPost('loaded');
const run = async function(){
- const db = new sqlite3.opfs.OpfsDb(dbName);
+ const db = new sqlite3.opfs.OpfsDb(dbName,'c');
//sqlite3.capi.sqlite3_busy_timeout(db.pointer, 2000);
db.transaction((db)=>{
db.exec([
@@ -37,7 +37,7 @@ self.sqlite3InitModule().then(async function(sqlite3){
const maxIterations = 10;
const interval = Object.assign(Object.create(null),{
- delay: 300,
+ delay: 500,
handle: undefined,
count: 0
});
@@ -58,9 +58,13 @@ self.sqlite3InitModule().then(async function(sqlite3){
}
};
const finish = ()=>{
- if(interval.error) stderr("Ending work due to error:",e.message);
- else stdout("Ending work after",interval.count,"interval(s)");
db.close();
+ if(interval.error){
+ wPost('failed',"Ending work after interval #"+interval.count,
+ "due to error:",interval.error);
+ }else{
+ wPost('finished',"Ending work after",interval.count,"intervals.");
+ }
};
if(1){/*use setInterval()*/
interval.handle = setInterval(async ()=>{