aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-02-02 06:44:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

clippy

Browse Source
This commit is contained in:
pedrocarlo
2025-07-10 12:48:09 -03:00
parent 4a13286d62
commit 46a7d20c12
3 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
core/io/clock.rs
View File

@@ -13,8 +13,6 @@ impl<T: chrono::TimeZone> From<chrono::DateTime<T>> for Instant {
}
}
pub trait Clock {
fn now(&self) -> Instant;
}

4
simulator/runner/clock.rs
View File

@@ -12,7 +12,7 @@ pub struct SimulatorClock {
impl SimulatorClock {
const MIN_TICK: u64 = 1;
const MAX_TICK: u64 = 50;
const MAX_TICK: u64 = 30;
pub fn new(rng: ChaCha8Rng) -> Self {
Self {
@@ -28,7 +28,7 @@ impl SimulatorClock {
.borrow_mut()
.gen_range(Self::MIN_TICK..Self::MAX_TICK);
let nanos = std::time::Duration::from_micros(nanos);
*time = *time + nanos;
*time += nanos;
*time
}
}

3
simulator/runner/file.rs
View File

@@ -4,7 +4,6 @@ use std::{
sync::Arc,
};
use chrono::{DateTime, Utc};
use rand::Rng as _;
use rand_chacha::ChaCha8Rng;
use tracing::{instrument, Level};
@@ -102,7 +101,7 @@ impl SimulatorFile {
// Chance to introduce some latency
rng.gen_bool(self.latency_probability as f64 / 100.0)
.then(|| {
let now: DateTime<Utc> = self.clock.now().into();
let now = self.clock.now();
let sum = now + std::time::Duration::from_millis(rng.gen_range(5..20));
sum.into()
})