Struct AeronLossDetector

Source

pub struct AeronLossDetector { /* private fields */ }

Implementations§

Source §

impl AeronLossDetector

Source

pub fn new( on_gap_detected: aeron_term_gap_scanner_on_gap_detected_func_t, feedback_delay_state: &AeronFeedbackDelayGeneratorState, on_gap_detected_clientd: *mut c_void, scanned_gap: AeronLossDetectorGap, active_gap: AeronLossDetectorGap, expiry_ns: 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<AeronTermGapScannerGapDetectedFuncHandlerImpl: AeronTermGapScannerGapDetectedFuncCallback>( &self, feedback_delay_state: &AeronFeedbackDelayGeneratorState, on_gap_detected: Option<&Handler<AeronTermGapScannerGapDetectedFuncHandlerImpl>>, ) -> Result<i32, AeronCError>

Source

pub fn init_fn<AeronTermGapScannerGapDetectedFuncHandlerImpl: FnMut(i32, i32, usize)>( &self, feedback_delay_state: &AeronFeedbackDelayGeneratorState, on_gap_detected: AeronTermGapScannerGapDetectedFuncHandlerImpl, ) -> Result<i32, AeronCError>

Stack-borrowed closure (_fn variant): the FnMut closure lives on the caller’s stack and is borrowed for this call only — the callback fires synchronously inside the call, so nothing is heap-allocated, nothing is stored, and the closure may borrow local state. Prefer this over the retained Handler-based form on the hot path; only generated for callbacks the C client does not retain (i.e. not stored for later firing).

§Panics

A panic inside the closure cannot unwind across the extern "C" callback boundary and aborts the process (since Rust 1.81). Return early instead of panicking in production fragment handlers.

Source

pub fn scan( &self, loss_found: &mut bool, buffer: *const u8, rebuild_position: i64, hwm_position: i64, now_ns: i64, term_length_mask: usize, position_bits_to_shift: usize, initial_term_id: i32, ) -> i32

Source

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

Source

pub unsafe fn get_inner_mut(&self) -> &mut aeron_loss_detector_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_loss_detector_t

Source §

impl AeronLossDetector

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)