Struct AeronRetransmitHandler

Source

pub struct AeronRetransmitHandler { /* private fields */ }

Implementations§

Source §

impl AeronRetransmitHandler

Source

pub fn new( retransmit_action_pool: &AeronRetransmitAction, delay_timeout_ns: u64, linger_timeout_ns: u64, invalid_packets_counter: &mut i64, active_retransmit_count: c_int, has_group_semantics: bool, max_retransmits: usize, retransmit_overflow_counter: &mut i64, ) -> Result<Self, AeronCError>

Source

pub fn new_zeroed_on_heap() -> Self

creates zeroed struct where the underlying c struct is on the heap

Source

pub fn new_zeroed_on_stack() -> Self

creates zeroed struct where the underlying c struct is on the stack (Use with care)

Source

pub fn init( &self, invalid_packets_counter: &mut i64, delay_timeout_ns: u64, linger_timeout_ns: u64, has_group_semantics: bool, max_retransmits: u32, retransmit_overflow_counter: &mut i64, ) -> Result<i32, AeronCError>

Source

pub fn on_nak<AeronRetransmitHandlerResendFuncHandlerImpl: AeronRetransmitHandlerResendFuncCallback + 'static>( &self, term_id: i32, term_offset: i32, length: i32, term_length: usize, mtu_length: usize, flow_control: &AeronFlowControlStrategy, now_ns: i64, resend: Option<AeronRetransmitHandlerResendFuncHandlerImpl>, ) -> Result<Option<Handler<AeronRetransmitHandlerResendFuncHandlerImpl>>, AeronCError>

The callback is retained by the C client; this resource keeps it alive automatically. Returns the created Handler for optional state access — safe to ignore. Closures with a matching signature are accepted directly.

Source

pub fn process_timeouts<AeronRetransmitHandlerResendFuncHandlerImpl: AeronRetransmitHandlerResendFuncCallback + 'static>( &self, now_ns: i64, resend: Option<AeronRetransmitHandlerResendFuncHandlerImpl>, ) -> Result<Option<Handler<AeronRetransmitHandlerResendFuncHandlerImpl>>, AeronCError>

The callback is retained by the C client; this resource keeps it alive automatically. Returns the created Handler for optional state access — safe to ignore. Closures with a matching signature are accepted directly.

Source

pub fn get_inner(&self) -> *mut aeron_retransmit_handler_t

Source

pub unsafe fn get_inner_mut(&self) -> &mut aeron_retransmit_handler_t

Mutable access to the underlying C struct, minted from &self: nothing prevents two live &mut at once, so the caller must ensure exclusive access for the lifetime of the returned reference.

§Safety

No other reference (& or &mut) to the underlying struct may be alive while the returned &mut is in use.

Source

pub fn get_inner_ref(&self) -> &aeron_retransmit_handler_t

Source §

impl AeronRetransmitHandler

Source

pub fn clone_struct(&self) -> Self

Regular clone just increases the reference count of underlying count. clone_struct shallow copies the content of the underlying struct on heap.

NOTE: if the struct has references to other structs these will not be copied

Must be only used on structs which has no init/clean up methods. So its dangerous to use with Aeron/AeronContext/AeronPublication/AeronSubscription More intended for AeronArchiveRecordingDescriptor (note strings will not work as its a shallow copy)