Struct InMemorySlotAllocator 

pub struct InMemorySlotAllocator { /* private fields */ }

In-Memory-Slot-Allocator. Vermittelt das gleiche SlotBackend-Interface wie der POSIX-mmap-Backend (posix.rs), aber liegt im Process-Heap — Single-Process-Pub/Sub und Test-Setups ohne mmap-Dep.

Implementations

impl InMemorySlotAllocator

pub fn new(segment_id: u64, slot_count: usize, slot_capacity: usize) -> Self

Erzeugt einen neuen Allocator mit slot_count Slots zu je slot_capacity Bytes Daten-Bereich.

pub fn with_type_hash(self, hash: [u8; 16]) -> Self

Spec §6.1: Allocator mit verbundenem Type-Hash. Reader, der gegen diesen Backend liest, prueft den Hash gegen T::TYPE_HASH und droppt bei Mismatch.

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

Spec §4.1 reserve_slot. Sucht einen freien Slot (alle aktiven Reader haben gelesen) oder den ersten unbenutzten.

Errors

NoFreeSlot wenn alle Slots geloant oder unfertig.

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

Spec §4.1 commit_slot. Schreibt sample-bytes in den Slot und setzt SlotHeader { sn, sample_size, reader_mask=0 }.

Errors

OutOfBounds, SampleTooLarge, oder Lock-Poison.

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

Spec §4.1 release_slot (kein commit; verwirft Loan).

Errors

OutOfBounds oder Lock-Poison.

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

Reader-Side: liest Slot-Header + bytes.

Errors

OutOfBounds.

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

Reader-Side: setzt reader_index-Bit im reader_mask.

Errors

OutOfBounds oder Lock-Poison.

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

Spec §5.2 Reader-Disconnect retroaktiv.

Wird vom Caller (SPDP-Lease-Expiry-Hook) gerufen wenn ein Reader gestorben ist. Setzt sein Bit auf allen Slots, damit der Slot-Allocator ihn als “hat gelesen” sieht und belegte Slots wieder freigibt.

Errors

Lock-Poison.

pub fn slot_capacity(&self) -> usize

Slot-Capacity (data-Bereich; ohne Header).

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

Anzahl konfigurierter Slots.

pub fn slot_total_size(&self) -> usize

Berechnet die Gesamt-Slot-Groesse (Header + Daten, gepaddet auf 64-byte Cache-Line) — fuer SEDP-Discovery.

Trait Implementations

impl SlotBackend for InMemorySlotAllocator

Available on crate feature std only.

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.