def next.body.parsed

mylsm-lsm-store@0.6.0.1 · src/scan/ByteBlockReader.bend:1272

import mylsm-lsm-store@0.6.0.1/src/scan/ByteBlockReader.bend as ByteBlockReader
import Base
import mylsm-lsm-store@0.6.0.1/src/ByteSstFile.bend as ByteSstFile
import mylsm-lsm-store@0.6.0.1/src/ByteMemTable.bend as ByteMemTable
import bend-kit-bytes@0.3.2.0/bytes.bend as Bytes

1272def next.body.parsed(
1273  file: File,
1274  state: State,
1275  block_bytes: Bytes.Bytes,
1276  +payload_length: U32,
1277  valid_checksum: Bool,
1278  result: Result<&1, &1, ByteSstFile.Error, ByteMemTable.Table>
1279) -> IO(Result<&1, &1, U32 & String, Step>):
1280  match valid_checksum:
1281    case False{}:
1282      close.failed(file, corruption("byte SST block checksum mismatch"))
1283    case True{}:
1284      match result:
1285        case Fail{error}:
1286          close.failed(file, codec.error(error))
1287        case Done{ByteMemTable.Table{entries}}:
1288          next.body.ordered(file, state, block_bytes, payload_length,
1289            ByteMemTable.count.keep(entries))

Uses (17)

Used by (1)