AthenaInterprocess::Process Class Reference

#include <Process.h>

Collaboration diagram for AthenaInterprocess::Process:

Public Member Functions
	Process (pid_t pid)
	Process (const Process &other)
Process &	operator= (const Process &other)
virtual	~Process ()
pid_t	getProcessID () const
bool	connectIn (const SharedQueue &queue)
bool	connectOut (const IdentifiedSharedQueue &queue)
bool	schedule (const IMessageDecoder *func, const ScheduledWork *args)
int mainloop	ATLAS_NOT_THREAD_SAFE ()

Static Public Member Functions
static Process	launch ()

Private Attributes
SharedQueue	m_inbox
IdentifiedSharedQueue	m_outbox
pid_t	m_pid

Detailed Description

Definition at line 17 of file Process.h.

Constructor & Destructor Documentation

Process() [1/2]

AthenaInterprocess::Process::Process ( pid_t  pid )

explicit

Definition at line 34 of file Process.cxx.

                           : m_inbox(), m_outbox(), m_pid( pid ) 
{
 
}

Process() [2/2]

AthenaInterprocess::Process::Process

(

const Process &

other

)

Definition at line 39 of file Process.cxx.

                                       :
  m_inbox( other.m_inbox ), m_outbox( other.m_outbox ), m_pid( other.m_pid )
{
 
}

~Process()

AthenaInterprocess::Process::~Process ( )

virtual

Definition at line 55 of file Process.cxx.

{
 
}

Member Function Documentation

ATLAS_NOT_THREAD_SAFE()

int mainloop AthenaInterprocess::Process::ATLAS_NOT_THREAD_SAFE

(

)

connectIn()

bool AthenaInterprocess::Process::connectIn

(

const SharedQueue &

queue

)

Definition at line 67 of file Process.cxx.

{
   if ( ! queue.name().empty() ) {
      m_inbox = queue;
   /* TODO: check that the queue is valid and can receive messages */
      return true;
   }
 
   return false;
}

connectOut()

bool AthenaInterprocess::Process::connectOut

(

const IdentifiedSharedQueue &

queue

)

Definition at line 78 of file Process.cxx.

{
   if ( ! queue.name().empty() ) {
      m_outbox = queue;
   /* TODO: check that the queue is valid and can send messages */
      return true;
   }
 
   return false;
}

getProcessID()

pid_t AthenaInterprocess::Process::getProcessID

(

)

const

Definition at line 62 of file Process.cxx.

{
   return m_pid;
}

launch()

Process AthenaInterprocess::Process::launch ( )

static

Definition at line 20 of file Process.cxx.

{
   std::cout.flush();
   std::cerr.flush();
 
   pid_t pid = fork();
   if ( pid == 0 )
      prctl( PR_SET_PDEATHSIG, SIGHUP );          // Linux only
 
   return Process(pid);
}

operator=()

Process & AthenaInterprocess::Process::operator=

(

const Process &

other

)

Definition at line 45 of file Process.cxx.

{
   if ( this != &other ) {
      m_inbox = other.m_inbox;
      m_outbox = other.m_outbox;
      m_pid = other.m_pid;
   }
   return *this;
}

schedule()

bool AthenaInterprocess::Process::schedule	(	const IMessageDecoder *	func,
		const ScheduledWork *	args
	)

Definition at line 89 of file Process.cxx.

{
  //Send func
  std::string strptr("");
  if(func) {
    size_t ptrsize = sizeof(func);
    char* charptr = new char[ptrsize];
    memcpy(charptr,&func,ptrsize);
    strptr=std::string(charptr,ptrsize);
    delete[] charptr;
  }
  bool send_ok = m_inbox.try_send(strptr);
 
  //Send params
  if(send_ok) {
    std::string strparam = (args?std::string((char*)args->data,args->size):std::string(""));
    send_ok = m_inbox.try_send(strparam);
  }
  
  return send_ok;
}

Member Data Documentation

m_inbox

SharedQueue AthenaInterprocess::Process::m_inbox

private

Definition at line 36 of file Process.h.

m_outbox

IdentifiedSharedQueue AthenaInterprocess::Process::m_outbox

private

Definition at line 37 of file Process.h.

m_pid

pid_t AthenaInterprocess::Process::m_pid

private

Definition at line 38 of file Process.h.

---

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

• Process.h
• Process.cxx