process.hpp

Go to the documentation of this file.

 
#ifndef BOOSTER_SEAT_PROCESS_HPP_
#define BOOSTER_SEAT_PROCESS_HPP_
 
#include <iostream>
#include <sstream>
#include <string>
#include <vector>
 
#include <ext/stdio_filebuf.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <unistd.h>
 
#include <BoosterSeat/exception.hpp>
#include <BoosterSeat/sleep.hpp>
 
namespace bst {
 
class Process {
public:
  Process(const std::string &cmd, std::vector<std::string> argv);
  ~Process();
 
  void writeToInStream(const std::string &s);
  void closeInStream();
  const std::string &getStdout();
  const std::string &getStderr();
  int getExitCode();
 
  void waitToComplete(unsigned int timeout = 1000);
 
private:
  void assertComplete();
  void run(const std::string &cmd, std::vector<std::string> argv);
  void child(const std::vector<std::string> &argv);
 
  pid_t pid_;
 
  int in_pipe_[2];
  int out_pipe_[2];
  int err_pipe_[2];
 
  __gnu_cxx::stdio_filebuf<char> *p_in_filebuf_;
  __gnu_cxx::stdio_filebuf<char> *p_out_filebuf_;
  __gnu_cxx::stdio_filebuf<char> *p_err_filebuf_;
 
  std::ostream *in_stream_;
  std::istream *out_stream_;
  std::istream *err_stream_;
 
  bool have_exit_code_ = false;
 
  int exit_code_ = 0;
  std::string stdout_string_;
  std::string stderr_string_;
};
 
} // namespace bst
 
#endif /* BOOSTER_SEAT_PROCESS_HPP_ */