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_ */