Skip to main content

check_native_exec_forwarding_cut

Function check_native_exec_forwarding_cut 

Source
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.