---

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 DaqSource : public InputSource, private evf::ModuleWeb {

   public:
    explicit DaqSource(const ParameterSet& pset, 
                     const InputSourceDescription& desc);
  
    virtual ~DaqSource();
    
   private:
  
    virtual std::auto_ptr<EventPrincipal> readEvent_();
    virtual boost::shared_ptr<LuminosityBlockPrincipal> readLuminosityBlock_();
    virtual boost::shared_ptr<RunPrincipal> readRun_();
    virtual std::auto_ptr<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();


    DaqBaseReader*  reader_;
    unsigned int    lumiSegmentSizeInEvents_; //temporary kludge, LS# will come from L1 Global record
    bool            fakeLSid_;
  
    RunNumber_t runNumber_;
    LuminosityBlockNumber_t luminosityBlockNumber_;
    bool noMoreEvents_;
    bool newRun_;
    bool newLumi_;
    std::auto_ptr<EventPrincipal> ep_;
    
    pthread_mutex_t mutex_;
    pthread_cond_t cond_;
    xdata::UnsignedInteger32         lumiSectionIndex_;
    xdata::UnsignedInteger32         prescaleSetIndex_;
    xdata::Boolean                   lsTimedOut_;
    xdata::InfoSpace                *is_;
    xdata::InfoSpace                *mis_;
    int count;
  };
  
}
  
#endif

---