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

Go to the documentation of this file.

//
// FUResourceTable
// ---------------
//
//            12/10/2006 Philipp Schieferdecker <philipp.schieferdecker@cern.ch>
//            20/01/2012 Andrei Spataru <aspataru@cern.ch>

#ifndef FURESOURCETABLE_H
#define FURESOURCETABLE_H 1

#include "EventFilter/ResourceBroker/interface/BUProxy.h"
#include "EventFilter/ResourceBroker/interface/SMProxy.h"
#include "EventFilter/ResourceBroker/interface/FUTypes.h"
#include "EventFilter/ShmBuffer/interface/FUShmBuffer.h"
#include "EventFilter/Utilities/interface/Exception.h"

#include "log4cplus/logger.h"
#include "toolbox/lang/Class.h"
#include "toolbox/task/Action.h"
#include "toolbox/task/WorkLoop.h"

#include <sys/types.h>
#include <string>
#include <vector>
#include <queue>

#include "IPCMethod.h"

namespace evf {

class FUResourceTable: public IPCMethod {
public:
        //
        // construction/destruction
        //
        FUResourceTable(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, EvffedFillerRB* frb,
                        xdaq::Application*) throw (evf::Exception);
        virtual ~FUResourceTable();

        //
        // member functions
        //

        void initialize(bool segmentationMode, UInt_t nbRawCells,
                        UInt_t nbRecoCells, UInt_t nbDqmCells, UInt_t rawCellSize,
                        UInt_t recoCellSize, UInt_t dqmCellSize) throw (evf::Exception);

        bool sendData();
        bool sendDataWhileHalting();

        bool sendDqm();
        bool sendDqmWhileHalting();

        bool discard();
        bool discardWhileHalting(bool sendDiscards);

        bool buildResource(MemRef_t* bufRef);

        bool discardDataEvent(MemRef_t* bufRef);

        bool discardDataEventWhileHalting(MemRef_t* bufRef);

        bool discardDqmEvent(MemRef_t* bufRef);
        bool discardDqmEventWhileHalting(MemRef_t* bufRef);

        void postEndOfLumiSection(MemRef_t* bufRef);

        void dropEvent();

        bool handleCrashedEP(UInt_t runNumber, pid_t pid);

        void shutDownClients();

        void clear();

        void resetCounters();

        UInt_t nbResources() const {
                return resources_.size();
        }

        // information about (raw) shared memory cells
        UInt_t nbClients() const;
        std::vector<pid_t> clientPrcIds() const;
        std::string clientPrcIdsAsString() const;
        std::vector<std::string> cellStates() const;
        std::vector<std::string> dqmCellStates() const;
        std::vector<UInt_t> cellEvtNumbers() const;
        std::vector<pid_t> cellPrcIds() const;
        std::vector<time_t> cellTimeStamps() const;

        //
        // helpers
        //
        unsigned int nbResources() {
                return resources_.size();
        }
        void lastResort();
        void resetIPC();

        //debugging
        std::string printStatus();

private:

        void discardNoReschedule();

        void rethrowShmBufferException(evf::Exception& e, std::string where) const throw (evf::Exception);

        void shutdownWatchdog(unsigned int timeout);


        FUShmBuffer *shmBuffer_;

        //workloop termination status
        bool sDataActive_;
        bool sDqmActive_;

        std::atomic_bool watchDogEnd_;
        std::atomic_bool watchDogSetFailed_;


};

} // namespace evf


#endif