pub fn check_native_exec_forwarding_cut(
owner_tid: i32,
produced: u64,
previous: Option<&CoordinatorForwardingReceipt>,
) -> Result<CoordinatorForwardingReceipt, CoordinatorForwardingCutError>Expand description
Collect, write and check one owner’s actual counted interval, then require the registered forwarding source to have no unchecked or queued records.
Unlike check_forwarded_count, this successor-only inspection refuses a
missing or unhealthy message source and any persistent determinism loss; it
checks zero too. It uses the unchanged request/COMMIT order rule and never
substitutes captured line counts for actual socket records. A refusal retains
all unchecked intervals and queues (records collected during the check remain
queued); a success consumes only the interval that was actually validated.
The caller must bind owner_tid and produced through its authenticated
counted request, exclude concurrent producers, and repeat this check with the
returned receipt at the final cut. The sink must report write failures through
record_determinism_loss, as the existing sink interface returns no result.
This coordinator-local receipt is not a guest acknowledgment, watched-birth
authority, scheduler permission, or proof that a later exec edge is neutral.