pub fn tick_epoch(&mut self) {
        trace!("w{}@{:?} tick epoch", self.worker_index, self.curr_cap);

        if self.epoch_count % 1 == 0 {
            if self.curr_cap.first > 0 {
                // println!("{}|{}|{}|{}|{}", self.worker_index, self.curr_cap.first - 1, self.elapsed.elapsed().as_nanos(), self.overall_messages, self.pag_messages);
            }
            self.elapsed = std::time::Instant::now();
            self.overall_messages = 0;
            self.pag_messages = 0;

            self.next_cap.first += 1;
        }

        if self.curr_cap == Default::default() {
            // The dataflow structure is propagated to all writers.
            self.flush_to_all();
        } else {
            if self.epoch_count % 1 == 0 {
                self.flush_buffer();
                self.curr_writer = (self.curr_writer + 1) % self.writers.len();
            }
        }

        self.epoch_count += 1;
    }
/// Advances the PAGLogger's epoch.
Advances the PAGLogger's epoch.
Advances the PAGLogger ' s epoch .
pub fn tick_epoch(&mut self) {
        trace!("w{}@{:?} tick epoch", self.worker_index, self.curr_cap);
        if self.epoch_count % 1 == 0 {
            if self.curr_cap.first > 0 {
                // println!("{}|{}|{}|{}|{}", self.worker_index, self.curr_cap.first - 1, self.elapsed.elapsed().as_nanos(), self.overall_messages, self.pag_messages);
            }
            self.elapsed = std::time::Instant::now();
            self.overall_messages = 0;
            self.pag_messages = 0;
            self.next_cap.first += 1;
        }
        if self.curr_cap == Default::default() {
            // The dataflow structure is propagated to all writers.
            self.flush_to_all();
        } else {
            if self.epoch_count % 1 == 0 {
                self.flush_buffer();
                self.curr_writer = (self.curr_writer + 1) % self.writers.len();
            }
        }
        self.epoch_count += 1;
    }
pub fn tick_epoch ( & mut self ) { trace ! ( " " self worker_index self curr_cap ) ; if self . epoch_count % 1 == 0 { if self . curr_cap . first > 0 { // println!("{}|{}|{}|{}|{}", self.worker_index, self.curr_cap.first - 1, self.elapsed.elapsed().as_nanos(), self.overall_messages, self.pag_messages); } self . elapsed = std :: time :: Instant :: now ( ) ; self . overall_messages = 0 ; self . pag_messages = 0 ; self . next_cap . first += 1 ; } if self . curr_cap == Default :: default ( ) { // The dataflow structure is propagated to all writers. self . flush_to_all ( ) ; } else { if self . epoch_count % 1 == 0 { self . flush_buffer ( ) ; self . curr_writer = ( self . curr_writer + 1 ) % self . writers . len ( ) ; } } self . epoch_count += 1 ; }
Advances the PAGLogger's epoch.
Advances the PAGLogger ' s epoch .
&mut self
&mut self