#include <DaqSource.h>

Inheritance diagram for edm::DaqSource:

Public Member Functions
	DaqSource (const ParameterSet &pset, const InputSourceDescription &desc)

virtual	~DaqSource ()

Public Member Functions inherited from edm::InputSource
boost::shared_ptr < ActivityRegistry >	actReg () const
	Accessor for Activity Registry. More...

boost::shared_ptr < BranchIDListHelper >	branchIDListHelper () const
	Accessor for branchIDListHelper. More...

void	closeFile (FileBlock *, bool cleaningUpAfterException)
	close current file More...

void	doBeginJob ()
	Called by framework at beginning of job. More...

void	doBeginLumi (LuminosityBlockPrincipal &lbp)
	Called by framework at beginning of lumi block. More...

void	doBeginRun (RunPrincipal &rp)
	Called by framework at beginning of run. More...

void	doEndJob ()
	Called by framework at end of job. More...

void	doEndLumi (LuminosityBlockPrincipal &lbp, bool cleaningUpAfterException)
	Called by framework at end of lumi block. More...

void	doEndRun (RunPrincipal &rp, bool cleaningUpAfterException)
	Called by framework at end of run. More...

void	doPostForkReacquireResources (boost::shared_ptr< multicore::MessageReceiverForSource >)

void	doPreForkReleaseResources ()
	Called by the framework before forking the process. More...

ProcessingController::ForwardState	forwardState () const

bool	goToEvent (EventID const &eventID)

	InputSource (ParameterSet const &, InputSourceDescription const &)
	Constructor. More...

	InputSource (InputSource const &)=delete

void	issueReports (EventID const &eventID)
	issue an event report More...

LuminosityBlockNumber_t	luminosityBlock () const
	Accessor for current luminosity block number. More...

boost::shared_ptr < LuminosityBlockAuxiliary >	luminosityBlockAuxiliary () const
	Called by the framework to merge or insert lumi in principal cache. More...

int	maxEvents () const

int	maxLuminosityBlocks () const

ModuleDescription const &	moduleDescription () const
	Accessor for 'module' description. More...

ItemType	nextItemType ()

InputSource &	operator= (InputSource const &)=delete

bool	primary () const
	Accessor for primary input source flag. More...

ProcessConfiguration const &	processConfiguration () const
	Accessor for Process Configuration. More...

std::string const &	processGUID () const
	Accessor for global process identifier. More...

ProcessingMode	processingMode () const
	RunsLumisAndEvents (default), RunsAndLumis, or Runs. More...

boost::shared_ptr < ProductRegistry const >	productRegistry () const
	Accessor for product registry. More...

bool	randomAccess () const

boost::shared_ptr < LuminosityBlockPrincipal >	readAndCacheLumi (HistoryAppender &historyAppender)
	Read next luminosity block (new lumi) More...

boost::shared_ptr< RunPrincipal >	readAndCacheRun (HistoryAppender &historyAppender)
	Read next run (new run) More...

void	readAndMergeLumi (boost::shared_ptr< LuminosityBlockPrincipal > lbp)
	Read next luminosity block (same as a prior lumi) More...

void	readAndMergeRun (boost::shared_ptr< RunPrincipal > rp)
	Read next run (same as a prior run) More...

EventPrincipal *	readEvent (EventPrincipal &ep)

EventPrincipal *	readEvent (EventPrincipal &ep, EventID const &)
	Read a specific event. More...

std::unique_ptr< FileBlock >	readFile ()
	Read next file. More...

boost::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary ()
	Read next luminosity block Auxilary. More...

boost::shared_ptr< RunAuxiliary >	readRunAuxiliary ()
	Read next run Auxiliary. More...

ProcessHistoryID const &	reducedProcessHistoryID () const

void	registerProducts ()
	Register any produced products. More...

int	remainingEvents () const

int	remainingLuminosityBlocks () const

void	repeat ()
	Reset the remaining number of events/lumis to the maximum number. More...

ProcessingController::ReverseState	reverseState () const

void	rewind ()
	Begin again at the first event. More...

RunNumber_t	run () const
	Accessor for current run number. More...

boost::shared_ptr< RunAuxiliary >	runAuxiliary () const
	Called by the framework to merge or insert run in principal cache. More...

void	setLuminosityBlockNumber_t (LuminosityBlockNumber_t lb)
	Set the luminosity block ID. More...

void	setRunNumber (RunNumber_t r)
	Set the run number. More...

void	skipEvents (int offset)

bool	skipForForking ()

Timestamp const &	timestamp () const
	Accessor for the current time, as seen by the input source. More...

virtual	~InputSource ()
	Destructor. More...

Private Member Functions
virtual void	closeBackDoor ()

void	defaultWebPage (xgi::Input in, xgi::Output out)

int	doMyBeginRun ()

virtual ItemType	getNextItemType ()

virtual void	openBackDoor (unsigned int, bool *)

virtual void	publish (xdata::InfoSpace *)

virtual void	publishForkInfo (evf::moduleweb::ForkInfoObj *forkInfoObj)

virtual void	publishToXmas (xdata::InfoSpace *)

virtual EventPrincipal *	readEvent_ (EventPrincipal &eventPrincipal)

virtual EventPrincipal *	readIt (EventID const &eventID)

virtual boost::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ ()

virtual boost::shared_ptr < RunAuxiliary >	readRunAuxiliary_ ()

virtual void	setLumi (LuminosityBlockNumber_t lb)

virtual void	setRun (RunNumber_t r)

virtual void	signalWaitingThreadAndBlock ()

virtual void	skip (int offset)

Private Member Functions inherited from evf::ModuleWeb
	ModuleWeb (const std::string &)

virtual	~ModuleWeb ()

Private Attributes
bool	alignLsToLast_

bool	beginRunTiming_

int	bunchCrossing_

pthread_cond_t	cond_

int	count

DaqProvenanceHelper	daqProvenanceHelper_

unsigned int	eventCounter_

EventID	eventID_

EventAuxiliary::ExperimentType	evttype_

bool	fakeLSid_

FEDRawDataCollection *	fedCollection_

evf::moduleweb::ForkInfoObj *	forkInfo_

bool	goToStopping

bool	immediateStop

xdata::InfoSpace *	is_

bool	keepUsingPsidFromTrigger_

xdata::UnsignedInteger32 *	lastLumiPrescaleIndex_

xdata::UnsignedInteger32 *	lastLumiUsingEol_

xdata::Boolean *	lsTimedOut_

xdata::Boolean *	lsToBeRecovered_

LuminosityBlockNumber_t	luminosityBlockNumber_

xdata::UnsignedInteger32 *	lumiSectionIndex_

unsigned int	lumiSegmentSizeInEvents_

unsigned int	lumiSegmentSizeInSeconds_

xdata::InfoSpace *	mis_

pthread_mutex_t	mutex_

bool	noMoreEvents_

int	orbitNumber_

ProcessHistoryID	phid_

xdata::UnsignedInteger32 *	prescaleSetIndex_

DaqBaseReader *	reader_

bool	runFork_

RunNumber_t	runNumber_

pthread_mutex_t	signal_lock_

struct timeval	startOfLastLumi

unsigned int	thisEventLSid

timeval	tvStat_

bool	useEventCounter_

bool	useTimer_

Private Attributes inherited from evf::ModuleWeb
std::string	moduleName_

Additional Inherited Members
Public Types inherited from edm::InputSource
enum	ItemType { IsInvalid, IsStop, IsFile, IsRun, IsLumi, IsEvent, IsRepeat }

enum	ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents }

typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Static Public Member Functions inherited from edm::InputSource
static const std::string &	baseType ()

static void	fillDescription (ParameterSetDescription &desc)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Protected Member Functions inherited from edm::InputSource
void	decreaseRemainingEventsBy (int iSkipped)

bool	eventCached () const

boost::shared_ptr < LuminosityBlockPrincipal > const	luminosityBlockPrincipal () const

bool	newLumi () const

bool	newRun () const

ProductRegistry &	productRegistryUpdate () const

void	reset () const

void	resetEventCached ()

void	resetLuminosityBlockAuxiliary (bool isNewLumi=true) const

void	resetNewLumi ()

void	resetNewRun ()

void	resetRunAuxiliary (bool isNewRun=true) const

boost::shared_ptr < RunPrincipal > const	runPrincipal () const

void	setEventCached ()
	Called by the framework to merge or ached() const {return eventCached_;}. More...

void	setLuminosityBlockAuxiliary (LuminosityBlockAuxiliary *lbp)

void	setNewLumi ()

void	setNewRun ()

void	setRunAuxiliary (RunAuxiliary *rp)

void	setTimestamp (Timestamp const &theTime)
	To set the current time, as seen by the input source. More...

ItemType	state () const

Detailed Description

Definition at line 39 of file DaqSource.h.

Constructor & Destructor Documentation

DaqSource::DaqSource	(	const ParameterSet &	pset,
		const InputSourceDescription &	desc
	)

explicit

Definition at line 55 of file DaqSource.cc.

References edm::Timestamp::beginOfTime(), cms::Exception::category(), cond_, count, gather_cfg::cout, edm::DaqProvenanceHelper::daqInit(), daqProvenanceHelper_, alignCSCRings::e, fakeLSid_, reco::get(), edm::ParameterSet::getUntrackedParameter(), lumiSegmentSizeInEvents_, lumiSegmentSizeInSeconds_, mutex_, phid_, edm::InputSource::productRegistryUpdate(), matplotRender::reader, reader_, runNumber_, DaqBaseReader::setRunNumber(), edm::InputSource::setTimestamp(), signal_lock_, startOfLastLumi, and AlCaHLTBitMon_QueryRunRegistry::string.

     : InputSource(pset,desc)
     , evf::ModuleWeb("DaqSource")
     , reader_(0)
     , lumiSegmentSizeInEvents_(pset.getUntrackedParameter<unsigned int>("evtsPerLS",0))
     , lumiSegmentSizeInSeconds_(pset.getUntrackedParameter<unsigned int>("secondsPerLS",0))
     , useEventCounter_(pset.getUntrackedParameter<bool>("useEventCounter",false))
     , useTimer_(lumiSegmentSizeInSeconds_!=0)
     , eventCounter_(0)
     , keepUsingPsidFromTrigger_(pset.getUntrackedParameter<bool>("keepUsingPsidFromTrigger",false))
     , fakeLSid_(lumiSegmentSizeInEvents_ != 0 || lumiSegmentSizeInSeconds_ != 0)
     , runNumber_(pset.getUntrackedParameter<unsigned int>("runNumber",RunID::firstValidRun().run()))
     , luminosityBlockNumber_(LuminosityBlockID::firstValidLuminosityBlock().luminosityBlock())
     , daqProvenanceHelper_(TypeID(typeid(FEDRawDataCollection)))
     , noMoreEvents_(false)
     , alignLsToLast_(false)
     , lumiSectionIndex_(0)
     , prescaleSetIndex_(0)
     , lastLumiPrescaleIndex_(0)
     , lastLumiUsingEol_(0)
     , lsTimedOut_(0)
     , lsToBeRecovered_(0)
     , is_(0)
     , mis_(0)
     , thisEventLSid(0)
     , goToStopping(false)
     , immediateStop(false)
     , forkInfo_(nullptr)
     , runFork_(false)
     , beginRunTiming_(false)
     , bunchCrossing_(EventAuxiliary::invalidBunchXing)
     , orbitNumber_(EventAuxiliary::invalidBunchXing)
     , evttype_(EventAuxiliary::Undefined)
     , eventID_(0,0,0)
     , fedCollection_(nullptr)
   {
     count = 0;
     pthread_mutex_init(&mutex_,0);
     pthread_mutex_init(&signal_lock_,0);
     pthread_cond_init(&cond_,0);
 
     std::cout << " DaqSourceFake will use fake ls id ? " << fakeLSid_ << std::endl; 
     if(fakeLSid_) std::cout << " DaqSourceFake set to make a new ls every " << lumiSegmentSizeInEvents_ << " events " << std::endl;
     if(fakeLSid_) std::cout << " DaqSourceFake set to make a new ls every " << lumiSegmentSizeInSeconds_ << " seconds " << std::endl;
 
     setTimestamp(Timestamp::beginOfTime());
     
     // Instantiate the requested data source
     std::string reader = pset.getUntrackedParameter<std::string>("readerPluginName");
     
     try{
       reader_=
         DaqReaderPluginFactory::get()->create(reader,
                         pset.getUntrackedParameter<ParameterSet>("readerPset"));
       reader_->setRunNumber(runNumber_);
     }
     catch(edm::Exception &e) {
       if(e.category() == "Configuration" && reader_ == 0) {
     reader_ = DaqReaderPluginFactoryU::get()->create(reader);
     if(reader_ == 0) throw;
     else reader_->setRunNumber(runNumber_);
       }
       else {
         throw;
       }
     }
 
     // Initialize LS timer if requested
     if(lumiSegmentSizeInSeconds_ != 0) gettimeofday(&startOfLastLumi,0);
 
     // Initialize metadata, and save the process history ID for use every event.
     phid_ = daqProvenanceHelper_.daqInit(productRegistryUpdate());
 
   }

DaqSource::~DaqSource ( )

virtual

Definition at line 132 of file DaqSource.cc.

References reader_.

                         {
     delete reader_;
   }

Member Function Documentation

void DaqSource::closeBackDoor ( )

privatevirtual

Reimplemented from evf::ModuleWeb.

Definition at line 692 of file DaqSource.cc.

References cond_, count, lsTimedOut_, mutex_, and signal_lock_.

   {
     count--;
     pthread_cond_signal(&cond_);
     pthread_mutex_unlock(&mutex_);
     pthread_mutex_lock(&signal_lock_);
     if (lsTimedOut_ != 0)
       lsTimedOut_->value_ = false; 
   }

void DaqSource::defaultWebPage	(	xgi::Input *	in,
		xgi::Output *	out
	)

privatevirtual

Reimplemented from evf::ModuleWeb.

Definition at line 717 of file DaqSource.cc.

References alignCSCRings::e, cppFunctionSkipper::exception, edm::first(), goToStopping, LaserDQM_cfg::input, evf::ModuleWeb::moduleName_, getHLTPrescaleColumns::path, pos, o2o::query, edm::second(), and AlCaHLTBitMon_QueryRunRegistry::string.

   {
       std::string path;
       std::string urn;
       std::string mname;
       std::string query;
       std::string original_referrer_;
       try 
     {
       cgicc::Cgicc cgi(in);
       if ( xgi::Utils::hasFormElement(cgi,"gotostopping") )
         {
           goToStopping=true;
         }
       if ( xgi::Utils::hasFormElement(cgi,"module") )
         mname = xgi::Utils::getFormElement(cgi, "module")->getValue();
       cgicc::CgiEnvironment cgie(in);
       if(original_referrer_ == "")
         original_referrer_ = cgie.getReferrer();
       path = cgie.getPathInfo();
       query = cgie.getQueryString();
     }
       catch (const std::exception & e) 
     {
       // don't care if it did not work
     }
 
       using std::endl;
       *out << "<html>"                                                   << endl;
       *out << "<head>"                                                   << endl;
 
 
       *out << "<STYLE type=\"text/css\"> #T1 {border-width: 2px; border: solid blue; text-align: center} </STYLE> "                                      << endl; 
       *out << "<link type=\"text/css\" rel=\"stylesheet\"";
       *out << " href=\"/" <<  urn
        << "/styles.css\"/>"                   << endl;
 
       *out << "<title>" << moduleName_
        << " MAIN</title>"                                            << endl;
 
       *out << "</head>"                                                  << endl;
       *out << "<body onload=\"loadXMLDoc()\">"                           << endl;
       *out << "<table border=\"0\" width=\"100%\">"                      << endl;
       *out << "<tr>"                                                     << endl;
       *out << "  <td align=\"left\">"                                    << endl;
       *out << "    <img"                                                 << endl;
       *out << "     align=\"middle\""                                    << endl;
       *out << "     src=\"/evf/images/bugicon.jpg\""                     << endl;
       *out << "     alt=\"main\""                                        << endl;
       *out << "     width=\"90\""                                        << endl;
       *out << "     height=\"64\""                                       << endl;
       *out << "     border=\"\"/>"                                       << endl;
       *out << "    <b>"                                                  << endl;
       *out <<             moduleName_                                    << endl;
       *out << "    </b>"                                                 << endl;
       *out << "  </td>"                                                  << endl;
       *out << "  <td width=\"32\">"                                      << endl;
       *out << "    <a href=\"/urn:xdaq-application:lid=3\">"             << endl;
       *out << "      <img"                                               << endl;
       *out << "       align=\"middle\""                                  << endl;
       *out << "       src=\"/hyperdaq/images/HyperDAQ.jpg\""             << endl;
       *out << "       alt=\"HyperDAQ\""                                  << endl;
       *out << "       width=\"32\""                                      << endl;
       *out << "       height=\"32\""                                     << endl;
       *out << "       border=\"\"/>"                                     << endl;
       *out << "    </a>"                                                 << endl;
       *out << "  </td>"                                                  << endl;
       *out << "  <td width=\"32\">"                                      << endl;
       *out << "  </td>"                                                  << endl;
       *out << "  <td width=\"32\">"                                      << endl;
       *out << "    <a href=\"" << original_referrer_  << "\">"           << endl;
       *out << "      <img"                                               << endl;
       *out << "       align=\"middle\""                                  << endl;
       *out << "       src=\"/evf/images/spoticon.jpg\""          << endl;
       *out << "       alt=\"main\""                                      << endl;
       *out << "       width=\"32\""                                      << endl;
       *out << "       height=\"32\""                                     << endl;
       *out << "       border=\"\"/>"                                     << endl;
       *out << "    </a>"                                                 << endl;
       *out << "  </td>"                                                  << endl;
       *out << "</tr>"                                                    << endl;
       *out << "</table>"                                                 << endl;
 
       *out << "<hr/>"                                                    << endl;
   
       *out << cgicc::form().set("method","GET").set("action", path ) 
        << std::endl;
       boost::char_separator<char> sep("&");
       boost::tokenizer<boost::char_separator<char> > tokens(query, sep);
       for (boost::tokenizer<boost::char_separator<char> >::iterator tok_iter = tokens.begin();
        tok_iter != tokens.end(); ++tok_iter){
     size_t pos = (*tok_iter).find_first_of("=");
     if(pos != std::string::npos){
       std::string first  = (*tok_iter).substr(0    ,                        pos);
       std::string second = (*tok_iter).substr(pos+1, (*tok_iter).length()-pos-1);
       *out << cgicc::input().set("type","hidden").set("name",first).set("value", second) 
            << std::endl;
     }
       }
 
       *out << cgicc::input().set("type","hidden").set("name","gotostopping").set("value","true")
        << std::endl;
       *out << cgicc::input().set("type","submit").set("value","Go To Stopping")          << std::endl;
       *out << cgicc::form()                        << std::endl;  
 
       *out << "</body>"                                                  << endl;
       *out << "</html>"                                                  << endl;
   }

int DaqSource::doMyBeginRun ( )

private

Definition at line 149 of file DaqSource.cc.

Referenced by getNextItemType().

                               {
 
     if (forkInfo_) {
       while (!immediateStop) {
     //queue new run to Framework (causes EP beginRun to be executed)
     if (newRun()) {
       beginRunTiming_=true;
       gettimeofday(&tvStat_, NULL);
       return 2;
     }
     //measure time in fwk beginRun
     if (beginRunTiming_) {
       timeval tsTmp;
       gettimeofday(&tsTmp,NULL);
       long tusecs = (tsTmp.tv_sec-tvStat_.tv_sec)*1000000 + tsTmp.tv_usec - tvStat_.tv_usec;
       double tsecs = ((double)(tusecs/10000))/100.;
       std::cout << "DaqSource: FWK beginRun elapsed time: " << tsecs << " seconds in master EP"<< std::endl;
       edm::LogInfo("DaqSource") << "FWK beginRun elapsed time: " << tsecs << " seconds in master EP";
       beginRunTiming_=false;
       usleep(10000);//short sleep before fork
     }
     //first or new run init
     if (forkInfo_->forkParams.isMaster==-1) {
       forkInfo_->lock();//keeping it locked during init!
       forkInfo_->forkHandler(forkInfo_->fuAddr); //fork all slaves
         }
     if (forkInfo_->forkParams.isMaster==-1) {
       forkInfo_->unlock();
       std::cout << "ERROR (DaqSource): not notified to be either in  master or slave process after fork" << std::endl;
       return -2;
     }
 
     //slave process after fork: exit all this
     if (forkInfo_->forkParams.isMaster==0) {
       forkInfo_->unlock();
       return 1;
     }
 
     //master process after fork:
     if (forkInfo_->forkParams.isMaster==1) {
         forkInfo_->unlock();
         int slotToRestart=-1;
         sem_wait(forkInfo_->control_sem_);
         forkInfo_->lock();
 
         //got unblocked due to next run
         if (forkInfo_->forkParams.isMaster==-1) {
                 forkInfo_->unlock();
             continue; // check here for newRun()?
             }
         //check if asked to stop
         immediateStop=forkInfo_->stopCondition;
         if (immediateStop) {
           forkInfo_->receivedStop_=true;
           break;
         }
         
         //check if asked to restart
         slotToRestart = forkInfo_->forkParams.slotId;
 
       if (slotToRestart==-1 && forkInfo_->forkParams.restart==0) {
         //this will deal with spurious semaphore signals when slave is killed
         forkInfo_->unlock();
         continue;
       }
       //restart single slave
       forkInfo_->forkHandler(forkInfo_->fuAddr);
     }
       }
       //loop exit
       forkInfo_->unlock();
       return 0;
     }
     return -1; //no forkInfo_
   }

InputSource::ItemType DaqSource::getNextItemType ( )

privatevirtual

Implements edm::InputSource.

Definition at line 228 of file DaqSource.cc.

References alignLsToLast_, beginRunTiming_, bunchCrossing_, cond_, gather_cfg::cout, FEDRawData::data(), doMyBeginRun(), edm::EventID::event(), edm::InputSource::eventCached(), eventCounter_, eventID_, evf::evtn::evm_board_sense(), evttype_, edm::hlt::Exception, fakeLSid_, fedCollection_, FEDRawDataCollection::FEDData(), DaqBaseReader::fillRawData(), forkInfo_, evf::evtn::getevtyp(), evf::evtn::getfdlbx(), evf::evtn::getfdlpsc(), evf::evtn::getgpshigh(), evf::evtn::getgpslow(), evf::evtn::getlbn(), evf::evtn::getorbit(), goToStopping, evf::evtn::gtpe_board_sense(), evf::evtn::gtpe_getbx(), evf::evtn::gtpe_getlbn(), evf::evtn::gtpe_getorbit(), edm::daqsource::gtpeId_, edm::daqsource::gtpEvmId_, immediateStop, edm::EventAuxiliary::invalidBunchXing, edm::Timestamp::invalidTimestamp(), edm::InputSource::IsEvent, edm::InputSource::IsLumi, edm::InputSource::IsRun, edm::InputSource::IsStop, keepUsingPsidFromTrigger_, lastLumiPrescaleIndex_, lastLumiUsingEol_, edm::errors::LogicError, lsToBeRecovered_, edm::InputSource::luminosityBlock(), edm::InputSource::luminosityBlockAuxiliary(), luminosityBlockNumber_, lumiSectionIndex_, lumiSegmentSizeInEvents_, lumiSegmentSizeInSeconds_, mutex_, edm::InputSource::newLumi(), edm::InputSource::newRun(), noMoreEvents_, NULL, nullptr, orbitNumber_, phid_, edm::EventAuxiliary::PhysicsTrigger, prescaleSetIndex_, reader_, edm::InputSource::resetLuminosityBlockAuxiliary(), runFork_, runNumber_, edm::InputSource::setEventCached(), edm::InputSource::setLuminosityBlockAuxiliary(), edm::InputSource::setNewLumi(), edm::InputSource::setTimestamp(), signalWaitingThreadAndBlock(), FEDRawData::size(), startOfLastLumi, thisEventLSid, cond::rpcobgas::time, edm::InputSource::timestamp(), tvStat_, edm::EventAuxiliary::Undefined, and useEventCounter_.

                              {
     //    std::cout << getpid() << " enter getNextItemType " << std::endl;
     if (runFork_) {
       runFork_=false;
       int queueNext = doMyBeginRun();
       //check if new run (requires returning IsRun once)
       if (queueNext == 2) runFork_=true;
     }
 
     //get initial time before beginRun (used with old forking)
     if (!forkInfo_ && newRun()) {
       beginRunTiming_=true;
       gettimeofday(&tvStat_, NULL);
     }
 
     if (immediateStop) return IsStop;
 
     // --------------
     if(goToStopping){noMoreEvents_ = true; goToStopping=false;}
     if (noMoreEvents_) {
       pthread_mutex_lock(&mutex_);
       pthread_cond_signal(&cond_);
       pthread_mutex_unlock(&mutex_);
       return IsStop;
     }
     if (newRun()) {
       return IsRun;
     }
 
     //calculate and print the beginRun the timing
     if (beginRunTiming_) {
       timeval tsTmp;
       gettimeofday(&tsTmp,NULL);
       long tusecs = (tsTmp.tv_sec-tvStat_.tv_sec)*1000000 + tsTmp.tv_usec - tvStat_.tv_usec;
       double tsecs = ((double)(tusecs/10000))/100.;
       std::cout << "DaqSource (slave pid "<< getpid() << " ): FWK beginRun elapsed time: " 
         << tsecs << " seconds "<< std::endl;
       edm::LogInfo("DaqSource") << "DaqSource (slave pid "<< getpid() << " ): FWK beginRun elapsed time: " 
         << tsecs << " seconds ";
       beginRunTiming_=false;
     }
 
     if (newLumi() && luminosityBlockAuxiliary()) {
       //      std::cout << "newLumi & lumiblock valid " << std::endl;
       return IsLumi;
     }
     if (alignLsToLast_) { //here we are recovering from a gap in Ls number so an event may already be cached but 
       // we hold onto it until we have issued all the necessary endLumi/beginLumi
       //       std::cout << getpid() << "alignLsToLast was set and ls number is " 
       //        << luminosityBlockNumber_ << " before signaling" << std::endl;
       signalWaitingThreadAndBlock();
       luminosityBlockNumber_++;
       //       std::cout << getpid() << "alignLsToLast signaled and incremented " 
       //        << luminosityBlockNumber_ << " eventcached " 
       //        << eventCached() << std::endl;
       setNewLumi();
       if (lumiSectionIndex_!=0)
         lumiSectionIndex_->value_ = luminosityBlockNumber_;
       resetLuminosityBlockAuxiliary();
       if(luminosityBlockNumber_ == thisEventLSid+1) 
       {
         alignLsToLast_ = false;
       }
       if (!luminosityBlockAuxiliary() || luminosityBlockAuxiliary()->luminosityBlock() != luminosityBlockNumber_) {
     setLuminosityBlockAuxiliary(new LuminosityBlockAuxiliary(
           runNumber_, luminosityBlockNumber_, timestamp(), Timestamp::invalidTimestamp()));
     luminosityBlockAuxiliary()->setProcessHistoryID(phid_);
 
     //      std::cout << "nextItemType: dealt with new lumi block principal, retval is " << retval << std::endl;
       }
       return IsLumi;
     }
     if (eventCached()) {
       //      std::cout << "read event already cached " << std::endl;
       return IsEvent;
     }
 
     if(reader_ == 0) {
       throw edm::Exception(errors::LogicError)
       << "DaqSource is used without a reader. Check your configuration !";
     }
     TimeValue_t time = 0LL;
     timeval stv;
     gettimeofday(&stv,0);
     time = stv.tv_sec;
     time = (time << 32) + stv.tv_usec;
     Timestamp tstamp(time);
 
     bunchCrossing_ = EventAuxiliary::invalidBunchXing;
     orbitNumber_   = EventAuxiliary::invalidBunchXing;
     evttype_ = EventAuxiliary::Undefined;
     
     // pass a null pointer to fillRawData()!
     fedCollection_ = nullptr ;
 
   
     // let reader_ fill the fedCollection 
     int retval = reader_->fillRawData(eventID_, tstamp, fedCollection_);
     if(retval==0) {
       // fillRawData() failed, clean up the fedCollection in case it was allocated!
       if (nullptr != fedCollection_) delete fedCollection_;
       noMoreEvents_ = true;
       pthread_mutex_lock(&mutex_);
       pthread_cond_signal(&cond_);
       pthread_mutex_unlock(&mutex_);
       return IsStop;
     }
     else if(retval<0)
       {
  
     unsigned int nextLsFromSignal = (-1)*retval+1;
 //  std::cout << getpid() << "::got end-of-lumi for " << (-1)*retval
 //        << " was " << luminosityBlockNumber_ << std::endl;
     if(luminosityBlockNumber_ == (nextLsFromSignal-1) )
       {
         if (lastLumiUsingEol_ != 0)
           lastLumiUsingEol_->value_ = nextLsFromSignal;
         if(lsToBeRecovered_ != 0 && lsToBeRecovered_->value_){
 //        std::cout << getpid() << "eol::recover ls::for " << (-1)*retval << std::endl;
           signalWaitingThreadAndBlock();
           luminosityBlockNumber_++;
           setNewLumi();
           if (lumiSectionIndex_ != 0)
             lumiSectionIndex_->value_ = luminosityBlockNumber_;
           resetLuminosityBlockAuxiliary();
           thisEventLSid = nextLsFromSignal - 1;
           if(luminosityBlockNumber_ != thisEventLSid+1) 
         alignLsToLast_ = true;
           //          std::cout << getpid() << "eol::::alignLsToLast_ " << alignLsToLast_ << std::endl;
         }
         else{
           //          std::cout << getpid() << "eol::realign ls::for " << (-1)*retval << std::endl;
           luminosityBlockNumber_ = nextLsFromSignal;
           setNewLumi();
           if (lumiSectionIndex_ != 0)
             lumiSectionIndex_->value_ = luminosityBlockNumber_;
           resetLuminosityBlockAuxiliary();
         }
       }
     else {
       if(nextLsFromSignal >(luminosityBlockNumber_+100) ) {
         edm::LogError("DaqSource") << "Got EOL event with value " << retval 
                        << " nextLS would be " << nextLsFromSignal 
                        << " while we expected " << luminosityBlockNumber_+1 << " - disregarding... ";
       }
       if (nextLsFromSignal > luminosityBlockNumber_+2) //recover on delta > 2
       {
           if (lastLumiUsingEol_ != 0)
             lastLumiUsingEol_->value_ = nextLsFromSignal;
               thisEventLSid=nextLsFromSignal-1;//set new LS
           signalWaitingThreadAndBlock();
           luminosityBlockNumber_++;
           setNewLumi();
           if (lumiSectionIndex_ != 0)
           lumiSectionIndex_->value_ = luminosityBlockNumber_;
           alignLsToLast_ = true;
 
           //set new lumi block
           resetLuminosityBlockAuxiliary();
           setLuminosityBlockAuxiliary(new LuminosityBlockAuxiliary(
             runNumber_, luminosityBlockNumber_, timestamp(), Timestamp::invalidTimestamp()));
           luminosityBlockAuxiliary()->setProcessHistoryID(phid_);
       }
 
     }
     //  else
     //    std::cout << getpid() << "::skipping end-of-lumi for " << (-1)*retval << std::endl;
       }
     else
       {
     if (eventID_.event() == 0) {
       throw edm::Exception(errors::LogicError)
         << "The reader used with DaqSource has returned an invalid (zero) event number!\n"
         << "Event numbers must begin at 1, not 0.";
     }
     EventSourceSentry(*this);
     setTimestamp(tstamp);
     
     unsigned char *gtpFedAddr = fedCollection_->FEDData(daqsource::gtpEvmId_).size()!=0 ? fedCollection_->FEDData(daqsource::gtpEvmId_).data() : 0;
     uint32_t gtpsize = 0;
     if(gtpFedAddr !=0) gtpsize = fedCollection_->FEDData(daqsource::gtpEvmId_).size();
     unsigned char *gtpeFedAddr = fedCollection_->FEDData(daqsource::gtpeId_).size()!=0 ? fedCollection_->FEDData(daqsource::gtpeId_).data() : 0; 
 
     unsigned int nextFakeLs = 0;
     eventCounter_++;
     if (fakeLSid_)
         evttype_ =  edm::EventAuxiliary::PhysicsTrigger;
     bool fakeLSFromEventCount = fakeLSid_ && (lumiSegmentSizeInEvents_ != 0);
     bool fakeLSFromTimer = fakeLSid_ && (lumiSegmentSizeInSeconds_ != 0);
     if(fakeLSFromEventCount && luminosityBlockNumber_ != 
        (nextFakeLs = useEventCounter_ ? ((eventCounter_-1)/lumiSegmentSizeInEvents_ + 1) :
         ((eventID_.event() - 1)/lumiSegmentSizeInEvents_ + 1))) {
         if (prescaleSetIndex_ != 0 && lastLumiPrescaleIndex_!= 0) {
           lastLumiPrescaleIndex_->value_ = prescaleSetIndex_->value_;
           prescaleSetIndex_->value_ = 0; // since we do not know better but we want to be able to run
         }
       if(luminosityBlockNumber_ == nextFakeLs-1)
         signalWaitingThreadAndBlock();
       luminosityBlockNumber_ = nextFakeLs;
       thisEventLSid = nextFakeLs-1;
       setNewLumi();
       if (lumiSectionIndex_ != 0)
         lumiSectionIndex_->value_ = luminosityBlockNumber_;
       resetLuminosityBlockAuxiliary();
       if(keepUsingPsidFromTrigger_ && 
          gtpFedAddr!=0 && evf::evtn::evm_board_sense(gtpFedAddr,gtpsize)){
         if (prescaleSetIndex_ != 0)
           prescaleSetIndex_->value_  = (evf::evtn::getfdlpsc(gtpFedAddr) & 0xffff);
       }   
     }
     else if(fakeLSFromTimer){
       struct timeval tv;
       gettimeofday(&tv,0);
       unsigned int elapsed_time = tv.tv_sec - startOfLastLumi.tv_sec;
       //      std::cout << "daqsource elapsed time " << elapsed_time << std::endl;
       if(luminosityBlockNumber_ != 
          (nextFakeLs = elapsed_time/lumiSegmentSizeInSeconds_ + 1)) {
         if(prescaleSetIndex_ != 0){
           lastLumiPrescaleIndex_->value_ = prescaleSetIndex_->value_;
           prescaleSetIndex_->value_ = 0; // since we do not know better but we want to be able to run
         }
         if(luminosityBlockNumber_ == (nextFakeLs-1))
           signalWaitingThreadAndBlock();
         luminosityBlockNumber_ = nextFakeLs;
         thisEventLSid = nextFakeLs-1;
         setNewLumi();
         if(lumiSectionIndex_!=0)
           lumiSectionIndex_->value_ = luminosityBlockNumber_;
         resetLuminosityBlockAuxiliary();
         if(keepUsingPsidFromTrigger_ && 
            gtpFedAddr!=0 && evf::evtn::evm_board_sense(gtpFedAddr,gtpsize)){
           if(prescaleSetIndex_ != 0)
         prescaleSetIndex_->value_  = (evf::evtn::getfdlpsc(gtpFedAddr) & 0xffff);
         }     
       }
     } 
     else if(!fakeLSid_){ 
 
       if(gtpFedAddr!=0 && evf::evtn::evm_board_sense(gtpFedAddr,gtpsize)){
         if (lastLumiPrescaleIndex_ != 0 && prescaleSetIndex_ != 0)
           lastLumiPrescaleIndex_->value_ = prescaleSetIndex_->value_;
         thisEventLSid = evf::evtn::getlbn(gtpFedAddr);
         if (prescaleSetIndex_ != 0)
           prescaleSetIndex_->value_  = (evf::evtn::getfdlpsc(gtpFedAddr) & 0xffff);
         evttype_ =  edm::EventAuxiliary::ExperimentType(evf::evtn::getevtyp(gtpFedAddr));
         if(luminosityBlockNumber_ > (thisEventLSid + 1))
         {
           //late event,throw fwk exception
           std::ostringstream excptmsg;
           excptmsg << "DaqSource::event with late LS (" << thisEventLSid + 1 << ")received.";
               throw edm::Exception(errors::LogicError,excptmsg.str());
         }
         if(luminosityBlockNumber_ != (thisEventLSid + 1)){
           // we got here in a running process and some Ls might have been skipped so set the flag, 
           // increase by one, check and if appropriate set the flag then continue
           if(lsToBeRecovered_!=0 && lsToBeRecovered_->value_){
         //      std::cout << getpid() << "eve::recover ls::for " << thisEventLSid << std::endl;
         signalWaitingThreadAndBlock();
         luminosityBlockNumber_++;
         setNewLumi();
         if (lumiSectionIndex_ !=0 )
           lumiSectionIndex_->value_ = luminosityBlockNumber_;
         resetLuminosityBlockAuxiliary();
         if(luminosityBlockNumber_ != thisEventLSid+1) alignLsToLast_ = true;
         //      std::cout << getpid() << "eve::::alignLsToLast_ " << alignLsToLast_ << std::endl;
           }
           else{ // we got here because the process was restarted. just realign the ls id and proceed with this event
         //      std::cout << getpid() << "eve::realign ls::for " << thisEventLSid << std::endl;
         luminosityBlockNumber_ = thisEventLSid + 1;
         setNewLumi();
         if (lumiSectionIndex_ !=0)
           lumiSectionIndex_->value_ = luminosityBlockNumber_;
         resetLuminosityBlockAuxiliary();
         if (lsToBeRecovered_ !=0)
           lsToBeRecovered_->value_ = true;
           }
         }
       }
       else if(gtpeFedAddr!=0 && evf::evtn::gtpe_board_sense(gtpeFedAddr)){
         if (lastLumiPrescaleIndex_ != 0 && prescaleSetIndex_ != 0)
           lastLumiPrescaleIndex_->value_ = prescaleSetIndex_->value_;
         thisEventLSid = evf::evtn::gtpe_getlbn(gtpeFedAddr);
         if (prescaleSetIndex_ != 0)
           prescaleSetIndex_->value_ = 0; //waiting to get a PS index from gtpe
         evttype_ =  edm::EventAuxiliary::PhysicsTrigger; 
         if(luminosityBlockNumber_ != (thisEventLSid + 1)){
           if(luminosityBlockNumber_ == thisEventLSid)
         signalWaitingThreadAndBlock();
           luminosityBlockNumber_ = thisEventLSid + 1;
           setNewLumi();
           if (lumiSectionIndex_ !=0 )
             lumiSectionIndex_->value_ = luminosityBlockNumber_;
           resetLuminosityBlockAuxiliary();
         }
       }
     }
     if(gtpFedAddr!=0 && evf::evtn::evm_board_sense(gtpFedAddr,gtpsize)){
       bunchCrossing_ =  int(evf::evtn::getfdlbx(gtpFedAddr));
       orbitNumber_ =  int(evf::evtn::getorbit(gtpFedAddr));
       TimeValue_t time = evf::evtn::getgpshigh(gtpFedAddr);
       time = (time << 32) + evf::evtn::getgpslow(gtpFedAddr);
       Timestamp tstamp(time);
       setTimestamp(tstamp);      
     }
     else if(gtpeFedAddr!=0 && evf::evtn::gtpe_board_sense(gtpeFedAddr)){
       bunchCrossing_ =  int(evf::evtn::gtpe_getbx(gtpeFedAddr));
       orbitNumber_ =  int(evf::evtn::gtpe_getorbit(gtpeFedAddr));
     }
       }    
           
     //    std::cout << "lumiblockaux = " << luminosityBlockAuxiliary() << std::endl;
     // If there is no luminosity block principal, make one.
     if (!luminosityBlockAuxiliary() || luminosityBlockAuxiliary()->luminosityBlock() != luminosityBlockNumber_) {
       setNewLumi();
       setLuminosityBlockAuxiliary(new LuminosityBlockAuxiliary(
     runNumber_, luminosityBlockNumber_, timestamp(), Timestamp::invalidTimestamp()));
       luminosityBlockAuxiliary()->setProcessHistoryID(phid_);
 
       //      std::cout << "nextItemType: dealt with new lumi block principal, retval is " << retval << std::endl;
     }
     //    std::cout << "here retval = " << retval << std::endl;
     if(retval<0){
       //      std::cout << getpid() << " returning from getnextitem because retval < 0 - IsLumi "
       //        << IsLumi << std::endl;
       if(newLumi()) return IsLumi; else return getNextItemType();
     }
     if (newLumi()) {
       return IsLumi;
     }
     setEventCached();
     return IsEvent;
   }

void DaqSource::openBackDoor	(	unsigned int	timeout_sec,
		bool *	running
	)

privatevirtual

Reimplemented from evf::ModuleWeb.

Definition at line 670 of file DaqSource.cc.

References CLOCK_REALTIME, cond_, count, lsTimedOut_, mutex_, NULL, and signal_lock_.

   {
     count++;
     if(count==2) throw;
     pthread_mutex_lock(&mutex_);
     if (running) *running=true;
     pthread_mutex_unlock(&signal_lock_);
     timespec ts;
 #if _POSIX_TIMERS > 0
     clock_gettime(CLOCK_REALTIME, &ts);
 #else
     struct timeval tv; 
     gettimeofday(&tv, NULL);
     ts.tv_sec = tv.tv_sec + 0;
     ts.tv_nsec = 0;
 #endif
     ts.tv_sec += timeout_sec;
 
     int rc = pthread_cond_timedwait(&cond_, &mutex_, &ts);
     if(rc == ETIMEDOUT && lsTimedOut_ != 0) lsTimedOut_->value_ = true; 
   }

void DaqSource::publish ( xdata::InfoSpace * is )

privatevirtual

Implements evf::ModuleWeb.

Definition at line 655 of file DaqSource.cc.

References is_, lastLumiPrescaleIndex_, lastLumiUsingEol_, lsTimedOut_, lsToBeRecovered_, lumiSectionIndex_, and prescaleSetIndex_.

   {
     is_ = is;
     lumiSectionIndex_      = (xdata::UnsignedInteger32*)is_->find("lumiSectionIndex");
     prescaleSetIndex_      = (xdata::UnsignedInteger32*)is_->find("prescaleSetIndex");
     lastLumiPrescaleIndex_ = (xdata::UnsignedInteger32*)is_->find("lastLumiPrescaleIndex");
     lastLumiUsingEol_ = (xdata::UnsignedInteger32*)is_->find("lastLumiUsingEol");
     lsTimedOut_            = (xdata::Boolean*)is_->find("lsTimedOut");
     lsToBeRecovered_       = (xdata::Boolean*)is_->find("lsToBeRecovered");
   }

void DaqSource::publishForkInfo ( evf::moduleweb::ForkInfoObj * forkInfoObj )

privatevirtual

Reimplemented from evf::ModuleWeb.

Definition at line 136 of file DaqSource.cc.

References forkInfo_, immediateStop, noMoreEvents_, and runFork_.

                                                                        {
     forkInfo_ = forkInfoObj;
     runFork_=true;
     immediateStop=false;
     noMoreEvents_=false;
   }

void DaqSource::publishToXmas ( xdata::InfoSpace * is )

privatevirtual

Reimplemented from evf::ModuleWeb.

Definition at line 665 of file DaqSource.cc.

References mis_.

   {
     mis_ = is;
   }

EventPrincipal * DaqSource::readEvent_ ( EventPrincipal & eventPrincipal )

privatevirtual

Implements edm::InputSource.

Definition at line 593 of file DaqSource.cc.

References bunchCrossing_, edm::DaqProvenanceHelper::constBranchDescription_, daqProvenanceHelper_, edm::DaqProvenanceHelper::dummyProvenance_, edm::EventID::event(), edm::InputSource::eventCached(), eventID_, evttype_, fedCollection_, edm::EventPrincipal::fillEventPrincipal(), edm::EventAuxiliary::invalidStoreNumber, edm::InputSource::newLumi(), edm::InputSource::newRun(), noMoreEvents_, orbitNumber_, phid_, edm::InputSource::processGUID(), edm::EventPrincipal::put(), edm::InputSource::resetEventCached(), runNumber_, thisEventLSid, and edm::InputSource::timestamp().

                                                       {
     //    std::cout << "assert not newRun " << std::endl;
     assert(!newRun());
     //    std::cout << "assert not newLumi " << std::endl;
     assert(!newLumi());
     //    std::cout << "assert not noMoreEvents " << std::endl;
     assert(!noMoreEvents_);
     //    std::cout << "assert eventCached " << std::endl;
     assert(eventCached());
     //    std::cout << "asserts done " << std::endl;
 
     resetEventCached();
 
     // make a brand new event principal
     eventID_ = EventID(runNumber_,thisEventLSid+1, eventID_.event());
     EventAuxiliary eventAux(eventID_, processGUID(),
                 timestamp(),
                 true,
                 evttype_,
                 bunchCrossing_,
                 EventAuxiliary::invalidStoreNumber,
                 orbitNumber_);
     eventAux.setProcessHistoryID(phid_);
     eventPrincipal.fillEventPrincipal(eventAux);
     
     // have fedCollection managed by a std::auto_ptr<>
     std::auto_ptr<FEDRawDataCollection> bare_product(fedCollection_);
 
     WrapperOwningHolder edp(new Wrapper<FEDRawDataCollection>(bare_product), Wrapper<FEDRawDataCollection>::getInterface());
     eventPrincipal.put(daqProvenanceHelper_.constBranchDescription_, edp, daqProvenanceHelper_.dummyProvenance_);
 
 /*
     Event e(eventPrincipal, md_);
     // put the fed collection into the transient event store
     e.put(bare_product);
     // The commit is needed to complete the "put" transaction.
     e.commit_();
 */
     return &eventPrincipal;
   }

EventPrincipal * DaqSource::readIt ( EventID const & eventID )

privatevirtual

Definition at line 642 of file DaqSource.cc.

References edm::hlt::Exception, and edm::errors::LogicError.

                                   {
       throw edm::Exception(errors::LogicError,"DaqSource::readIt(EventID const& eventID)")
         << "Random access read cannot be used for DaqSource.\n"
         << "Contact a Framework developer.\n";
   }

boost::shared_ptr< LuminosityBlockAuxiliary > DaqSource::readLuminosityBlockAuxiliary_ ( )

privatevirtual

Implements edm::InputSource.

Definition at line 583 of file DaqSource.cc.

References edm::InputSource::luminosityBlockAuxiliary(), edm::InputSource::newLumi(), edm::InputSource::newRun(), noMoreEvents_, and edm::InputSource::resetNewLumi().

                                            {
     assert(!newRun());
     assert(newLumi());
     assert(!noMoreEvents_);
     assert(luminosityBlockAuxiliary());
     resetNewLumi();
     return luminosityBlockAuxiliary();
   }

boost::shared_ptr< RunAuxiliary > DaqSource::readRunAuxiliary_ ( )

privatevirtual

Implements edm::InputSource.

Definition at line 573 of file DaqSource.cc.

References edm::Timestamp::invalidTimestamp(), edm::InputSource::newRun(), noMoreEvents_, phid_, edm::InputSource::resetNewRun(), runNumber_, and edm::InputSource::timestamp().

                                {
     assert(newRun());
     assert(!noMoreEvents_);
     resetNewRun();
     boost::shared_ptr<RunAuxiliary> ra(new RunAuxiliary(runNumber_, timestamp(), Timestamp::invalidTimestamp()));
     ra->setProcessHistoryID(phid_);
     return ra;
   }

void DaqSource::setLumi ( LuminosityBlockNumber_t lb )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 635 of file DaqSource.cc.

References edm::hlt::Exception, and edm::errors::LogicError.

                                             {
       throw edm::Exception(errors::LogicError,"DaqSource::setLumi(LuminosityBlockNumber_t lumiNumber)")
         << "The luminosity block number cannot be set externally for DaqSource.\n"
         << "Contact a Framework developer.\n";
   }

void DaqSource::setRun ( RunNumber_t r )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 562 of file DaqSource.cc.

References edm::InputSource::eventCached(), noMoreEvents_, alignCSCRings::r, reader_, edm::InputSource::reset(), edm::InputSource::resetLuminosityBlockAuxiliary(), runNumber_, edm::InputSource::setNewRun(), and DaqBaseReader::setRunNumber().

                                  {
     assert(!eventCached());
     reset();
     setNewRun();
     runNumber_ = r;
     if (reader_) reader_->setRunNumber(runNumber_);
     noMoreEvents_ = false;
     resetLuminosityBlockAuxiliary();
   }

void DaqSource::signalWaitingThreadAndBlock ( )

privatevirtual

Definition at line 702 of file DaqSource.cc.

References cond_, is_, mutex_, and signal_lock_.

Referenced by getNextItemType().

   {
     //check if we are running offline, in which case return immediately
     if(is_ == 0) return;
     pthread_mutex_lock(&signal_lock_);
     pthread_mutex_lock(&mutex_);
     pthread_mutex_unlock(&signal_lock_);
     //    std::cout << getpid() << " DS::signal from evloop " << std::endl;
     pthread_cond_signal(&cond_);
     //    std::cout << getpid() << " DS::go to wait for scalers wl " << std::endl;
     pthread_cond_wait(&cond_, &mutex_);
     pthread_mutex_unlock(&mutex_);
     ::usleep(1000);//allow other thread to lock
   }  

void DaqSource::skip ( int offset )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 649 of file DaqSource.cc.

References edm::hlt::Exception, and edm::errors::LogicError.

                      {
       throw edm::Exception(errors::LogicError,"DaqSource::skip(int offset)")
         << "Random access skip cannot be used for DaqSource\n"
         << "Contact a Framework developer.\n";
   }