test_MigrationUtils_timedRetry.js (761B)
1 "use strict"; 2 3 let tmpFile = FileUtils.getDir("TmpD", []); 4 let dbConn; 5 6 add_task(async function setup() { 7 tmpFile.append("TestDB"); 8 dbConn = await Sqlite.openConnection({ path: tmpFile.path }); 9 10 registerCleanupFunction(async () => { 11 await dbConn.close(); 12 await IOUtils.remove(tmpFile.path); 13 }); 14 }); 15 16 add_task(async function testgetRowsFromDBWithoutLocksRetries() { 17 let deferred = Promise.withResolvers(); 18 let promise = MigrationUtils.getRowsFromDBWithoutLocks( 19 tmpFile.path, 20 "Temp DB", 21 "SELECT * FROM moz_temp_table", 22 deferred.promise 23 ); 24 await new Promise(resolve => do_timeout(50, resolve)); 25 dbConn 26 .execute("CREATE TABLE moz_temp_table (id INTEGER PRIMARY KEY)") 27 .then(deferred.resolve); 28 await promise; 29 });