Process provides an encapsulation of a spawned process, allowing the parent process to perform I/O with the spawned process, send it signals and wait for it to finish. More...

#include <Process.h>

Public Member Functions
	Process (pid_t pid)
	Construct a Process. More...

	Process ()
	Default constructor. More...

	Process (const Process &x)
	Copy constructor. More...

Process &	operator= (const Process &x)
	Assignment operator. More...

	~Process ()
	Destructor, which does very little. More...

void	kill (int signal) throw (IOException)
	Send a signal to the process. More...

int	wait (bool hang, int *status) throw (IOException)
	Do a system wait on a process. More...

int	getInFd () const
	Get the file descriptor of the pipe that is connected to the standard in of the Process. More...

std::ostream &	inStream ()
	Get the ostream of the pipe that is connected to the standard in of the Process. More...

void	closeIn ()
	Close the file descriptor and ostream of the pipe connected to the standard in of the Process. More...

int	getOutFd () const
	Get the file descriptor of the pipe that is connected to the standard out of the Process. More...

std::istream &	outStream ()
	Get the istream of the pipe that is connected to the standard out of the Process. More...

void	closeOut ()
	Close the file descriptor and istream of the pipe connected to the standard out of the Process. More...

int	getErrFd () const
	Get the file descriptor of the pipe that is connected to the standard error of the Process. More...

std::istream &	errStream ()
	Get the istream of the pipe that is connected to the standard error of the Process. More...

void	closeErr ()
	Close the file descriptor and istream of the pipe connected to the standard error of the Process. More...

pid_t	getPid () const
	The process id of the Process. More...

Static Public Member Functions
static Process	spawn (const std::string &cmd, const std::vector< std::string > &args, const std::map< std::string, std::string > &env, int niceval=0) throw (IOException)
	Fork and execute a command and associated arguments and environment. More...

static Process	spawn (const std::string &cmd, const std::vector< std::string > &args, int niceval=0) throw (IOException)
	Fork and execute a command and associated arguments. More...

static Process	spawn (const std::string &cmd) throw (IOException)
	Execute a command by forking and executing command from the shell command line using "sh -c cmd". More...

static pid_t	checkPidFile (const std::string &pidFile) throw (IOException)
	Check if another process is running, using the named process id file. More...

static void	removePidFile ()
	Remove the pid file. More...

static void	addEffectiveCapability (int cap) throw (Exception)
	Add an effective capability to this process. More...

static void	clearEffectiveCapability (int cap) throw (Exception)

static bool	getEffectiveCapability (int cap) throw (Exception)
	Check if this process has an effective capability. More...

static std::string	expandEnvVars (std::string input)

static bool	getEnvVar (const std::string &name, std::string &value)
	Get an environment variable given a variable name like "HOST", without the '$', or any brackets, '{' or '}'. More...

static void	setEnvVar (const std::string &name, const std::string &value)

static void	clearEnv ()
	Remove any environment settings made by setEnvVar and release any memory allocated to put those settings in the environment. More...

static unsigned long	getVMemSize ()
	Return the virtual memory size in bytes of the current process, as read from the /proc/pid/stat file. More...

static unsigned long	getMaxRSS ()
	Return the maximum resident set size of the current process, in bytes. More...

Private Member Functions
void	setInFd (int val)

void	setOutFd (int val)

void	setErrFd (int val)

Private Attributes
pid_t	_pid

int	_infd
	File descriptor that is connected via a pipe to the standard in file descriptor of a spawned process. More...

auto_ptr < __gnu_cxx::stdio_filebuf < char > >	_inbuf_ap
	GNU extension filebuf which is needed to create a ostream from a file descriptor. More...

auto_ptr< std::ostream >	_instream_ap

int	_outfd
	File descriptor that is connected via a pipe to the standard out file descriptor of a spawned process. More...

auto_ptr < __gnu_cxx::stdio_filebuf < char > >	_outbuf_ap

auto_ptr< std::istream >	_outstream_ap

int	_errfd
	File descriptor that is connected via a pipe to the standard error file descriptor of a spawned process. More...

auto_ptr < __gnu_cxx::stdio_filebuf < char > >	_errbuf_ap

auto_ptr< std::istream >	_errstream_ap

Static Private Attributes
static std::string	_pidFile

static std::map< std::string, char * >	_environment

static Mutex	_envLock

Detailed Description

Process provides an encapsulation of a spawned process, allowing the parent process to perform I/O with the spawned process, send it signals and wait for it to finish.

Static methods are provided for spawning (forking and executing) a process. A static method also exists to atomically check and create a process id file.

Constructor & Destructor Documentation

Process::Process ( pid_t pid )

Construct a Process.

@ param pid: pid should be > 0 and be a valid process id. Unix system calls support doing kills and waits on a pid less than or equal to 0, but those capabilities are not supported in this class. I/O via the getXXFd() or xxStream() methods is not possible with a process created with this constructor. kill() and wait() are supported. In order to use the Process methods to perform I/O with a process, it must be started with one of the spawn methods.

References _pid, and kill().

Process::Process ( )

Default constructor.

Does not point to any process.

Process::Process ( const Process & x )

Copy constructor.

The new process will inherit the file descriptors and iostreams from x. The file descriptors and iostreams of the copied Process, x, are no longer valid after this copy.

References _errfd, _infd, and _outfd.

Process::~Process ( )

Destructor, which does very little.

It does not do a kill or wait on the process, or close any file descriptors that are connected to the process.

Member Function Documentation

void Process::addEffectiveCapability	(	int	cap	)
throw	(	Exception
	)

static

Add an effective capability to this process.

See man 7 capabilities. If a process has been started with an effective uid of 0(root), one should call prctl(PR_SET_KEEPCAPS,1,0,0,0) prior to doing setuid to a uid > 0. Then use this method to add a capability.

Referenced by nidas::core::NidasApp::lockMemory(), main(), and nidas::core::NidasApp::setupProcess().

pid_t Process::checkPidFile	(	const std::string &	pidFile	)
throw	(	IOException
	)

static

Check if another process is running, using the named process id file.

A process id file typically has a name like /var/run/xxxx.pid, or /tmp/xxxx.pid. This function is useful when there should only be one instance of a process running on a system - for example a daemon which listens on a socket port. The process name, "xxxx" should not be used by any other process on the system.

Returns: 0: means that no other process which uses file pidFile appears to be running. The pidFile was then created, containing the process id of the current process. >0: pid of a process that either holds a lock on pidFile, or pidFile contains a pid of a process that is still running.

If the return is 0, it means that the pidFile either didn't exist, was empty, didn't contain a number, or a current process with the given number doesn't exist. In this case, the file is created if necessary, and will contain the process id of the current process. checkPidFile also calls atexit() to schedule the removePidFile() function to be run when the current process exits. One typically does not have to call removePidFile explicitly.

References fd.

Referenced by nidas::core::NidasApp::checkPidFile().

void Process::clearEffectiveCapability	(	int	cap	)
throw	(	Exception
	)

static

void Process::clearEnv ( )

static

Remove any environment settings made by setEnvVar and release any memory allocated to put those settings in the environment.

References _environment, and _envLock.

void Process::closeErr ( )

Close the file descriptor and istream of the pipe connected to the standard error of the Process.

References _errbuf_ap, _errfd, and _errstream_ap.

void Process::closeIn ( )

Close the file descriptor and ostream of the pipe connected to the standard in of the Process.

The Process will then receive an EOF on a subsequent read from the other end of the pipe.

References _inbuf_ap, _infd, and _instream_ap.

void Process::closeOut ( )

Close the file descriptor and istream of the pipe connected to the standard out of the Process.

References _outbuf_ap, _outfd, and _outstream_ap.

std::istream& nidas::util::Process::errStream ( )

inline

Get the istream of the pipe that is connected to the standard error of the Process.

This istream is only valid after a spawn() of a Process. The error output of the Process can be read from this istream.

References _errstream_ap.

Referenced by nidas::util::svnStatus().

string Process::expandEnvVars ( std::string input )

static

References getEnvVar().

Referenced by nidas::core::IOChannel::createIOChannel(), nidas::core::MultipleUDPSockets::fromDOMElement(), nidas::core::McSocketUDP::fromDOMElement(), nidas::core::McSocket::fromDOMElement(), nidas::core::DatagramSocket::fromDOMElement(), nidas::core::Socket::fromDOMElement(), nidas::core::ServerSocket::fromDOMElement(), nidas::core::NidasApp::getConfigsXML(), StatsProcess::getDataset(), nidas::core::ProjectConfig::initProject(), nidas::dynld::raf::SyncServer::initProject(), StatsProcess::listOutputSamples(), nidas::core::DSMServerApp::parseXMLConfigFile(), ARLIngest::prepareHeaderIds(), PacketDecode::run(), StatsProcess::run(), DmdA2dCk::run(), nidas::dynld::XMLConfigService::Worker::run(), nidas::core::DSMEngine::run(), ExtractFast2D::run(), ExtractDMT::run(), DataPrep::run(), DataDump::run(), DataStats::run(), nidas::core::FsMount::setDevice(), nidas::core::FsMount::setDir(), and nidas::core::NidasApp::throw().

bool Process::getEffectiveCapability	(	int	cap	)
throw	(	Exception
	)

static

Check if this process has an effective capability.

See man 7 capabilities.

Referenced by nidas::core::NidasApp::setupProcess().

bool Process::getEnvVar	(	const std::string &	name,
		std::string &	value
	)

static

Get an environment variable given a variable name like "HOST", without the '$', or any brackets, '{' or '}'.

Returns: : true if variable found

References _envLock.

Referenced by expandEnvVars(), nidas::core::Project::MyDictionary::getTokenValue(), nidas::util::UTime::getTZ(), nidas::core::ProjectConfig::putenv(), and nidas::util::UTime::setTZ().

int nidas::util::Process::getErrFd ( ) const

inline

Get the file descriptor of the pipe that is connected to the standard error of the Process.

This file descriptor is only valid after a spawn() of a Process. The error output of the Process can be read from this file descriptor.

References _errfd.

int nidas::util::Process::getInFd ( ) const

inline

Get the file descriptor of the pipe that is connected to the standard in of the Process.

This file descriptor is only valid after a spawn() of a Process. Bytes writen to this file descriptor can be then read by the Process.

References _infd.

unsigned long Process::getMaxRSS ( )

static

Return the maximum resident set size of the current process, in bytes.

This is the portion of the process's memory that is held in RAM. This value is determined with the getrusage(RUSAGE_SELF,...) system call.

References ELOG, and nidas::util::Exception::errnoToString().

int nidas::util::Process::getOutFd ( ) const

inline

Get the file descriptor of the pipe that is connected to the standard out of the Process.

This file descriptor is only valid after a spawn() of a Process. The output of the Process can be read from this file descriptor.

References _outfd.

pid_t nidas::util::Process::getPid ( ) const

inline

The process id of the Process.

Returns: : Will be -1 if this Process is not associated with a valid process.

References _pid.

Referenced by nidas::core::FsMount::cancel().

unsigned long Process::getVMemSize ( )

static

Return the virtual memory size in bytes of the current process, as read from the /proc/pid/stat file.

Do man proc for info.

References ELOG, nidas::util::Exception::errnoToString(), fclose(), and fp.

std::ostream& nidas::util::Process::inStream ( )

inline

Get the ostream of the pipe that is connected to the standard in of the Process.

This ostream is only valid after a spawn() of a Process.

References _instream_ap.

void Process::kill	(	int	signal	)
throw	(	IOException
	)

Send a signal to the process.

Referenced by nidas::core::FsMount::cancel(), and Process().

Process & Process::operator= ( const Process & x )

Assignment operator.

The assigned process (on LHS of =) will inherit the file descriptors and iostreams from x. The file descriptors and iostreams of the RHS Process, x, are no longer valid after this assignment.

References _errbuf_ap, _errfd, _errstream_ap, _inbuf_ap, _infd, _instream_ap, _outbuf_ap, _outfd, _outstream_ap, and _pid.

std::istream& nidas::util::Process::outStream ( )

inline

Get the istream of the pipe that is connected to the standard out of the Process.

This istream is only valid after a spawn() of a Process. The output of the Process can be read from this istream.

References _outstream_ap.

Referenced by nidas::core::FsMount::autoMount(), nidas::core::FsMount::mount(), nidas::util::svnStatus(), and nidas::core::FsMount::unmount().

void Process::removePidFile ( )

static

Remove the pid file.

Note that checkPidFile schedules this function to be called when the process exits.

References _pidFile.

void Process::setEnvVar	(	const std::string &	name,
		const std::string &	value
	)

static

References _environment, _envLock, and if().

Referenced by nidas::core::Dataset::putenv(), nidas::core::ProjectConfig::putenv(), and nidas::util::UTime::setTZ().

void Process::setErrFd ( int val )

private

References _errbuf_ap, _errfd, and _errstream_ap.

Referenced by spawn().

void Process::setInFd ( int val )

private

References _inbuf_ap, _infd, and _instream_ap.

Referenced by spawn().

void Process::setOutFd ( int val )

private

References _outbuf_ap, _outfd, and _outstream_ap.

Referenced by spawn().

Process Process::spawn	(	const std::string &	cmd,
		const std::vector< std::string > &	args,
		const std::map< std::string, std::string > &	env,
		int	niceval = `0`
	)
throw	(	IOException
	)

static

Fork and execute a command and associated arguments and environment.

Return the Process object that can be used to communicate with or control the sub-process.

Parameters

cmd,:	The name of the command. spawn uses the execvp system call, which means that if the command name does not contain a slash (/) character, then a search is done for the command name using the PATH environment variable.
args,:	Arguments that are passed to the command. The zero'th argument should be the short name of the command, as is required by the exec system calls.
env,:	Environment variables to be added or changed in the subprocess. The map keys are the names of the environment variables. Note that by default, the current environment is copied to the subprocess, so you only need to specify variables that you wish to be added or changed.
niceval,:	The desired nice value, typically a positive value so that the spawned process has a higher nice value (lower priority). If niceval is negative and the user does not have sufficient permisions to lower the nice value, the error is silently ignored.

References setErrFd(), setInFd(), and setOutFd().

Referenced by nidas::core::FsMount::autoMount(), nidas::core::DSMEngine::main(), nidas::core::FsMount::mount(), and nidas::core::FsMount::unmount().

Process Process::spawn	(	const std::string &	cmd,
		const std::vector< std::string > &	args,
		int	niceval = `0`
	)
throw	(	IOException
	)

static

Fork and execute a command and associated arguments.

Return the Process object that can be used to communicate with or control the sub-process. spawn uses the execvp system call, which means that if the command name does not contain a slash (/) character, then a search is done for the command name using the PATH environment variable.

Process Process::spawn	(	const std::string &	cmd	)
throw	(	IOException
	)

static

Execute a command by forking and executing command from the shell command line using "sh -c cmd".

Return the Process.

References setErrFd(), setInFd(), and setOutFd().

int Process::wait	(	bool	hang,
		int *	status
	)
throw	(	IOException
	)

Do a system wait on a process.

Returns: Process id of waited on process, or 0 if hang=false and process has not finished, or -1 if process does not exist.

Parameters

hang,:	If true, wait for process state to change. If hang=false, don't wait, return 0 if process state has not changed.
status,:	status of process. See man 2 waitpid. After a successfull wait, any file descriptors connected to the process will be closed.

Referenced by nidas::core::FsMount::autoMount(), nidas::core::FsMount::cancel(), nidas::core::FsMount::mount(), nidas::util::svnStatus(), and nidas::core::FsMount::unmount().

Member Data Documentation

map< string, char * > Process::_environment

staticprivate

Referenced by clearEnv(), and setEnvVar().

Mutex Process::_envLock

staticprivate

Referenced by clearEnv(), getEnvVar(), and setEnvVar().

auto_ptr<__gnu_cxx::stdio_filebuf<char> > nidas::util::Process::_errbuf_ap

mutableprivate

Referenced by closeErr(), operator=(), and setErrFd().

int nidas::util::Process::_errfd

mutableprivate

File descriptor that is connected via a pipe to the standard error file descriptor of a spawned process.

Referenced by closeErr(), getErrFd(), operator=(), Process(), and setErrFd().

auto_ptr<std::istream> nidas::util::Process::_errstream_ap

mutableprivate

Referenced by closeErr(), errStream(), operator=(), and setErrFd().

auto_ptr<__gnu_cxx::stdio_filebuf<char> > nidas::util::Process::_inbuf_ap

mutableprivate

GNU extension filebuf which is needed to create a ostream from a file descriptor.

Referenced by closeIn(), operator=(), and setInFd().

int nidas::util::Process::_infd

mutableprivate

File descriptor that is connected via a pipe to the standard in file descriptor of a spawned process.

It is declared mutable to allow invalidating x._infd in the copy constructor and assignment operators that take a reference to a const Process argument.

Referenced by closeIn(), getInFd(), operator=(), Process(), and setInFd().

auto_ptr<std::ostream> nidas::util::Process::_instream_ap

mutableprivate

Referenced by closeIn(), inStream(), operator=(), and setInFd().

auto_ptr<__gnu_cxx::stdio_filebuf<char> > nidas::util::Process::_outbuf_ap

mutableprivate

Referenced by closeOut(), operator=(), and setOutFd().

int nidas::util::Process::_outfd

mutableprivate

File descriptor that is connected via a pipe to the standard out file descriptor of a spawned process.

Referenced by closeOut(), getOutFd(), operator=(), Process(), and setOutFd().

auto_ptr<std::istream> nidas::util::Process::_outstream_ap