7a1b7cdf92
Implement Wasmtime's new API as designed by RFC 11. This is quite a large commit which has had lots of discussion externally, so for more information it's best to read the RFC thread and the PR thread.
41 lines
834 B
Rust
41 lines
834 B
Rust
#[cfg(unix)]
|
|
pub mod unix;
|
|
#[cfg(unix)]
|
|
pub use unix::poll_oneoff;
|
|
|
|
#[cfg(windows)]
|
|
pub mod windows;
|
|
#[cfg(windows)]
|
|
pub use windows::poll_oneoff;
|
|
|
|
use std::thread;
|
|
use std::time::Duration;
|
|
use wasi_common::{
|
|
sched::{Poll, WasiSched},
|
|
Error,
|
|
};
|
|
|
|
pub struct SyncSched {}
|
|
impl SyncSched {
|
|
pub fn new() -> Self {
|
|
Self {}
|
|
}
|
|
}
|
|
#[async_trait::async_trait]
|
|
impl WasiSched for SyncSched {
|
|
async fn poll_oneoff<'a>(&self, poll: &mut Poll<'a>) -> Result<(), Error> {
|
|
poll_oneoff(poll).await
|
|
}
|
|
async fn sched_yield(&self) -> Result<(), Error> {
|
|
thread::yield_now();
|
|
Ok(())
|
|
}
|
|
async fn sleep(&self, duration: Duration) -> Result<(), Error> {
|
|
std::thread::sleep(duration);
|
|
Ok(())
|
|
}
|
|
}
|
|
pub fn sched_ctx() -> Box<dyn WasiSched> {
|
|
Box::new(SyncSched::new())
|
|
}
|