def open_existing_wait

mylsm-lsm-store@0.6.0.1 · src/ByteDurableDb.bend:458

import mylsm-lsm-store@0.6.0.1/src/ByteDurableDb.bend as ByteDurableDb
import Base
import mylsm-lsm-store@0.6.0.1/src/Fs.bend as Fs

458# Opens an existing byte database after immediate or bounded lock acquisition.
459def open_existing_wait(
460  +path: String,
461  timeout_ms: U32,
462  backoff_ms: U32
463) -> IO(Result<&1, &1, Error, Handle>):
464  do IO<Result<&1, &1, Error, Handle>>:
465    present : Result<&1, &1, U32 & String, Bool> <- Fs.exists(path ++ "/WAL")
466    open.existing.wait.present(path, timeout_ms, backoff_ms, present)

Uses (12)

Used by (1)