def parse.multi.block.decoded

mylsm-lsm-store@0.6.0.1 · src/ByteSstFile.bend:1684

import Base
import mylsm-lsm-store@0.6.0.1/src/ByteMemTable.bend as ByteMemTable
import mylsm-lsm-store@0.6.0.1/src/ByteWal.bend as ByteWal
import mylsm-lsm-store@0.6.0.1/src/coordinator/QueuePolicy.bend as QueuePolicy
import mylsm-lsm-store@0.6.0.1/src/Wal.bend as Wal
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes

1684def parse.multi.block.decoded(
1685  result: Result<&1, &1, Wal.Error, ByteWal.Batch>,
1686  file: Bytes.Bytes,
1687  index_offset: Nat,
1688  next_block: Nat,
1689  block_count: Nat,
1690  level: U32,
1691  total: Nat,
1692  decoded: Nat,
1693  table: ByteMemTable.Table,
1694  record_count: Nat
1695) -> Result<&1, &1, Error, MultiRead>:
1696  match result:
1697    case Fail{Wal.ChecksumMismatch{}}: Fail{ChecksumMismatch{}}
1698    case Fail{_}: Fail{Malformed{}}
1699    case Done{ByteWal.Batch{mutations}}:
1700      parse.multi.block.apply(QueuePolicy.nat.clone.pair(record_count),
1701        table, mutations, file, index_offset, next_block, block_count, level,
1702        total, decoded)