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

Handle timeout

Browse Source
This commit is contained in:
Marcin Mielniczuk
2020-01-16 15:09:36 +01:00
parent 33818ea18e
commit 410777de52
1 changed files with 2 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
crates/wasi-common/src/sys/windows/hostcalls_impl/misc.rs
View File

@@ -269,19 +269,12 @@ pub(crate) fn poll_oneoff(
let mut stdin_events = vec![]; let mut stdin_events = vec![];
let mut immediate_events = vec![]; let mut immediate_events = vec![];
let mut pipe_events = vec![]; let mut pipe_events = vec![];
let mut stdin_ready = None;
for event in fd_events { for event in fd_events {
match event.descriptor { match event.descriptor {
Descriptor::Stdin if event.r#type == wasi::__WASI_EVENTTYPE_FD_READ => { Descriptor::Stdin if event.r#type == wasi::__WASI_EVENTTYPE_FD_READ => {
// Cache the non-emptiness for better performance.
let immediate = stdin_ready.get_or_insert_with(stdin_nonempty);
if *immediate {
immediate_events.push(event)
} else {
stdin_events.push(event) stdin_events.push(event)
} }
}
Descriptor::Stdin | Descriptor::Stderr | Descriptor::Stdout => { Descriptor::Stdin | Descriptor::Stderr | Descriptor::Stdout => {
immediate_events.push(event) immediate_events.push(event)
} }
@@ -322,7 +315,7 @@ pub(crate) fn poll_oneoff(
match state { match state {
PollState::Ready => handle_rw_event(event, events), PollState::Ready => handle_rw_event(event, events),
PollState::Closed => { /* error? FIXME */ } PollState::Closed => { /* error? FIXME */ }
PollState::TimedOut => { /* FIXME */ } PollState::TimedOut => handle_timeout_event(timeout.unwrap().0, events),
PollState::Error(ref e) => { PollState::Error(ref e) => {
error!("PollState error"); error!("PollState error");
handle_error_event(event, Error::ENOTSUP /*FIXME*/, events); handle_error_event(event, Error::ENOTSUP /*FIXME*/, events);