def admit.inputs

mylsm-lsm-store@0.6.0.1 · src/coordinator/QueuePolicy.bend:40

import Base

40def admit.inputs(
41  count: Nat,
42  queued_pair: Nat & Nat,
43  request_pair: Nat & Nat,
44  max_queue_bytes: Nat,
45  within_request_limit: Bool,
46  within_count: Bool
47) -> Decision:
48  match queued_pair:
49    case (queued_check, queued_output):
50      match request_pair:
51        case (request_check, request_output):
52          admit.decision(count, within_request_limit, within_count,
53            admit.total.pair(Nat.add(queued_check, request_check),
54              Nat.add(queued_output, request_output), max_queue_bytes))