fn wait_for_commit(&self, target: i64) -> u128 {
        let mut max_iterations = MAX_WAIT_COMMIT_ITERATIONS;
        let now = time::Instant::now();
        while max_iterations > 0 {
            max_iterations -= 1;
            if self.get_committed_txns_counter() == target {
                return now.elapsed().as_millis();
            }
            thread::sleep(time::Duration::from_micros(500));
        }
        let wait_duration_ms = now.elapsed().as_millis();
        warn!("wait_for_commit() timeout after {} ms", wait_duration_ms);
        wait_duration_ms
    }
/// Wait for #committed TXNs reaching target with fixed number of query iterations.
Wait for #committed TXNs reaching target with fixed number of query iterations.
Wait for #committed TXNs reaching target with fixed number of query iterations .
fn wait_for_commit(&self, target: i64) -> u128 {
        let mut max_iterations = MAX_WAIT_COMMIT_ITERATIONS;
        let now = time::Instant::now();
        while max_iterations > 0 {
            max_iterations -= 1;
            if self.get_committed_txns_counter() == target {
                return now.elapsed().as_millis();
            }
            thread::sleep(time::Duration::from_micros(500));
        }
        let wait_duration_ms = now.elapsed().as_millis();
        warn!("wait_for_commit() timeout after {} ms", wait_duration_ms);
        wait_duration_ms
    }
fn wait_for_commit ( & self , target : i64 ) -> u128 { let mut max_iterations = MAX_WAIT_COMMIT_ITERATIONS ; let now = time :: Instant :: now ( ) ; while max_iterations > 0 { max_iterations -= 1 ; if self . get_committed_txns_counter ( ) == target { return now . elapsed ( ) . as_millis ( ) ; } thread :: sleep ( time :: Duration :: from_micros ( 500 ) ) ; } let wait_duration_ms = now . elapsed ( ) . as_millis ( ) ; warn ! ( " " wait_duration_ms ) ; wait_duration_ms }
Wait for #committed TXNs reaching target with fixed number of query iterations.
Wait for #committed TXNs reaching target with fixed number of query iterations .
&self
target
i64