fn advance_cap(&mut self, t: &Duration) {
        self.next_cap.second = *t;
        self.tick_sys = false;

        trace!("w{} progresses from {:?} to {:?}", self.worker_index, self.curr_cap, self.next_cap);

        for writer in self.writers.iter_mut() {
            writer.push(Event::Progress(vec![
                (self.next_cap.clone(), 1),
                (self.curr_cap.clone(), -1),
            ]));
        }

        self.curr_cap = self.next_cap.clone();
    }
/// Sends progress information for SnailTrail. The capability is
/// downgraded to `next_cap`, allowing the frontier to advance.
Sends progress information for SnailTrail. The capability is
downgraded to `next_cap`, allowing the frontier to advance.
Sends progress information for SnailTrail . The capability is downgraded to ` next_cap ` allowing the frontier to advance .
fn advance_cap(&mut self, t: &Duration) {
        self.next_cap.second = *t;
        self.tick_sys = false;
        trace!("w{} progresses from {:?} to {:?}", self.worker_index, self.curr_cap, self.next_cap);
        for writer in self.writers.iter_mut() {
            writer.push(Event::Progress(vec![
                (self.next_cap.clone(), 1),
                (self.curr_cap.clone(), -1),
            ]));
        }
        self.curr_cap = self.next_cap.clone();
    }
fn advance_cap ( & mut self , t : & Duration ) { self . next_cap . second = * t ; self . tick_sys = false ; trace ! ( " " self worker_index self curr_cap self next_cap ) ; for writer in self . writers . iter_mut ( ) { writer . push ( Event :: Progress ( vec ! [ ( self next_cap clone ( ) 1 ) ( self curr_cap clone ( ) 1 ) ] ) ) ; } self . curr_cap = self . next_cap . clone ( ) ; }
Sends progress information for SnailTrail.
Sends progress information for SnailTrail .
&mut self
t
&Duration
&mut self
t
&Duration