logos-storage/logos-storage-nim
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim.git synced 2026-05-12 06:19:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove unneeded keepalives

Browse Source
This commit is contained in:
E M 2026-03-23 16:20:28 +11:00
parent ef989571b5
commit 554ea683a3
No known key found for this signature in database
1 changed files with 10 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
tests/js/harness.js
View File

@ -163,26 +163,21 @@ export class StorageNode {
* Resolves when the node is ready (storage_new callback fires RET_OK).
*/
async create(configJson) {
let cb;
const promise = new Promise((resolve, reject) => {
const keepAlive = setInterval(() => {}, 200);
cb = koffi.register((ret, msg, _len, _userData) => {
clearInterval(keepAlive);
return new Promise((resolve, reject) => {
let cb = koffi.register((ret, msg, _len, _userData) => {
koffi.unregister(cb);
if (ret === RET_OK) resolve();
else reject(new Error(msg ?? 'storage_new callback failed'));
}, koffi.pointer(StorageCallback));
this.#ctx = _lib.storage_new(configJson, cb, null);
if (!this.#ctx) {
koffi.unregister(cb);
throw new Error('storage_new returned null — check configJson');
}
});
this.#ctx = _lib.storage_new(configJson, cb, null);
if (!this.#ctx) {
koffi.unregister(cb);
throw new Error('storage_new returned null — check configJson');
}
await promise;
return this;
}
/** Returns the version string synchronously (e.g. "v0.3.2") */