Struct tokio::runtime::io::registration_set::RegistrationSet

pub(super) struct RegistrationSet {
    num_pending_release: AtomicUsize,
}

Fields

num_pending_release: AtomicUsize

Implementations

impl RegistrationSet

pub(super) fn new() -> (RegistrationSet, Synced)

pub(super) fn is_shutdown(&self, synced: &Synced) -> bool

pub(super) fn needs_release(&self) -> bool

Returns true if there are registrations that need to be released

pub(super) fn allocate(&self, synced: &mut Synced) -> Result<Arc<ScheduledIo>>

pub(super) fn deregister( &self, synced: &mut Synced, registration: &Arc<ScheduledIo>, ) -> bool

pub(super) fn shutdown(&self, synced: &mut Synced) -> Vec<Arc<ScheduledIo>>

pub(super) fn release(&self, synced: &mut Synced)

pub(super) unsafe fn remove(&self, synced: &mut Synced, io: &ScheduledIo)