RawEventFileWriterForBU Class Reference

#include <RawEventFileWriterForBU.h>

Public Member Functions
uint32	adler32 () const
void	doFlushFile ()
void	doOutputEvent (FRDEventMsgView const &msg)
void	doOutputEvent (boost::shared_array< unsigned char > &msg)
void	doOutputEventFragment (unsigned char *dataPtr, unsigned long dataSize)
void	endOfLS (int ls)
void	handler (int s)
void	initialize (std::string const &destinationDir, std::string const &name, int ls)
	RawEventFileWriterForBU (edm::ParameterSet const &ps)
	RawEventFileWriterForBU (std::string const &fileName)
bool	sharedMode () const
void	start ()
void	stop ()
	~RawEventFileWriterForBU ()

Static Public Member Functions
static void	staticHandler (int s)

Private Attributes
uint32	adlera_
uint32	adlerb_
std::string	destinationDir_
std::string	fileName_
string	jsonDefLocation_
DataPointMonitor *	lumiMon_
int	microSleep_
std::auto_ptr< std::ofstream >	ost_
int	outfd_
IntJ	perFileEventCount_
DataPointMonitor *	perFileMon_
IntJ	perLumiEventCount_

Static Private Attributes
static RawEventFileWriterForBU *	instance = 0

Detailed Description

Definition at line 23 of file RawEventFileWriterForBU.h.

Constructor & Destructor Documentation

RawEventFileWriterForBU::RawEventFileWriterForBU ( edm::ParameterSet const &  ps )

explicit

Definition at line 36 of file RawEventFileWriterForBU.cc.

References instance, jsonDefLocation_, lumiMon_, NULL, perFileEventCount_, perFileMon_, perLumiEventCount_, jsoncollector::JsonMonitorable::setName(), staticHandler(), and jsoncollector::IntJ::value().

                                                                         : lumiMon_(0), outfd_(0),
                                           jsonDefLocation_(ps.getUntrackedParameter<string>("jsonDefLocation","")),
                                           // default to .5ms sleep per event
                                           microSleep_(ps.getUntrackedParameter<int>("microSleep", 0))
{
  //  initialize(ps.getUntrackedParameter<std::string>("fileName", "testFRDfile.dat"));
  perLumiEventCount_ = 0;
  // set names of the variables to be matched with JSON Definition
  perLumiEventCount_.setName("NEvents");

  // create a vector of all monitorable parameters to be passed to the monitor
  vector<JsonMonitorable*> lumiMonParams;
  lumiMonParams.push_back(&perLumiEventCount_);

  // create a DataPointMonitor using vector of monitorable parameters and a path to a JSON Definition file
  lumiMon_ = new DataPointMonitor(lumiMonParams, jsonDefLocation_);


  perFileEventCount_.value() = 0;
  perFileEventCount_.setName("NEvents");

  // create a vector of all monitorable parameters to be passed to the monitor
  vector<JsonMonitorable*> fileMonParams;
  fileMonParams.push_back(&perFileEventCount_);

  perFileMon_ = new DataPointMonitor(fileMonParams, jsonDefLocation_);
  instance = this;

  // SIGINT Handler
  struct sigaction sigIntHandler;
  sigIntHandler.sa_handler = RawEventFileWriterForBU::staticHandler;
  sigemptyset(&sigIntHandler.sa_mask);
  sigIntHandler.sa_flags = 0;
  sigaction(SIGINT, &sigIntHandler, NULL);

}

RawEventFileWriterForBU::RawEventFileWriterForBU ( std::string const &  fileName )

explicit

Definition at line 73 of file RawEventFileWriterForBU.cc.

{
  //  initialize(fileName);

}

RawEventFileWriterForBU::~RawEventFileWriterForBU

(

)

Definition at line 79 of file RawEventFileWriterForBU.cc.

References lumiMon_, and perFileMon_.

{
  //  ost_->close();
  if (lumiMon_ != 0)
    delete lumiMon_;
  if (perFileMon_ != 0)
    delete perFileMon_;
}

Member Function Documentation

uint32 RawEventFileWriterForBU::adler32 ( ) const

inline

Definition at line 36 of file RawEventFileWriterForBU.h.

{ return (adlerb_ << 16) | adlera_; }

void RawEventFileWriterForBU::doFlushFile

(

)

Definition at line 117 of file RawEventFileWriterForBU.cc.

References edm::hlt::Exception, fileName_, and ost_.

{
  ost_->flush();
  if (ost_->fail()) {
    throw cms::Exception("RawEventFileWriterForBU", "doOutputEvent")
      << "Error writing FED Raw Data event data to "
      << fileName_ << ".  Possibly the output disk "
      << "is full?" << std::endl;
  }
}

void RawEventFileWriterForBU::doOutputEvent

(

FRDEventMsgView const &

msg

)

Definition at line 88 of file RawEventFileWriterForBU.cc.

References edm::hlt::Exception, fileName_, microSleep_, outfd_, perFileEventCount_, perLumiEventCount_, FRDEventMsgView::size(), FRDEventMsgView::startAddress(), jsoncollector::IntJ::value(), and TablePrint::write.

{
  //  ost_->write((const char*) msg.startAddress(), msg.size());
  //  if (ost_->fail()) {
  ssize_t retval =  write(outfd_,(void*)msg.startAddress(), msg.size());
  if((unsigned)retval!= msg.size()){
    throw cms::Exception("RawEventFileWriterForBU", "doOutputEvent")
      << "Error writing FED Raw Data event data to "
      << fileName_ << ".  Possibly the output disk "
      << "is full?" << std::endl;
  }

  // throttle event output
  usleep(microSleep_);

  perLumiEventCount_.value()++;
  perFileEventCount_.value()++;

  //   ost_->flush();
  //   if (ost_->fail()) {
  //     throw cms::Exception("RawEventFileWriterForBU", "doOutputEvent")
  //       << "Error writing FED Raw Data event data to "
  //       << fileName_ << ".  Possibly the output disk "
  //       << "is full?" << std::endl;
  //   }

  //  cms::Adler32((const char*) msg.startAddress(), msg.size(), adlera_, adlerb_);
}

void RawEventFileWriterForBU::doOutputEvent ( boost::shared_array< unsigned char > &  msg )

inline

Definition at line 32 of file RawEventFileWriterForBU.h.

{};

void RawEventFileWriterForBU::doOutputEventFragment	(	unsigned char *	dataPtr,
		unsigned long	dataSize
	)

Definition at line 128 of file RawEventFileWriterForBU.cc.

References cms::Adler32(), adlera_, adlerb_, edm::hlt::Exception, fileName_, and ost_.

{
  ost_->write((const char*) dataPtr, dataSize);
  if (ost_->fail()) {
    throw cms::Exception("RawEventFileWriterForBU", "doOutputEventFragment")
      << "Error writing FED Raw Data event data to "
      << fileName_ << ".  Possibly the output disk "
      << "is full?" << std::endl;
  }

  ost_->flush();
  if (ost_->fail()) {
    throw cms::Exception("RawEventFileWriterForBU", "doOutputEventFragment")
      << "Error writing FED Raw Data event data to "
      << fileName_ << ".  Possibly the output disk "
      << "is full?" << std::endl;
  }

  cms::Adler32((const char*) dataPtr, dataSize, adlera_, adlerb_);
}

void RawEventFileWriterForBU::endOfLS

(

int

ls

)

Definition at line 202 of file RawEventFileWriterForBU.cc.

References destinationDir_, reco::dp, lumiMon_, outfd_, convertSQLitetoXML_cfg::output, getHLTPrescaleColumns::path, perLumiEventCount_, cond::serialize(), and jsoncollector::DataPointMonitor::snap().

{
  //writing empty EoLS file (will be filled with information)
  // create a DataPoint object and take a snapshot of the monitored data into it
  DataPoint dp;
  lumiMon_->snap(dp);

  std::ostringstream ostr;
  ostr << destinationDir_ << "/EoLS_" << std::setfill('0') << std::setw(4) << ls << ".jsn";
  int outfd_ = open(ostr.str().c_str(), O_WRONLY | O_CREAT,  S_IRWXU | S_IRWXG | S_IRWXO);
  if(outfd_!=0){close(outfd_); outfd_=0;}

  // serialize the DataPoint and output it
  string output;
  JSONSerializer::serialize(&dp, output);

  string path = ostr.str();
  FileIO::writeStringToFile(path, output);

  perLumiEventCount_ = 0;
}

void RawEventFileWriterForBU::handler

(

int

s

)

Definition at line 19 of file RawEventFileWriterForBU.cc.

References destinationDir_, convertSQLitetoXML_cfg::output, getHLTPrescaleColumns::path, DTTTrigCorrFirst::run, and AlCaHLTBitMon_QueryRunRegistry::string.

                                          {
  printf("Caught signal %d. Writing EOR file!\n",s);
  if (destinationDir_.size() > 0)
    {
      // CREATE EOR file
      string path = destinationDir_ + "/" + "EoR.jsd";
      string output = "EOR";
      FileIO::writeStringToFile(path, output);
      //dirty hack: extract run number from destination directory
      std::string::size_type pos = destinationDir_.find("run");
      std::string run = destinationDir_.substr(pos+3);
      path=destinationDir_ + "/" + "EoR_" + run + ".jsn";
      FileIO::writeStringToFile(path, output);
    }
  _exit(0);
}

void RawEventFileWriterForBU::initialize	(	std::string const &	destinationDir,
		std::string const &	name,
		int	ls
	)

Definition at line 150 of file RawEventFileWriterForBU.cc.

References adlera_, adlerb_, destinationDir_, reco::dp, edm::hlt::Exception, fileName_, mergeVDriftHistosByStation::name, ost_, dbtoconf::out, outfd_, convertSQLitetoXML_cfg::output, getHLTPrescaleColumns::path, perFileEventCount_, perFileMon_, cond::serialize(), jsoncollector::DataPointMonitor::snap(), AlCaHLTBitMon_QueryRunRegistry::string, and jsoncollector::IntJ::value().

{
  std::string oldFileName = fileName_;
  fileName_ = name;
  destinationDir_ = destinationDir;
  if(outfd_!=0){
    close(outfd_);
    outfd_=0;
  }
  outfd_ = open(fileName_.c_str(), O_WRONLY | O_CREAT,  S_IRWXU);
  if(outfd_ <= 0) { //attention here... it may happen that outfd_ is *not* set (e.g. missing initialize call...)
    throw cms::Exception("RawEventFileWriterForBU","initialize")
      << "Error opening FED Raw Data event output file: " << name
      << ": " << strerror(errno) << "\n";
  }
  ost_.reset(new std::ofstream(name.c_str(), std::ios_base::binary | std::ios_base::out));

  //move old file to done directory
  if (!oldFileName.empty()) {
    //rename(oldFileName.c_str(),destinationDir_.c_str());

    DataPoint dp;
    perFileMon_->snap(dp);
    string output;
    JSONSerializer::serialize(&dp, output);
    std::stringstream ss;
    ss << destinationDir_ << "/" << oldFileName.substr(oldFileName.rfind("/") + 1, oldFileName.size() - oldFileName.rfind("/") - 5) << ".jsn";
    string path = ss.str();
    FileIO::writeStringToFile(path, output);
    //now that the json file is there, move the raw file
    int fretval = rename(oldFileName.c_str(),(destinationDir_+oldFileName.substr(oldFileName.rfind("/"))).c_str());
    // if (debug_)
    edm::LogInfo("RawEventFileWriterForBU") << " tried move " << oldFileName << " to " << destinationDir_
                        << " status "  << fretval << " errno " << strerror(errno);
    
    edm::LogInfo("RawEventFileWriterForBU") << "Wrote JSON input file: " << path 
                        << " with perFileEventCount = " << perFileEventCount_.value();

    perFileEventCount_.value() = 0;

  }


  if (!ost_->is_open()) {
    throw cms::Exception("RawEventFileWriterForBU","initialize")
      << "Error opening FED Raw Data event output file: " << name << "\n";
  }

  adlera_ = 1;
  adlerb_ = 0;
}

bool RawEventFileWriterForBU::sharedMode ( ) const

inline

Definition at line 42 of file RawEventFileWriterForBU.h.

{return false;}

void RawEventFileWriterForBU::start ( void  )

inline

Definition at line 38 of file RawEventFileWriterForBU.h.

Referenced by progressbar.ProgressBar::__next__(), Types.LuminosityBlockRange::cppID(), and Types.EventRange::cppID().

{}

static void RawEventFileWriterForBU::staticHandler ( int  s )

inlinestatic

Definition at line 45 of file RawEventFileWriterForBU.h.

References instance.

Referenced by RawEventFileWriterForBU().

{ instance->handler(s); }

void RawEventFileWriterForBU::stop ( )

inline

Definition at line 39 of file RawEventFileWriterForBU.h.

{}

Member Data Documentation

uint32 RawEventFileWriterForBU::adlera_

private

Definition at line 62 of file RawEventFileWriterForBU.h.

Referenced by doOutputEventFragment(), and initialize().

uint32 RawEventFileWriterForBU::adlerb_

private

Definition at line 63 of file RawEventFileWriterForBU.h.

Referenced by doOutputEventFragment(), and initialize().

std::string RawEventFileWriterForBU::destinationDir_

private

Definition at line 57 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), handler(), and initialize().

std::string RawEventFileWriterForBU::fileName_

private

Definition at line 56 of file RawEventFileWriterForBU.h.

Referenced by doFlushFile(), doOutputEvent(), doOutputEventFragment(), and initialize().

RawEventFileWriterForBU * RawEventFileWriterForBU::instance = 0

staticprivate

Definition at line 65 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU().

string RawEventFileWriterForBU::jsonDefLocation_

private

Definition at line 59 of file RawEventFileWriterForBU.h.

Referenced by RawEventFileWriterForBU().

DataPointMonitor* RawEventFileWriterForBU::lumiMon_

private

Definition at line 50 of file RawEventFileWriterForBU.h.

Referenced by endOfLS(), RawEventFileWriterForBU(), and ~RawEventFileWriterForBU().

int RawEventFileWriterForBU::microSleep_

private

Definition at line 60 of file RawEventFileWriterForBU.h.

Referenced by doOutputEvent().

std::auto_ptr<std::ofstream> RawEventFileWriterForBU::ost_

private

Definition at line 54 of file RawEventFileWriterForBU.h.

Referenced by doFlushFile(), doOutputEventFragment(), and initialize().

int RawEventFileWriterForBU::outfd_

private

Definition at line 55 of file RawEventFileWriterForBU.h.

Referenced by doOutputEvent(), endOfLS(), and initialize().

IntJ RawEventFileWriterForBU::perFileEventCount_

private

Definition at line 51 of file RawEventFileWriterForBU.h.

Referenced by doOutputEvent(), initialize(), and RawEventFileWriterForBU().

DataPointMonitor* RawEventFileWriterForBU::perFileMon_

private

Definition at line 52 of file RawEventFileWriterForBU.h.

Referenced by initialize(), RawEventFileWriterForBU(), and ~RawEventFileWriterForBU().

IntJ RawEventFileWriterForBU::perLumiEventCount_

private

Definition at line 49 of file RawEventFileWriterForBU.h.

Referenced by doOutputEvent(), endOfLS(), and RawEventFileWriterForBU().