AthenaInterprocess::ProcessGroup Class Reference

#include <ProcessGroup.h>

Collaboration diagram for AthenaInterprocess::ProcessGroup:

Public Member Functions
	ProcessGroup (int nprocs=-1)
virtual	~ProcessGroup ()
pid_t launchProcess	ATLAS_NOT_THREAD_SAFE ()
int map_async	ATLAS_NOT_THREAD_SAFE (const IMessageDecoder *func, const ScheduledWork *args, pid_t pid=0)
int wait	ATLAS_NOT_THREAD_SAFE (int options=0)
pid_t	wait_once (bool &flag)
ProcessResult *	pullOneResult ()
pid_t	getGroupID () const
const std::vector< Process > &	getChildren () const
const std::vector< ProcessStatus > &	getStatuses () const

Private Member Functions
bool create	ATLAS_NOT_THREAD_SAFE ()

Private Attributes
std::vector< Process >	m_processes
std::vector< ProcessStatus >	m_statuses
IdentifiedSharedQueue	m_inbox
int	m_nprocs
pid_t	m_pgid
int	m_processesCreated

Detailed Description

Definition at line 27 of file ProcessGroup.h.

Constructor & Destructor Documentation

ProcessGroup()

AthenaInterprocess::ProcessGroup::ProcessGroup ( int  nprocs = -1 )

explicit

Definition at line 34 of file ProcessGroup.cxx.

  : m_nprocs(nprocs)
  , m_pgid(-1)
  , m_processesCreated(0)
{
   if ( m_nprocs < 0 ) {
   // determine number of cores from system (available ones only)
      m_nprocs = sysconf( _SC_NPROCESSORS_ONLN );
   }
}

~ProcessGroup()

AthenaInterprocess::ProcessGroup::~ProcessGroup ( )

virtual

Definition at line 45 of file ProcessGroup.cxx.

{
}

Member Function Documentation

ATLAS_NOT_THREAD_SAFE() [1/4]

pid_t launchProcess AthenaInterprocess::ProcessGroup::ATLAS_NOT_THREAD_SAFE

(

)

ATLAS_NOT_THREAD_SAFE() [2/4]

bool create AthenaInterprocess::ProcessGroup::ATLAS_NOT_THREAD_SAFE ( )

private

ATLAS_NOT_THREAD_SAFE() [3/4]

int map_async AthenaInterprocess::ProcessGroup::ATLAS_NOT_THREAD_SAFE	(	const IMessageDecoder *	func,
		const ScheduledWork *	args,
		pid_t	pid = 0
	)

ATLAS_NOT_THREAD_SAFE() [4/4]

int wait AthenaInterprocess::ProcessGroup::ATLAS_NOT_THREAD_SAFE

(

int

options = 0

)

getChildren()

const std::vector< Process > & AthenaInterprocess::ProcessGroup::getChildren

(

)

const

Definition at line 197 of file ProcessGroup.cxx.

{
// Give access to the processes; this is temporarily needed for the python
// interface, but it is better broken up into the actual needs).
   return m_processes;
}

getGroupID()

pid_t AthenaInterprocess::ProcessGroup::getGroupID

(

)

const

Definition at line 192 of file ProcessGroup.cxx.

{
   return m_pgid;
}

getStatuses()

const std::vector< ProcessStatus > & AthenaInterprocess::ProcessGroup::getStatuses

(

)

const

Definition at line 204 of file ProcessGroup.cxx.

{
  return m_statuses;
}

pullOneResult()

ProcessResult * AthenaInterprocess::ProcessGroup::pullOneResult

(

)

Definition at line 177 of file ProcessGroup.cxx.

{
  ProcessResult* result(0);
  pid_t pid = -1;
  std::string buf = m_inbox.try_receive( pid );
  if(pid>0) {
    result = new ProcessResult;
    result->pid = pid;
    result->output.data = malloc(buf.size());
    memcpy(result->output.data,buf.data(),buf.size());
    result->output.size = buf.size();
  }
  return result;
}

wait_once()

pid_t AthenaInterprocess::ProcessGroup::wait_once

(

bool &

flag

)

Definition at line 149 of file ProcessGroup.cxx.

{
  flag = true;
  if(m_processes.empty()) return 0;
  int child_status = 0;
  pid_t child = waitpid(-m_pgid, &child_status,WNOHANG);
  if(child>0) {
    // Check if the process has failed
    flag = !(WIFSIGNALED(child_status) || WEXITSTATUS(child_status));
    // save the status
    child_status = WIFSIGNALED(child_status) ? WTERMSIG(child_status) : WEXITSTATUS(child_status);
    ProcessStatus p = {child, child_status};
    m_statuses.push_back(p);
    // remove the process from m_processes
    for(std::vector<Process>::iterator iproc=m_processes.begin();
    iproc!=m_processes.end(); ++iproc) {
      if(iproc->getProcessID()==child) {
    m_processes.erase(iproc);
    break;
      }
    }
  }
  else if(child<0) {
    flag = false;
  }
  return child;  
}

Member Data Documentation

m_inbox

IdentifiedSharedQueue AthenaInterprocess::ProcessGroup::m_inbox

private

Definition at line 49 of file ProcessGroup.h.

m_nprocs

int AthenaInterprocess::ProcessGroup::m_nprocs

private

Definition at line 50 of file ProcessGroup.h.

m_pgid

pid_t AthenaInterprocess::ProcessGroup::m_pgid

private

Definition at line 51 of file ProcessGroup.h.

m_processes

std::vector<Process> AthenaInterprocess::ProcessGroup::m_processes

private

Definition at line 47 of file ProcessGroup.h.

m_processesCreated

int AthenaInterprocess::ProcessGroup::m_processesCreated

private

Definition at line 52 of file ProcessGroup.h.

m_statuses

std::vector<ProcessStatus> AthenaInterprocess::ProcessGroup::m_statuses

private

Definition at line 48 of file ProcessGroup.h.

---

The documentation for this class was generated from the following files:

• ProcessGroup.h
• ProcessGroup.cxx