2019-01-12 15:57:19 +00:00
|
|
|
use std::{
|
|
|
|
thread,
|
|
|
|
time::{Duration, SystemTime},
|
|
|
|
};
|
|
|
|
|
|
|
|
const CLOCK_SMOOTHING: f64 = 0.9;
|
|
|
|
|
|
|
|
pub struct Clock {
|
|
|
|
last_sys_time: SystemTime,
|
|
|
|
last_delta: Option<Duration>,
|
|
|
|
running_tps_average: f64,
|
|
|
|
}
|
|
|
|
|
|
|
|
impl Clock {
|
2019-04-22 16:50:15 +00:00
|
|
|
#[allow(dead_code)]
|
2019-01-12 15:57:19 +00:00
|
|
|
pub fn new() -> Self {
|
|
|
|
Self {
|
|
|
|
last_sys_time: SystemTime::now(),
|
|
|
|
last_delta: None,
|
|
|
|
running_tps_average: 0.0,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2019-04-22 16:50:15 +00:00
|
|
|
#[allow(dead_code)]
|
2019-04-29 20:37:19 +00:00
|
|
|
pub fn get_tps(&self) -> f64 {
|
|
|
|
1.0 / self.running_tps_average
|
|
|
|
}
|
2019-01-12 15:57:19 +00:00
|
|
|
|
2019-04-22 16:50:15 +00:00
|
|
|
#[allow(dead_code)]
|
2019-04-29 20:37:19 +00:00
|
|
|
pub fn get_last_delta(&self) -> Duration {
|
|
|
|
self.last_delta.unwrap_or(Duration::new(0, 0))
|
|
|
|
}
|
2019-01-12 15:57:19 +00:00
|
|
|
|
2019-04-22 16:50:15 +00:00
|
|
|
#[allow(dead_code)]
|
2019-04-29 20:37:19 +00:00
|
|
|
pub fn get_avg_delta(&self) -> Duration {
|
|
|
|
Duration::from_secs_f64(self.running_tps_average)
|
|
|
|
}
|
2019-01-12 15:57:19 +00:00
|
|
|
|
2019-04-22 16:50:15 +00:00
|
|
|
#[allow(dead_code)]
|
2019-01-12 15:57:19 +00:00
|
|
|
pub fn tick(&mut self, tgt: Duration) {
|
|
|
|
let delta = SystemTime::now()
|
|
|
|
.duration_since(self.last_sys_time)
|
|
|
|
.expect("Time went backwards!");
|
|
|
|
|
2019-05-17 09:22:32 +00:00
|
|
|
// Attempt to sleep to fill the gap.
|
2019-01-12 15:57:19 +00:00
|
|
|
if let Some(sleep_dur) = tgt.checked_sub(delta) {
|
2019-04-22 16:50:15 +00:00
|
|
|
let adjustment = if self.running_tps_average == 0.0 {
|
|
|
|
1.0
|
|
|
|
} else {
|
|
|
|
tgt.as_secs_f64() / self.running_tps_average
|
|
|
|
};
|
2019-04-29 20:37:19 +00:00
|
|
|
thread::sleep(Duration::from_secs_f64(
|
|
|
|
sleep_dur.as_secs_f64() * adjustment,
|
|
|
|
));
|
2019-01-12 15:57:19 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
let delta = SystemTime::now()
|
|
|
|
.duration_since(self.last_sys_time)
|
|
|
|
.expect("Time went backwards!");
|
|
|
|
|
|
|
|
self.last_sys_time = SystemTime::now();
|
|
|
|
self.last_delta = Some(delta);
|
2019-04-22 16:50:15 +00:00
|
|
|
self.running_tps_average = if self.running_tps_average == 0.0 {
|
|
|
|
delta.as_secs_f64()
|
|
|
|
} else {
|
2019-04-29 20:37:19 +00:00
|
|
|
CLOCK_SMOOTHING * self.running_tps_average
|
|
|
|
+ (1.0 - CLOCK_SMOOTHING) * delta.as_secs_f64()
|
2019-04-22 16:50:15 +00:00
|
|
|
};
|
2019-01-12 15:57:19 +00:00
|
|
|
}
|
|
|
|
}
|