Struct madsim::Handle

pub struct Handle {
    pub net: NetHandle,
    pub fs: FsHandle,
    // some fields omitted
}

Supervisor handle to the runtime.

Fields

net: NetHandle

fs: FsHandle

Implementations

impl Handle

pub fn current() -> Self

Returns a Handle view over the currently running Runtime.

Panic

This will panic if called outside the context of a Madsim runtime.

let handle = madsim::Handle::current();

pub fn kill(&self, addr: SocketAddr)

Kill a host.

• All tasks spawned on this host will be killed immediately.
• All data that has not been flushed to the disk will be lost.

Example

use madsim::{Runtime, time::{sleep, Duration}};
use std::sync::{Arc, atomic::{AtomicUsize, Ordering}};

let rt = Runtime::new();
let addr = "0.0.0.1:1".parse().unwrap();

// host increases the counter every 2s
let flag = Arc::new(AtomicUsize::new(0));
let flag_ = flag.clone();
rt.local_handle(addr).spawn(async move {
    loop {
        sleep(Duration::from_secs(2)).await;
        flag_.fetch_add(2, Ordering::SeqCst);
    }
}).detach();
  
let handle = rt.handle();
rt.block_on(async move {
    sleep(Duration::from_secs(3)).await;
    assert_eq!(flag.load(Ordering::SeqCst), 2);

    handle.kill(addr);

    sleep(Duration::from_secs(2)).await;
    assert_eq!(flag.load(Ordering::SeqCst), 2);
});

pub fn local_handle(&self, addr: SocketAddr) -> LocalHandle

Return a handle of the specified host.

Trait Implementations

impl Clone for Handle

fn clone(&self) -> Handle

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.