Struct QueuedTx 

pub struct QueuedTx<const FRAME: usize = MAX_RESEND_FRAME_LEN> {
    pub priority: TxPriority,
    pub frame: Vec<u8, FRAME>,
    pub receipt: Option<SendReceipt>,
    pub identity_id: Option<LocalIdentityId>,
    pub sequence: u32,
    pub not_before_ms: u64,
    pub cad_attempts: u8,
    pub forward_deferrals: u8,
}

One entry in the TxQueue waiting to be transmitted by the Mac coordinator.

Each QueuedTx holds a complete, already-sealed frame ready to hand directly to the radio driver. The coordinator does not re-seal on retransmit; the frame bytes are the authoritative on-the-wire representation.

• priority — determines service order within the queue. See TxPriority.
• frame — the sealed frame bytes, at most FRAME bytes. The coordinator calls radio.transmit(&entry.frame, tx_options).await when this entry reaches the head of the queue and its not_before_ms has elapsed.
• receipt — for ACK-requested sends, the associated SendReceipt so the coordinator can update the PendingAck state after a successful transmit.
• sequence — a monotonic counter assigned at enqueue time, used to preserve FIFO ordering among entries sharing the same priority.
• not_before_ms — earliest acceptable transmit time in monotonic milliseconds. Entries with a future not_before_ms are skipped until the clock advances past it. Used to introduce per-node forwarding delay jitter that reduces collision probability. Zero means transmit immediately.
• cad_attempts — number of channel-activity-detection retries already consumed on this entry; compared against MAX_CAD_ATTEMPTS to bound medium contention retries.
• forward_deferrals — number of times a queued flood-forward has already been deferred after overhearing another copy of the same packet before it transmitted.

Fields

priority: TxPriority

Priority class.

frame: Vec<u8, FRAME>

Stored frame bytes.

receipt: Option<SendReceipt>

Optional receipt associated with the frame.

identity_id: Option<LocalIdentityId>

Identity that owns this send; set for identity-originated sends, None for internally generated frames (MAC ACKs, forwarded frames).

sequence: u32

Monotonic sequence number for stable ordering.

not_before_ms: u64

Earliest transmission timestamp.

cad_attempts: u8

Number of CAD attempts already consumed.

forward_deferrals: u8

Number of overheard-repeat deferrals already consumed.

Implementations

impl<const FRAME: usize> QueuedTx<FRAME>

pub fn try_new( priority: TxPriority, frame: &[u8], receipt: Option<SendReceipt>, identity_id: Option<LocalIdentityId>, sequence: u32, ) -> Result<Self, CapacityError>

Create a queue entry ready to send immediately.

pub fn try_new_with_state( priority: TxPriority, frame: &[u8], receipt: Option<SendReceipt>, identity_id: Option<LocalIdentityId>, sequence: u32, not_before_ms: u64, cad_attempts: u8, forward_deferrals: u8, ) -> Result<Self, CapacityError>

Create a queue entry with explicit timer and CAD state.

Trait Implementations

impl<const FRAME: usize> Clone for QueuedTx<FRAME>

fn clone(&self) -> QueuedTx<FRAME>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<const FRAME: usize> Debug for QueuedTx<FRAME>

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

Formats the value using the given formatter.

impl<const FRAME: usize> PartialEq for QueuedTx<FRAME>

fn eq(&self, other: &QueuedTx<FRAME>) -> bool

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<const FRAME: usize> Eq for QueuedTx<FRAME>

impl<const FRAME: usize> StructuralPartialEq for QueuedTx<FRAME>