def open.wal

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

import Base
import mylsm-lsm-store@0.6.0.1/src/ByteMemTable.bend as ByteMemTable
import mylsm-lsm-store@0.6.0.1/src/ByteWalIo.bend as ByteWalIo
import mylsm-lsm-store@0.6.0.1/src/DbLock.bend as DbLock
import mylsm-lsm-store@0.6.0.1/src/scan/VisibleStats.bend as VisibleStats

258# Replays the byte WAL into an empty in-memory delta after SST validation.
259def open.wal(
260  +path: String,
261  lock: DbLock.Lock,
262  base_stats: VisibleStats.Stats
263) -> IO(Result<&1, &1, Error, Handle>):
264  do IO<Result<&1, &1, Error, Handle>>:
265    replayed : Result<&1, &1, U32 & String, ByteMemTable.Table> <-
266      ByteWalIo.recover.from(path ++ "/WAL", ByteMemTable.empty())
267    recovered(path, lock, base_stats, replayed)