Peerplays_Blockchain/peerplays-fc
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add an optional timeout parameter when waiting for a local process to exit

Browse source
This commit is contained in:
Eric Frias 2014-05-14 08:51:30 -04:00
parent eb501387e8
commit db7b1bdd69
3 changed files with 10 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
include/fc/interprocess/iprocess.hpp
View file

@ -31,13 +31,13 @@ namespace fc
*
* @return *this
*/
virtual iprocess& exec( const fc::path& exe, std::vector<std::string> args,
const fc::path& work_dir = fc::path(), exec_opts opts = open_all ) = 0;
virtual iprocess& exec( const path& exe, std::vector<std::string> args,
const path& work_dir = path(), exec_opts opts = open_all ) = 0;
/**
* @return blocks until the process exits
*/
virtual int result() = 0;
virtual int result(const microseconds& timeout = microseconds::maximum()) = 0;
/**
@ -48,16 +48,16 @@ namespace fc
/**
* @brief returns a stream that writes to the process' stdin
*/
virtual fc::buffered_ostream_ptr in_stream() = 0;
virtual buffered_ostream_ptr in_stream() = 0;
/**
* @brief returns a stream that reads from the process' stdout
*/
virtual fc::buffered_istream_ptr out_stream() = 0;
virtual buffered_istream_ptr out_stream() = 0;
/**
* @brief returns a stream that reads from the process' stderr
*/
virtual fc::buffered_istream_ptr err_stream() = 0;
virtual buffered_istream_ptr err_stream() = 0;
};

3
include/fc/interprocess/process.hpp
View file

@ -20,7 +20,8 @@ namespace fc {
const fc::path& work_dir = fc::path(),
exec_opts opts = open_all );
virtual int result();
virtual int result(const microseconds& timeout = microseconds::maximum());
virtual void kill();
virtual fc::buffered_ostream_ptr in_stream();
virtual fc::buffered_istream_ptr out_stream();

4
src/interprocess/process.cpp
View file

@ -179,9 +179,9 @@ fc::buffered_istream_ptr process::err_stream() {
return my->_err;
}
int process::result()
int process::result(const microseconds& timeout /* = microseconds::maximum() */)
{
return my->_exited.wait();
return my->_exited.wait(timeout);
}
}