Struct EpollSubState 

pub struct EpollSubState {
    fd_meta: Mutex<EpollFd>,
    joins: Mutex<Vec<EpollJoinGuard>>,
    pending_bits: AtomicU8,
    enqueued: AtomicBool,
    generation: AtomicU64,
}

Fields

fd_meta: Mutex<EpollFd>

Snapshot of user-visible metadata.

joins: Mutex<Vec<EpollJoinGuard>>

Guard ownership for all attached handlers.

pending_bits: AtomicU8

Atomic readiness bitset (EPOLLIN/OUT/HUP/ERR).

enqueued: AtomicBool

Queue dedupe flag: whether this sub already has a ready-queue entry.

generation: AtomicU64

Generation used to invalidate stale queue entries after DEL/MOD.

Implementations

impl EpollSubState

pub fn new(fd_meta: EpollFd, generation: u64) -> Self

Creates a new subscription state with empty readiness and queue state.

pub fn next_generation(&self) -> u64

Returns generation + 1 without mutating the current subscription.

Callers use this to seed the generation of a replacement subscription.

pub fn add_join(&self, join: EpollJoinGuard)

Adds a registration guard that will detach handlers when dropped.

pub fn detach_joins(&self)

Detaches and drops all registered handlers for this subscription.

fn generation(&self) -> u64

pub(crate) fn fd_meta(&self) -> EpollFd

fn set_pending(&self, bit: u8) -> bool

fn take_pending_bits(&self) -> u8

fn pending_bits(&self) -> u8

fn mark_enqueued(&self) -> bool

fn clear_enqueued(&self)

Trait Implementations

impl Debug for EpollSubState

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

Formats the value using the given formatter.