/data/refman/pasoursint/CMSSW_5_2_9/src/EventFilter/ResourceBroker/interface/IPCManager.h

Go to the documentation of this file.

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

#ifndef IPCMANAGER_H_
#define IPCMANAGER_H_

#include "EventFilter/ResourceBroker/interface/IPCMethod.h"
#include "xdaq/Application.h"
#include "FWCore/Utilities/interface/CRC16.h"

namespace evf {

class IPCManager {

public:
        IPCManager(bool useMQ);
        virtual ~IPCManager();

        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();

private:
        // selected IPC method
        //      true - Message Queue
        //      false - Shared Memory
        bool useMessageQueueIPC_;

        // pointer to IPC communication type
        IPCMethod* ipc_;

};

}

#endif /* IPCMANAGER_H_ */