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