/afs/cern.ch/work/a/aaltunda/public/www/CMSSW_5_3_14/src/EventFilter/ResourceBroker/src/IPCManager.cc

Go to the documentation of this file.

//
// IPCManager.cc
// -------
//
//  Created on: Oct 26, 2011
//                                                                              Andrei Spataru : aspataru@cern.ch

#include "EventFilter/ResourceBroker/interface/IPCManager.h"
#include "EventFilter/ResourceBroker/interface/FUResourceTable.h"
#include "EventFilter/ResourceBroker/interface/FUResourceQueue.h"

using std::cout;
using std::endl;
using namespace evf;

//______________________________________________________________________________
IPCManager::IPCManager(bool useMQ) :
        useMessageQueueIPC_(useMQ) {
}

//______________________________________________________________________________
IPCManager::~IPCManager() {
        delete ipc_;
}

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

        // 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() {
        return ipc_;
}