rings-core 0.20.0

Chord DHT implementation with ICE
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

//! Audited task-spawn boundary for deterministic simulation observers.

use std::sync::Arc;

use tokio::sync::Notify;
use tokio::task::JoinHandle;

use super::SimulationRuntimeError;

pub(crate) fn spawn_storage_progress_observer(
    notify: Arc<Notify>,
) -> Result<JoinHandle<()>, SimulationRuntimeError> {
    let runtime = tokio::runtime::Handle::try_current()
        .map_err(|_| SimulationRuntimeError::MissingTokioRuntime)?;
    Ok(runtime.spawn(async move {
        notify.notified().await;
        super::record_storage_progress();
    }))
}