database/sqlite
1
0
Fork 0
mirror of https://github.com/sqlite/sqlite.git synced 2025-07-29 08:01:23 +03:00
Code Activity

Integrate the opfs-sahpool VFS into the JS build and get it loading (but it's still far from functional).

Browse Source 
FossilOrigin-Name: ef96e6b586825a2b3ed011174309cba8ce1031876c86dc59ed87ab9bbc64f57f
This commit is contained in:
stephan
2023-07-14 21:48:45 +00:00
parent 50c61825fc
commit 92bf6fd4f6
5 changed files with 28 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
ext/wasm/api/sqlite3-vfs-opfs-sahpool.js
View File

@ -79,7 +79,7 @@ const installOpfsVfs = async function(sqlite3){
sqlite3.config.log
];
const logImpl = (level,...args)=>{
if(verbosity>level) loggers[level]("OPFS syncer:",...args);
if(verbosity>level) loggers[level]("opfs-sahpool:",...args);
};
const log = (...args)=>logImpl(2, ...args);
const warn = (...args)=>logImpl(1, ...args);
@ -117,13 +117,14 @@ const installOpfsVfs = async function(sqlite3){
unavailable in the WASM build.*/;
const pDVfs = capi.sqlite3_vfs_find(null)/*default VFS*/;
const dVfs = pDVfs
? new sqlite3_vfs(pDVfs)
? new capi.sqlite3_vfs(pDVfs)
: null /* dVfs will be null when sqlite3 is built with
SQLITE_OS_OTHER. */;
opfsVfs.$iVersion = 2/*yes, two*/;
opfsVfs.$szOsFile = capi.sqlite3_file.structInfo.sizeof;
opfsVfs.$mxPathname = HEADER_MAX_PATH_SIZE;
opfsVfs.$zName = wasm.allocCString("opfs-sahpool");
log('opfsVfs.$zName =',opfsVfs.$zName);
opfsVfs.addOnDispose(
'$zName', opfsVfs.$zName,
'cleanup default VFS wrapper', ()=>(dVfs ? dVfs.dispose() : null)
@ -143,9 +144,9 @@ const installOpfsVfs = async function(sqlite3){
addCapacity: async function(n){
for(let i = 0; i < n; ++i){
const name = Math.random().toString(36).replace('0.','');
const h = await this.dirHandle.getFileName(name, {create:true});
const h = await this.dirHandle.getFileHandle(name, {create:true});
const ah = await h.createSyncAccessHandle();
this.mapAH2Name(ah,name);
this.mapAH2Name.set(ah,name);
this.setAssociatedPath(ah, '', 0);
}
},
@ -280,21 +281,29 @@ const installOpfsVfs = async function(sqlite3){
return i;
};
}
if(!opfsVfs.$xSleep){
vfsSyncWrappers.xSleep = function(pVfs,ms){
return 0;
};
}
try{
log("vfs list:",capi.sqlite3_js_vfs_list());
sqlite3.vfs.installVfs({
io: {struct: opfsIoMethods, methods: ioSyncWrappers},
vfs: {struct: opfsVfs, methods: vfsSyncWrappers}
});
log("vfs list:",capi.sqlite3_js_vfs_list());
}catch(e){
promiseReject(e);
return;
}
VState.isReady = VState.reset().then(async ()=>{
if(0===VState.getCapacity())[
if(0===VState.getCapacity()){
await VState.addCapacity(DEFAULT_CAPACITY);
}
log("opfs-sahpool VFS initialized.");
promiseResolve(sqlite3);
}).catch(promiseReject);
})/*thePromise*/;