evf::IPCManager Class Reference

#include <IPCManager.h>

List of all members.

Public Member Functions
void	initialise (bool segmentationMode, UInt_t nbRawCells, UInt_t nbRecoCells, UInt_t nbDqmCells, UInt_t rawCellSize, UInt_t recoCellSize, UInt_t dqmCellSize, int freeResRequiredForAllocate, BUProxy *bu, SMProxy *sm, log4cplus::Logger logger, unsigned int resourceStructureTimeout, EvffedFillerRB *frb, xdaq::Application *) throw (evf::Exception)
IPCMethod *const	ipc ()
	IPCManager (bool useMQ)
virtual	~IPCManager ()
Private Attributes
IPCMethod *	ipc_
bool	useMessageQueueIPC_

---

Detailed Description

Class used to create and initialize an IPC method of the required type. If constructed with argument <false>, the manager will create and initialize a FUResourceTable object. If constructed with argument <true>, the manager will create and initialize a FUResourceQueue object.

Author:

aspataru

Definition at line 27 of file IPCManager.h.

---

Constructor & Destructor Documentation

IPCManager::IPCManager

(

bool

useMQ

)

Definition at line 19 of file IPCManager.cc.

                                 :
        useMessageQueueIPC_(useMQ) {
}

IPCManager::~IPCManager

(

)

[virtual]

Definition at line 24 of file IPCManager.cc.

References ipc_.

                        {
        delete ipc_;
}

---

Member Function Documentation

void IPCManager::initialise	(	bool	segmentationMode,
		UInt_t	nbRawCells,
		UInt_t	nbRecoCells,
		UInt_t	nbDqmCells,
		UInt_t	rawCellSize,
		UInt_t	recoCellSize,
		UInt_t	dqmCellSize,
		int	freeResRequiredForAllocate,
		BUProxy *	bu,
		SMProxy *	sm,
		log4cplus::Logger	logger,
		unsigned int	resourceStructureTimeout,
		EvffedFillerRB *	frb,
		xdaq::Application *	app
	)		throw (evf::Exception)

Initialize the IPCMethod object with the given parameters.

Definition at line 29 of file IPCManager.cc.

References gather_cfg::cout, and fwlog::logger().

Referenced by evf::rb_statemachine::SharedResources::configureResources().

                                                                                {

        // XXX: MQ IPC is disabled until it is ready
        useMessageQueueIPC_ = false;

        if (!useMessageQueueIPC_) {
                // IPC communication type is SharedMemory
                //improve replace with logging
                cout << "IPCMANAGER:: ----> IPC communication type is Shared Memory!"
                                << endl;

                ipc_ = new FUResourceTable(segmentationMode, nbRawCells, nbRecoCells,
                                nbDqmCells, rawCellSize, recoCellSize, dqmCellSize, freeResReq, bu, sm,
                                logger, resourceStructureTimeout, frb, app);
        } else {
                // IPC communication type is MessageQueue
                cout << "IPCMANAGER:: ----> IPC communication type is Message Queue!"
                                << endl;

                ipc_ = new FUResourceQueue(segmentationMode, nbRawCells, nbRecoCells,
                                nbDqmCells, rawCellSize, recoCellSize, dqmCellSize, freeResReq, bu, sm,
                                logger, resourceStructureTimeout, frb, app);
        }
}

IPCMethod *const IPCManager::ipc

(

)

Returns a const pointer to the IPCMethod object created by the manager.

Definition at line 59 of file IPCManager.cc.

References ipc_.

Referenced by evf::rb_statemachine::SharedResources::configureResources().

                                 {
        return ipc_;
}

---

Member Data Documentation

IPCMethod* evf::IPCManager::ipc_ [private]

Definition at line 55 of file IPCManager.h.

Referenced by ipc(), and ~IPCManager().

bool evf::IPCManager::useMessageQueueIPC_ [private]

Definition at line 52 of file IPCManager.h.