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

Extra comments

Browse Source
This commit is contained in:
Marcin Mielniczuk
2020-01-16 19:50:16 +01:00
parent b5f293a71f
commit e4905c3100
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -72,7 +72,10 @@ impl StdinPoll {
fn event_loop(request_rx: Receiver<()>, notify_tx: Sender<PollState>) -> ! { fn event_loop(request_rx: Receiver<()>, notify_tx: Sender<PollState>) -> ! {
use std::io::BufRead; use std::io::BufRead;
loop { loop {
// Wait for the request to poll stdin
request_rx.recv().expect("request_rx channel closed"); request_rx.recv().expect("request_rx channel closed");
// Wait for data to appear in stdin.
// If `fill_buf` returns any slice, then it means that either // If `fill_buf` returns any slice, then it means that either
// (a) there some data in stdout, if it's non-empty // (a) there some data in stdout, if it's non-empty
// (b) EOF was received, if it's empty // (b) EOF was received, if it's empty
@@ -81,6 +84,9 @@ impl StdinPoll {
Ok(_) => PollState::Ready, Ok(_) => PollState::Ready,
Err(e) => PollState::Error(e.into()), Err(e) => PollState::Error(e.into()),
}; };
// Notify the requestor about data in stdin. They may have already timed out,
// then the next requestor will have to clean the channel.
notify_tx.send(resp).expect("notify_tx channel closed"); notify_tx.send(resp).expect("notify_tx channel closed");
} }
} }