-
Notifications
You must be signed in to change notification settings - Fork 1
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Redirect stdio #1
base: master
Are you sure you want to change the base?
Conversation
Codecov Report
@@ Coverage Diff @@
## master #1 +/- ##
==========================================
+ Coverage 76.04% 77.87% +1.82%
==========================================
Files 2 2
Lines 167 235 +68
==========================================
+ Hits 127 183 +56
- Misses 40 52 +12
Continue to review full report at Codecov.
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
After fubarnetes/fubarnetes#1 is solved, we should really use some other form of IPC rather than native mpsc
.
src/process.rs
Outdated
|
||
// Handle stdio | ||
if let Some(ref mut stdout) = p.stdout_reader { | ||
for line in stdout.lines() { | ||
info!("{:?}", line) | ||
p.stdout_sender |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
After fubarnetes/fubarnetes#1 is solved, this should ideally be some PUB
/SUB
or similar message queue.
src/process.rs
Outdated
} | ||
} | ||
|
||
if let Some(ref mut stdin) = p.stdin_writer { | ||
if let Ok(input) = p.stdin_receiver.try_recv() { | ||
info!("received: {}", input); | ||
stdin.write_all(input.as_bytes()) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
And this probably a PULL
or equivalent.
No description provided.