DaqSource.h

Go to the documentation of this file.

#ifndef DaqSource_DaqSource_H
#define DaqSource_DaqSource_H

#include <memory>
#include "boost/shared_ptr.hpp"
#include "FWCore/Framework/interface/InputSource.h"
#include "FWCore/Framework/interface/Frameworkfwd.h"
#include "EventFilter/Utilities/interface/ModuleWeb.h"

#include "xdata/UnsignedInteger32.h"
#include "xdata/Boolean.h"

#include <pthread.h>

class DaqBaseReader;

namespace edm {
  class ParameterSet;
  class Timestamp;
  class InputSourceDescription;
  class EventPrincipal;
  class LuminosityBlockAuxiliary;


  class DaqSource : public InputSource, private evf::ModuleWeb {

   public:
    explicit DaqSource(const ParameterSet& pset, 
             const InputSourceDescription& desc);
  
    virtual ~DaqSource();
    
   private:

    void defaultWebPage(xgi::Input *in, xgi::Output *out); 
    virtual EventPrincipal* readEvent_();
    virtual boost::shared_ptr<LuminosityBlockAuxiliary> readLuminosityBlockAuxiliary_();
    virtual boost::shared_ptr<RunAuxiliary> readRunAuxiliary_();
    virtual EventPrincipal* readIt(EventID const& eventID);
    virtual void skip(int offset);
    virtual void setLumi(LuminosityBlockNumber_t lb);
    virtual void setRun(RunNumber_t r);
    virtual ItemType getNextItemType();
  

    virtual void publish(xdata::InfoSpace *);
    virtual void publishToXmas(xdata::InfoSpace *);
    virtual void openBackDoor(unsigned int);
    virtual void closeBackDoor();
    virtual void signalWaitingThreadAndBlock();

    DaqBaseReader*  reader_;
    unsigned int    lumiSegmentSizeInEvents_; //temporary kludge, LS# will come from L1 Global record
    bool            useEventCounter_;
    unsigned int    eventCounter_;
    bool            keepUsingPsidFromTrigger_;
    bool            fakeLSid_;
  
    RunNumber_t runNumber_;
    LuminosityBlockNumber_t luminosityBlockNumber_;
    bool noMoreEvents_;
    bool newRun_;
    bool newLumi_;
    bool eventCached_;
    bool alignLsToLast_;
    
    pthread_mutex_t mutex_;
    pthread_mutex_t signal_lock_;
    pthread_cond_t cond_;
    xdata::UnsignedInteger32        *lumiSectionIndex_;
    xdata::UnsignedInteger32        *prescaleSetIndex_;
    xdata::UnsignedInteger32        *lastLumiPrescaleIndex_;
    xdata::UnsignedInteger32        *lastLumiUsingEol_;
    xdata::Boolean                  *lsTimedOut_;
    xdata::Boolean                  *lsToBeRecovered_;
    xdata::InfoSpace                *is_;
    xdata::InfoSpace                *mis_;
    int                              count;
    unsigned int                     thisEventLSid;
    bool                             goToStopping;
  };
  
}
  
#endif