fn inner_add_spu(&self, spu: &SpuSpec) {
        debug!("adding spu: {}", spu.id);

        // there should not be existing entry, if so something is wrong
        if let Some(conn) = self.sinks.get_sink(&spu.id) {
            drop(conn);
            self.sinks.clear_sink(&spu.id);
            warn!(
                "unexpected socket entry found for Spu({}). clearing ",
                spu.id
            );
            self.counter_tbl.inc_counter(&spu.id, ConnCntr::InternalErr);
        }
    }
/// synchronize spu spec with our connection
/// if there exists spu connection, we need to drop it.
synchronize spu spec with our connection
if there exists spu connection, we need to drop it.
synchronize spu spec with our connection if there exists spu connection we need to drop it .
fn inner_add_spu(&self, spu: &SpuSpec) {
        debug!("adding spu: {}", spu.id);
        // there should not be existing entry, if so something is wrong
        if let Some(conn) = self.sinks.get_sink(&spu.id) {
            drop(conn);
            self.sinks.clear_sink(&spu.id);
            warn!(
                "unexpected socket entry found for Spu({}). clearing ",
                spu.id
            );
            self.counter_tbl.inc_counter(&spu.id, ConnCntr::InternalErr);
        }
    }
fn inner_add_spu ( & self , spu : & SpuSpec ) { debug ! ( " " spu id ) ; // there should not be existing entry, if so something is wrong if let Some ( conn ) = self . sinks . get_sink ( & spu . id ) { drop ( conn ) ; self . sinks . clear_sink ( & spu . id ) ; warn ! ( " " spu id ) ; self . counter_tbl . inc_counter ( & spu . id , ConnCntr :: InternalErr ) ; } }
synchronize spu spec with our connection
if there exists spu connection, we need to drop it.
synchronize spu spec with our connection if there exists spu connection we need to drop it .
&self
spu
&SpuSpec
&self
spu
&SpuSpec