Struct PosixSlotAllocator 

pub struct PosixSlotAllocator { /* private fields */ }

POSIX-mmap Slot-Allocator. Ein Owner-Process erzeugt das Segment; Consumer-Processes attachen via attach.

Implementations

impl PosixSlotAllocator

pub fn create<P: Into<PathBuf>>( flink_path: P, slot_count: usize, slot_capacity: usize, ) -> Result<Self, PosixSlotError>

Erzeugt ein neues POSIX-SHM-Segment als Owner.

flink_path ist eine Datei im Filesystem (typisch /tmp/zerodds/<segment_id>.flink), die dem Consumer den realen OS-Segment-Namen verraet.

Errors

Shm bei shm_open-Fehler; CapacityOverflow wenn slot_capacity > u32::MAX.

pub fn attach<P: Into<PathBuf>>(flink_path: P) -> Result<Self, PosixSlotError>

Attached an ein bestehendes POSIX-SHM-Segment via flink-Pfad. Der Caller wird Consumer (kein Owner — Drop unmappt nur, nicht shm_unlink).

Errors

Shm bei attach-Fehler; InvalidHeader wenn Magic/Layout nicht stimmt.

pub fn flink_path(&self) -> &str

Pfad der flink-Datei (fuer Discovery).

pub fn segment_path(&self) -> String

Liefert den Segment-Pfad als String fuer den ShmLocator. Dies ist das, was im PID_SHM_LOCATOR steht.

Trait Implementations

impl SlotBackend for PosixSlotAllocator

fn reserve_slot( &self, active_readers_mask: ReaderMask, ) -> Result<SlotHandle, SlotError>

Reserviert einen freien Slot. Caller schreibt danach via commit_slot und veroeffentlicht damit das Sample.

fn commit_slot( &self, handle: SlotHandle, bytes: &[u8], ) -> Result<u32, SlotError>

Schreibt sample-bytes in den Slot und setzt SlotHeader { sn, sample_size, reader_mask=0 }. Liefert die SN.

fn discard_slot(&self, handle: SlotHandle) -> Result<(), SlotError>

Verwirft einen Loan ohne Commit. Slot wird wieder frei.

fn read_slot( &self, handle: SlotHandle, ) -> Result<(SlotHeader, Vec<u8>), SlotError>

Liest Slot-Header + Daten-Bytes (kopiert).

fn mark_read( &self, handle: SlotHandle, reader_index: u8, ) -> Result<(), SlotError>

Setzt das Bit reader_index im reader_mask des Slots (Reader hat gelesen).

fn mark_reader_disconnected(&self, reader_index: u8) -> Result<(), SlotError>

Setzt das reader_index-Bit retroaktiv auf allen Slots (SPDP-Lease-Expiry).

fn slot_count(&self) -> Result<usize, SlotError>

Anzahl konfigurierter Slots.

fn slot_total_size(&self) -> usize

Gesamt-Slot-Groesse (Header + Daten + Padding); fuer Discovery.

fn slot_capacity(&self) -> usize

Daten-Bereich pro Slot (ohne Header, ohne Padding).

fn type_hash(&self) -> Option<[u8; 16]>

Spec §6.1: TYPE_HASH des Topic-Type, falls dem Backend bekannt. None = Backend trackt keinen Hash; Caller muss auf andere Weise (z.B. Discovery) verifizieren. Default: None.

impl Send for PosixSlotAllocator

impl Sync for PosixSlotAllocator