ProcessGroup.cxx File Reference

#include "AthenaInterprocess/ProcessGroup.h"
#include "AthenaInterprocess/SharedQueue.h"
#include "AthenaInterprocess/Utilities.h"
#include <boost/interprocess/ipc/message_queue.hpp>
#include <sys/wait.h>
#include <errno.h>
#include <stdlib.h>
#include <unistd.h>
#include <sstream>
#include <iostream>

Go to the source code of this file.

Namespaces
namespace	AthenaInterprocess

Functions
static AthenaInterprocess::SharedQueue	create_queue (const std::string &owner, int count)
pid_t ProcessGroup::launchProcess	AthenaInterprocess::ATLAS_NOT_THREAD_SAFE ()
int ProcessGroup::map_async	AthenaInterprocess::ATLAS_NOT_THREAD_SAFE (const IMessageDecoder *func, const ScheduledWork *args, pid_t pid)
int ProcessGroup::wait	AthenaInterprocess::ATLAS_NOT_THREAD_SAFE (int options)

Function Documentation

create_queue()

AthenaInterprocess::SharedQueue create_queue ( const std::string & owner, int count )

inlinestatic

Definition at line 23 of file ProcessGroup.cxx.

{
   std::ostringstream s;
   s << "athenamp_" << owner << '_' << getpid() << '_' << count << '_' << AthenaInterprocess::randString() << std::ends;
   AthenaInterprocess::SharedQueue queue = AthenaInterprocess::SharedQueue( s.str() );
   return queue;
}