PlaybackRawDataProvider.h

Go to the documentation of this file.

#ifndef PLAYBACKRAWDATAPROVIDER_H
#define PLAYBACKRAWDATAPROVIDER_H 1

#include "FWCore/Framework/interface/EDAnalyzer.h"
#include "FWCore/Framework/interface/Event.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"

#include <memory>
#include <semaphore.h>

class FEDRawDataCollection;

class PlaybackRawDataProvider : public edm::EDAnalyzer {
public:
  //
  // construction/destruction
  //
  explicit PlaybackRawDataProvider(const edm::ParameterSet&);
  ~PlaybackRawDataProvider() override;

  // EDAnalyzer interface
  void beginJob() override;
  void analyze(const edm::Event&, const edm::EventSetup&) override;
  void endJob() override;
  void respondToCloseInputFile(edm::FileBlock const& fb) override;

  // provide cached fed collection (and run/evt number, if needed!)
  virtual FEDRawDataCollection* getFEDRawData();
  virtual FEDRawDataCollection* getFEDRawData(unsigned int& runNumber, unsigned int& evtNumber);
  void setFreeToEof();
  bool areFilesClosed();

  static PlaybackRawDataProvider* instance();

private:
  static PlaybackRawDataProvider* instance_;
  //
  // private member functions
  //
  void lock() { sem_wait(&lock_); }
  void unlock() { sem_post(&lock_); }
  void waitWriteSem() { sem_wait(&writeSem_); }
  void postWriteSem() { sem_post(&writeSem_); }
  void waitReadSem() { sem_wait(&readSem_); }
  void postReadSem() { sem_post(&readSem_); }

  void sem_print();

private:
  //
  // member data
  //
  unsigned int queueSize_;
  FEDRawDataCollection** eventQueue_;
  unsigned int* runNumber_;
  unsigned int* evtNumber_;
  unsigned int count_;

  sem_t lock_;
  sem_t writeSem_;
  sem_t readSem_;
  unsigned int writeIndex_;
  unsigned int readIndex_;
  bool freeToEof_;
  bool filesClosed_;
  bool destroying_;
};

//
// implementation of inline functions
//

//______________________________________________________________________________
inline PlaybackRawDataProvider* PlaybackRawDataProvider::instance() { return instance_; }

#endif