geph4-client 4.8.2

Geph client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

use event_listener::Event;
use once_cell::sync::Lazy;
use parking_lot::Mutex;
use smol::prelude::*;
use std::time::{Duration, SystemTime};

static LAST_ACTIVITY: Lazy<Mutex<SystemTime>> = Lazy::new(|| Mutex::new(SystemTime::now()));
static ACTIVITY_EVENT: Event = Event::new();

/// Wait till there's activity
pub async fn wait_activity(timeout: Duration) {
    ACTIVITY_EVENT
        .listen()
        .or(async {
            let adjusted_timeout = timeout.min(
                Duration::from_secs_f64(
                    1.5f64
                        .powf(
                            LAST_ACTIVITY
                                .lock()
                                .elapsed()
                                .unwrap_or_else(|_| Duration::from_secs(1000))
                                .as_secs_f64(),
                        )
                        .min(10000.0),
                )
                .max(Duration::from_secs(5)),
            );
            smol::Timer::after(adjusted_timeout).await;
        })
        .await
}

/// Notifies of activity.
pub fn notify_activity() {
    *LAST_ACTIVITY.lock() = SystemTime::now();
    ACTIVITY_EVENT.notify(usize::MAX);
}