fn handle_epoch_started(&mut self, sender_id: &D::NodeId, epoch: D::Epoch) -> CpStep<Self> {
        self.peer_epochs
            .entry(sender_id.clone())
            .and_modify(|e| {
                if *e < epoch {
                    *e = epoch;
                }
            })
            .or_insert(epoch);
        if !self.remove_participant_if_old(sender_id) {
            self.process_new_epoch(sender_id, epoch)
        } else {
            Step::<D>::default()
        }
    }
/// Handles an epoch start announcement.
Handles an epoch start announcement.
Handles an epoch start announcement .
fn handle_epoch_started(&mut self, sender_id: &D::NodeId, epoch: D::Epoch) -> CpStep<Self> {
        self.peer_epochs
            .entry(sender_id.clone())
            .and_modify(|e| {
                if *e < epoch {
                    *e = epoch;
                }
            })
            .or_insert(epoch);
        if !self.remove_participant_if_old(sender_id) {
            self.process_new_epoch(sender_id, epoch)
        } else {
            Step::<D>::default()
        }
    }
fn handle_epoch_started ( & mut self , sender_id : & D :: NodeId , epoch : D :: Epoch ) -> CpStep < Self > { self . peer_epochs . entry ( sender_id . clone ( ) ) . and_modify ( | e | { if * e < epoch { * e = epoch ; } } ) . or_insert ( epoch ) ; if ! self . remove_participant_if_old ( sender_id ) { self . process_new_epoch ( sender_id , epoch ) } else { Step :: < D > :: default ( ) } }
Handles an epoch start announcement.
Handles an epoch start announcement .
&mut self
sender_id
&D::NodeId
epoch
D::Epoch
&mut self
sender_id
&D::NodeId
epoch
D::Epoch