T0b1/wasmtime
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #2756 from bytecodealliance/pch/wasi_sleep_fallible

Browse Source 
wasi: make WasiSched::sleep fallible
This commit is contained in:
Pat Hickey
2021-03-23 14:40:21 -07:00
committed by GitHub
parent c95971ab59 81dfb9c458
commit 6b2da3d299
5 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
crates/wasi-common/cap-std-sync/src/sched/unix.rs
View File

@@ -108,8 +108,9 @@ impl WasiSched for SyncSched {
std::thread::yield_now();
Ok(())
}
fn sleep(&self, duration: Duration) {
std::thread::sleep(duration)
fn sleep(&self, duration: Duration) -> Result<(), Error> {
std::thread::sleep(duration);
Ok(())
}
}

5
crates/wasi-common/cap-std-sync/src/sched/windows.rs
View File

@@ -128,8 +128,9 @@ impl WasiSched for SyncSched {
thread::yield_now();
Ok(())
}
fn sleep(&self, duration: Duration) {
std::thread::sleep(duration)
fn sleep(&self, duration: Duration) -> Result<(), Error> {
std::thread::sleep(duration);
Ok(())
}
}

2
crates/wasi-common/src/sched.rs
View File

@@ -10,7 +10,7 @@ use subscription::{MonotonicClockSubscription, RwSubscription, Subscription, Sub
pub trait WasiSched {
fn poll_oneoff(&self, poll: &Poll) -> Result<(), Error>;
fn sched_yield(&self) -> Result<(), Error>;
fn sleep(&self, duration: Duration);
fn sleep(&self, duration: Duration) -> Result<(), Error>;
}
pub struct Userdata(u64);

3
crates/wasi-common/src/snapshots/preview_0.rs
View File

@@ -749,8 +749,7 @@ impl<'a> wasi_unstable::WasiUnstable for WasiCtx {
.flags
.contains(types::Subclockflags::SUBSCRIPTION_CLOCK_ABSTIME)
{
self.sched.sleep(Duration::from_nanos(clocksub.timeout));
self.sched.sleep(Duration::from_nanos(clocksub.timeout))?;
events.write(types::Event {
userdata: sub.userdata,
error: types::Errno::Success,

3
crates/wasi-common/src/snapshots/preview_1.rs
View File

@@ -920,8 +920,7 @@ impl<'a> wasi_snapshot_preview1::WasiSnapshotPreview1 for WasiCtx {
.flags
.contains(types::Subclockflags::SUBSCRIPTION_CLOCK_ABSTIME)
{
self.sched.sleep(Duration::from_nanos(clocksub.timeout));
self.sched.sleep(Duration::from_nanos(clocksub.timeout))?;
events.write(types::Event {
userdata: sub.userdata,
error: types::Errno::Success,