fn broadcast_message(&self, entries: &DispatcherMap, message: &Arc<SignedMessage>) {
        let current_index = self.index.load(Ordering::SeqCst) % entries.len() as u64;

        let mut skipped = 0;
        for pair in entries.iter() {
            if skipped != current_index {
                skipped += 1;
                continue;
            }

            let entry = pair.key();
            entry.tell_anonymously(message.clone()).unwrap();
            break;
        }

        self.index.store(current_index + 1, Ordering::SeqCst);
    }
// In according to the current index value we will select the entry that
// will be used as recipient of the message.
In according to the current index value we will select the entry that
will be used as recipient of the message.
In according to the current index value we will select the entry that will be used as recipient of the message .
fn broadcast_message(&self, entries: &DispatcherMap, message: &Arc<SignedMessage>) {
        let current_index = self.index.load(Ordering::SeqCst) % entries.len() as u64;
        let mut skipped = 0;
        for pair in entries.iter() {
            if skipped != current_index {
                skipped += 1;
                continue;
            }
            let entry = pair.key();
            entry.tell_anonymously(message.clone()).unwrap();
            break;
        }
        self.index.store(current_index + 1, Ordering::SeqCst);
    }
fn broadcast_message ( & self , entries : & DispatcherMap , message : & Arc < SignedMessage > ) { let current_index = self . index . load ( Ordering :: SeqCst ) % entries . len ( ) as u64 ; let mut skipped = 0 ; for pair in entries . iter ( ) { if skipped != current_index { skipped += 1 ; continue ; } let entry = pair . key ( ) ; entry . tell_anonymously ( message . clone ( ) ) . unwrap ( ) ; break ; } self . index . store ( current_index + 1 , Ordering :: SeqCst ) ; }
In according to the current index value we will select the entry that
will be used as recipient of the message.
In according to the current index value we will select the entry that will be used as recipient of the message .
&self
entries
&DispatcherMap
message
&Arc<SignedMessage>
&self
entries
&DispatcherMap
message
&Arc<SignedMessage>