pub(crate) fn bcast_append(&mut self) {
        let ids = self.prs.visit_nodes();
        let cur_id = self.id;
        for id in ids.iter().filter(|id| **id != cur_id) {
            if !self.send_append(*id) {
                debug!(
                    "message not to sent, {} inflights full: {}",
                    id,
                    self.prs.progress.must_get(id).inflights.full()
                );
            }
        }
    }
// sends RPC, with entries to all peers that are not up-to-date
// according to the progress recorded in self.prs.
sends RPC, with entries to all peers that are not up-to-date
according to the progress recorded in self.prs.
sends RPC with entries to all peers that are not up - to - date according to the progress recorded in self . prs .
pub(crate) fn bcast_append(&mut self) {
        let ids = self.prs.visit_nodes();
        let cur_id = self.id;
        for id in ids.iter().filter(|id| **id != cur_id) {
            if !self.send_append(*id) {
                debug!(
                    "message not to sent, {} inflights full: {}",
                    id,
                    self.prs.progress.must_get(id).inflights.full()
                );
            }
        }
    }
pub ( crate ) fn bcast_append ( & mut self ) { let ids = self . prs . visit_nodes ( ) ; let cur_id = self . id ; for id in ids . iter ( ) . filter ( | id | * * id != cur_id ) { if ! self . send_append ( * id ) { debug ! ( " " id self prs progress must_get ( id ) inflights full ( ) ) ; } } }
sends RPC, with entries to all peers that are not up-to-date
according to the progress recorded in self.prs.
sends RPC with entries to all peers that are not up - to - date according to the progress recorded in self . prs .
&mut self