dunedaq::oks::CommandOutput Struct Reference

Public Member Functions
	CommandOutput (const char *command_name, const OksKernel *k, std::string &cmd)
	~CommandOutput ()
const std::string &	file_name () const
std::string	cat2str () const
std::string	last_str () const
void	check_command_status (int status)

Public Attributes
std::string	p_file_name
std::string &	p_command
const char *	p_command_name

Detailed Description

Definition at line 4536 of file kernel.cpp.

Constructor & Destructor Documentation

CommandOutput()

dunedaq::oks::CommandOutput::CommandOutput	(	const char *	command_name,
		const OksKernel *	k,
		std::string &	cmd )

Definition at line 4553 of file kernel.cpp.

  : p_command(cmd)
  , p_command_name(command_name)
{
  p_file_name = get_temporary_dir() + '/' + command_name + '.' + std::to_string(getpid()) + ':' +
                std::to_string(reinterpret_cast<std::uintptr_t>(k)) + ".txt";
 
  p_command.append(" &>");
  p_command.append(p_file_name);
}

~CommandOutput()

dunedaq::oks::CommandOutput::~CommandOutput

(

)

Definition at line 4564 of file kernel.cpp.

{
  unlink(p_file_name.c_str());
}

Member Function Documentation

cat2str()

std::string dunedaq::oks::CommandOutput::cat2str

(

)

const

Definition at line 4570 of file kernel.cpp.

{
  std::ifstream f(p_file_name.c_str());
  std::string out;
 
  if (f) {
    std::filebuf* buf = f.rdbuf();
    while (true) {
      char c = buf->sbumpc();
      if (c == EOF)
        break;
      else
        out += c;
    }
  }
 
  return out;
}

check_command_status()

void dunedaq::oks::CommandOutput::check_command_status

(

int

status

)

Definition at line 4614 of file kernel.cpp.

{
  if (status == -1) {
    std::ostringstream text;
    text << "cannot execute command \'" << p_command << "\': " << strerror(errno);
    throw RepositoryOperationFailed(p_command_name, text.str());
  } else if (int error_code = WEXITSTATUS(status)) {
    std::ostringstream text;
    text << p_command.substr(0, p_command.find_first_of(' ')) << " exit with error code " << error_code << ", output:\n"
         << cat2str();
    throw RepositoryOperationFailed(p_command_name, text.str());
  }
}

file_name()

const std::string & dunedaq::oks::CommandOutput::file_name ( ) const

inline

Definition at line 4542 of file kernel.cpp.

{ return p_file_name; }

last_str()

std::string dunedaq::oks::CommandOutput::last_str

(

)

const

Definition at line 4590 of file kernel.cpp.

{
  std::ifstream f(p_file_name.c_str());
  std::string lastline;
 
  if (f.is_open()) {
    f.seekg(-1, std::ios_base::end);
    if (f.peek() == '\n') {
      f.seekg(-1, std::ios_base::cur);
      for (int i = f.tellg(); i >= 0; i--) {
        if (f.peek() == '\n') {
          f.get();
          break;
        }
        f.seekg(i, std::ios_base::beg);
      }
    }
 
    getline(f, lastline);
  }
  return lastline;
}

Member Data Documentation

p_command

std::string& dunedaq::oks::CommandOutput::p_command

Definition at line 4549 of file kernel.cpp.

p_command_name

const char* dunedaq::oks::CommandOutput::p_command_name

Definition at line 4550 of file kernel.cpp.

p_file_name

std::string dunedaq::oks::CommandOutput::p_file_name

Definition at line 4548 of file kernel.cpp.

---

The documentation for this struct was generated from the following file:

• /github/workspace/dunedaq/sourcecode/oks/src/kernel.cpp