Struct NondeterministicProposalData 

#[repr(C)]
pub struct NondeterministicProposalData {
    pub nondeterministic_bits: BytesM,
    pub nondeterministic_bit_count: u32,
    pub observed_queue_entry_sequence: VecM<QueueEntry, thruput_xdr::::transaction::NondeterministicProposalData::{constant#0}>,
}

Nondeterministic data captured during transaction execution by the proposer.

Thruput executes transactions in parallel, which introduces nondeterminism (e.g., from two-phase commit conflict resolution). To ensure validators can deterministically re-execute transactions, the proposer captures all nondeterministic decisions and includes them in the block proposal.

This allows validators to replay the exact same execution path as the proposer, ensuring consensus on the transaction result.

Fields

nondeterministic_bits: BytesM

A bitstring of nondeterministic decisions made during execution.

This includes:

• Two-phase commit conflict resolution results from try_invoke frames (one boolean per try_invoke frame that succeeds and attempts lock acquisition)
• Other nondeterministic outcomes that must be consistent across validators

Each bit represents a binary decision point encountered during execution. The bits are consumed sequentially as the transaction re-executes.

nondeterministic_bit_count: u32

The length of nondeterministic_bits in bits (not bytes).

Since nondeterministic_bits.size() returns the rounded-up length in bytes, this field tracks the exact bit count to avoid trailing garbage bits.

observed_queue_entry_sequence: VecM<QueueEntry, thruput_xdr::::transaction::NondeterministicProposalData::{constant#0}>

Retrocausal queue entries inserted by concurrent transactions in the same block that this transaction observed, so validators replay the same reads.

An entry is recorded when a peek or consume reads a concurrent entry. Reads of entries from past blocks or inserted by this transaction itself record nothing. Entries appear in the order they were first observed during execution, interleaved across queues; within one queue they are that queue’s concurrent entries in index order, starting at 0. Each (queue, index) is recorded once however many times it is read, so repeated peeks, or a peek followed by a consume, add a single entry. Whether each concurrent read found an entry is recorded separately, one bit per read, in nondeterministic_bits.

Trait Implementations

impl Clone for NondeterministicProposalData

fn clone(&self) -> NondeterministicProposalData

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ConstMaxSize for NondeterministicProposalData

const MAX_SIZE: Option<usize>

Worst-case CXS encoded size in bytes, or None if unbounded.

impl ConstMaxSize for NondeterministicProposalData

const MAX_SIZE: Option<usize>

Worst-case TXS encoded size in bytes, or None if unbounded.

impl Debug for NondeterministicProposalData

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl EncodesAs<NondeterministicProposalData> for NondeterministicProposalData

impl Eq for NondeterministicProposalData

impl Hash for NondeterministicProposalData

fn hash<__H>(&self, state: &mut __H)

where __H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl JsonSchema for NondeterministicProposalData

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl Ord for NondeterministicProposalData

fn cmp(&self, other: &NondeterministicProposalData) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

fn clamp_to<R>(self, range: R) -> Self

where Self: Sized, R: ClampBounds<Self>,

🔬This is a nightly-only experimental API. (clamp_to)

Restrict a value to a certain range.

impl PartialEq for NondeterministicProposalData

fn eq(&self, other: &NondeterministicProposalData) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl PartialOrd for NondeterministicProposalData

fn partial_cmp(&self, other: &NondeterministicProposalData) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

fn lt(&self, other: &Rhs) -> bool

Tests less than (for self and other) and is used by the < operator.

fn le(&self, other: &Rhs) -> bool

Tests less than or equal to (for self and other) and is used by the <= operator.

fn gt(&self, other: &Rhs) -> bool

Tests greater than (for self and other) and is used by the > operator.

fn ge(&self, other: &Rhs) -> bool

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl<'_r> ReadXDR<'_r> for NondeterministicProposalData

fn read_xdr<R>(r: &mut R) -> Result<NondeterministicProposalData, ReadError>

where R: Reader<'_r>,

Reads an XDR value from the reader.

fn read_xdr_in_place<R, '__xdrs_s>( r: &mut R, __xdrs_slot: Slot<'__xdrs_s, NondeterministicProposalData>, ) -> Result<Init<'__xdrs_s, NondeterministicProposalData>, ReadError>

where R: Reader<'_r>,

Reads an XDR value directly into slot, without first building it on the stack.

impl StructuralPartialEq for NondeterministicProposalData

impl WriteXDR for NondeterministicProposalData

fn write_xdr<F, W>(&self, w: &mut W) -> Result<(), WriteError>

where W: Writer<F>,

Writes this value as XDR data to the writer.

unsafe fn write_xdr_unchecked<F, W>(&self, w: &mut W)

where W: WriterUnchecked<F>,

Writes this value as XDR data to the writer, without runtime checks.