pub(super) fn init_shutdown(&self, err: Option<io::Error>) {
        if err.is_some() {
            self.io_stopped(err);
        } else if !self
            .flags
            .get()
            .intersects(Flags::IO_STOPPED | Flags::IO_STOPPING | Flags::IO_STOPPING_FILTERS)
        {
            log::trace!("initiate io shutdown {:?}", self.flags.get());
            self.insert_flags(Flags::IO_STOPPING_FILTERS);
            self.shutdown_filters();
        }
    }
/// Gracefully shutdown read and write io tasks
Gracefully shutdown read and write io tasks
Gracefully shutdown read and write io tasks
pub(super) fn init_shutdown(&self, err: Option<io::Error>) {
        if err.is_some() {
            self.io_stopped(err);
        } else if !self
            .flags
            .get()
            .intersects(Flags::IO_STOPPED | Flags::IO_STOPPING | Flags::IO_STOPPING_FILTERS)
        {
            log::trace!("initiate io shutdown {:?}", self.flags.get());
            self.insert_flags(Flags::IO_STOPPING_FILTERS);
            self.shutdown_filters();
        }
    }
pub ( super ) fn init_shutdown ( & self , err : Option < io :: Error > ) { if err . is_some ( ) { self . io_stopped ( err ) ; } else if ! self . flags . get ( ) . intersects ( Flags :: IO_STOPPED | Flags :: IO_STOPPING | Flags :: IO_STOPPING_FILTERS ) { log :: trace ! ( " " self flags get ( ) ) ; self . insert_flags ( Flags :: IO_STOPPING_FILTERS ) ; self . shutdown_filters ( ) ; } }
Gracefully shutdown read and write io tasks
Gracefully shutdown read and write io tasks
&self
err
Option<io::Error>
&self
err
Option<io::Error>