|
|
|
#include <DaqSource.h>
Public Member Functions | |
| DaqSource (const ParameterSet &pset, const InputSourceDescription &desc) | |
| virtual | ~DaqSource () |
Private Member Functions | |
| virtual void | closeBackDoor () |
| void | defaultWebPage (xgi::Input *in, xgi::Output *out) |
| virtual ItemType | getNextItemType () |
| virtual void | openBackDoor (unsigned int) |
| virtual void | publish (xdata::InfoSpace *) |
| virtual void | publishToXmas (xdata::InfoSpace *) |
| virtual EventPrincipal * | readEvent_ () |
| 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 Attributes | |
| bool | alignLsToLast_ |
| pthread_cond_t | cond_ |
| int | count |
| bool | eventCached_ |
| unsigned int | eventCounter_ |
| bool | fakeLSid_ |
| bool | goToStopping |
| 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_ |
| xdata::InfoSpace * | mis_ |
| pthread_mutex_t | mutex_ |
| bool | newLumi_ |
| bool | newRun_ |
| bool | noMoreEvents_ |
| xdata::UnsignedInteger32 * | prescaleSetIndex_ |
| DaqBaseReader * | reader_ |
| RunNumber_t | runNumber_ |
| pthread_mutex_t | signal_lock_ |
| unsigned int | thisEventLSid |
| bool | useEventCounter_ |
Definition at line 34 of file DaqSource.h.
| DaqSource::DaqSource | ( | const ParameterSet & | pset, |
| const InputSourceDescription & | desc | ||
| ) | [explicit] |
Definition at line 58 of file DaqSource.cc.
References edm::Timestamp::beginOfTime(), cms::Exception::category(), cond_, count, reco::get(), edm::ParameterSet::getUntrackedParameter(), mutex_, reader_, runNumber_, DaqBaseReader::setRunNumber(), edm::InputSource::setTimestamp(), and signal_lock_.
: InputSource(pset,desc) , evf::ModuleWeb("DaqSource") , reader_(0) , lumiSegmentSizeInEvents_(pset.getUntrackedParameter<unsigned int>("evtsPerLS",0)) , useEventCounter_(pset.getUntrackedParameter<bool>("useEventCounter",false)) , eventCounter_(0) , keepUsingPsidFromTrigger_(pset.getUntrackedParameter<bool>("keepUsingPsidFromTrigger",false)) , fakeLSid_(lumiSegmentSizeInEvents_ != 0) , runNumber_(RunID::firstValidRun().run()) , luminosityBlockNumber_(LuminosityBlockID::firstValidLuminosityBlock().luminosityBlock()) , noMoreEvents_(false) , newRun_(true) , newLumi_(true) , eventCached_(false) , alignLsToLast_(false) , is_(0) , mis_(0) , thisEventLSid(0) , goToStopping(false) { count = 0; pthread_mutex_init(&mutex_,0); pthread_mutex_init(&signal_lock_,0); pthread_cond_init(&cond_,0); produces<FEDRawDataCollection>(); 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; } } }
| DaqSource::~DaqSource | ( | ) | [virtual] |
Definition at line 109 of file DaqSource.cc.
| void DaqSource::closeBackDoor | ( | ) | [private, virtual] |
Reimplemented from evf::ModuleWeb.
Definition at line 475 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_);
lsTimedOut_->value_ = false;
}
| void DaqSource::defaultWebPage | ( | xgi::Input * | in, |
| xgi::Output * | out | ||
| ) | [private, virtual] |
Reimplemented from evf::ModuleWeb.
Definition at line 497 of file DaqSource.cc.
References exception, edm::first(), goToStopping, collect_tpl::input, evf::ModuleWeb::moduleName_, path(), pos, o2o::query, edm::second(), and EcalElecEmulTccFlatFileProducerFromTPG_cfg::tokens.
{
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;
}
}
| InputSource::ItemType DaqSource::getNextItemType | ( | ) | [private, virtual] |
Implements edm::InputSource.
Definition at line 120 of file DaqSource.cc.
References goToStopping, and noMoreEvents_.
{noMoreEvents_ = true; goToStopping=false;}
if (noMoreEvents_) {
pthread_mutex_lock(&mutex_);
pthread_cond_signal(&cond_);
pthread_mutex_unlock(&mutex_);
return IsStop;
}
if (newRun_) {
return IsRun;
}
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;
newLumi_ = true;
lumiSectionIndex_->value_ = luminosityBlockNumber_;
resetLuminosityBlockAuxiliary();
if(luminosityBlockNumber_ == thisEventLSid+1)
{
alignLsToLast_ = false;
}
if (!luminosityBlockAuxiliary() || luminosityBlockAuxiliary()->luminosityBlock() != luminosityBlockNumber_) {
setLuminosityBlockAuxiliary(new LuminosityBlockAuxiliary(
runNumber_, luminosityBlockNumber_, timestamp(), Timestamp::invalidTimestamp()));
readAndCacheLumi();
setLumiPrematurelyRead();
// 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 !";
}
EventID eventId;
TimeValue_t time = 0LL;
timeval stv;
gettimeofday(&stv,0);
time = stv.tv_sec;
time = (time << 32) + stv.tv_usec;
Timestamp tstamp(time);
int bunchCrossing = EventAuxiliary::invalidBunchXing;
int orbitNumber = EventAuxiliary::invalidBunchXing;
// pass a 0 pointer to fillRawData()!
FEDRawDataCollection* fedCollection(0);
edm::EventAuxiliary::ExperimentType evttype = EventAuxiliary::Undefined;
// 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 (0 != 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) )
{
lastLumiUsingEol_->value_ = nextLsFromSignal;
if(lsToBeRecovered_->value_){
// std::cout << getpid() << "eol::recover ls::for " << (-1)*retval << std::endl;
signalWaitingThreadAndBlock();
luminosityBlockNumber_++;
newLumi_ = true;
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;
newLumi_ = true;
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... ";
}
// 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_ && luminosityBlockNumber_ !=
(nextFakeLs = useEventCounter_ ? ((eventCounter_-1)/lumiSegmentSizeInEvents_ + 1) :
((eventId.event() - 1)/lumiSegmentSizeInEvents_ + 1))) {
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;
newLumi_ = true;
lumiSectionIndex_->value_ = luminosityBlockNumber_;
resetLuminosityBlockAuxiliary();
if(keepUsingPsidFromTrigger_ &&
gtpFedAddr!=0 && evf::evtn::evm_board_sense(gtpFedAddr,gtpsize)){
prescaleSetIndex_->value_ = (evf::evtn::getfdlpsc(gtpFedAddr) & 0xffff);
}
}
else if(!fakeLSid_){
if(gtpFedAddr!=0 && evf::evtn::evm_board_sense(gtpFedAddr,gtpsize)){
lastLumiPrescaleIndex_->value_ = prescaleSetIndex_->value_;
thisEventLSid = evf::evtn::getlbn(gtpFedAddr);
prescaleSetIndex_->value_ = (evf::evtn::getfdlpsc(gtpFedAddr) & 0xffff);
evttype = edm::EventAuxiliary::ExperimentType(evf::evtn::getevtyp(gtpFedAddr));
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_->value_){
// std::cout << getpid() << "eve::recover ls::for " << thisEventLSid << std::endl;
signalWaitingThreadAndBlock();
luminosityBlockNumber_++;
newLumi_ = true;
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;
newLumi_ = true;
lumiSectionIndex_->value_ = luminosityBlockNumber_;
resetLuminosityBlockAuxiliary();
lsToBeRecovered_->value_ = true;
}
}
}
else if(gtpeFedAddr!=0 && evf::evtn::gtpe_board_sense(gtpeFedAddr)){
lastLumiPrescaleIndex_->value_ = prescaleSetIndex_->value_;
thisEventLSid = evf::evtn::gtpe_getlbn(gtpeFedAddr);
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;
newLumi_ = true;
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_) {
newLumi_ = true;
setLuminosityBlockAuxiliary(new LuminosityBlockAuxiliary(
runNumber_, luminosityBlockNumber_, timestamp(), Timestamp::invalidTimestamp()));
readAndCacheLumi();
setLumiPrematurelyRead();
// 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();
}
// make a brand new event
eventId = EventID(runNumber_,thisEventLSid+1, eventId.event());
EventAuxiliary eventAux(eventId, processGUID(),
timestamp(),
true,
evttype,
bunchCrossing,
EventAuxiliary::invalidStoreNumber,
orbitNumber);
eventPrincipalCache()->fillEventPrincipal(eventAux, luminosityBlockPrincipal());
eventCached_ = true;
// have fedCollection managed by a std::auto_ptr<>
std::auto_ptr<FEDRawDataCollection> bare_product(fedCollection);
Event e(*eventPrincipalCache(), moduleDescription());
// put the fed collection into the transient event store
e.put(bare_product);
// The commit is needed to complete the "put" transaction.
e.commit_();
if (newLumi_) {
return IsLumi;
}
return IsEvent;
}
| void DaqSource::openBackDoor | ( | unsigned int | timeout_sec | ) | [private, virtual] |
Reimplemented from evf::ModuleWeb.
Definition at line 454 of file DaqSource.cc.
References CLOCK_REALTIME, cond_, count, lsTimedOut_, mutex_, NULL, and signal_lock_.
{
count++;
if(count==2) throw;
pthread_mutex_lock(&mutex_);
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_->value_ = true;
}
| void DaqSource::publish | ( | xdata::InfoSpace * | is | ) | [private, virtual] |
Implements evf::ModuleWeb.
Definition at line 439 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::publishToXmas(xdata::InfoSpace *is)
| void DaqSource::publishToXmas | ( | xdata::InfoSpace * | is | ) | [private, virtual] |
Reimplemented from evf::ModuleWeb.
Definition at line 449 of file DaqSource.cc.
References mis_.
{
mis_ = is;
}
| EventPrincipal * DaqSource::readEvent_ | ( | ) | [private, virtual] |
Implements edm::InputSource.
Definition at line 404 of file DaqSource.cc.
| EventPrincipal * DaqSource::readIt | ( | EventID const & | eventID | ) | [private, virtual] |
Reimplemented from edm::InputSource.
Definition at line 426 of file DaqSource.cc.
| boost::shared_ptr< LuminosityBlockAuxiliary > DaqSource::readLuminosityBlockAuxiliary_ | ( | ) | [private, virtual] |
Implements edm::InputSource.
Definition at line 392 of file DaqSource.cc.
| boost::shared_ptr< RunAuxiliary > DaqSource::readRunAuxiliary_ | ( | ) | [private, virtual] |
Implements edm::InputSource.
Definition at line 384 of file DaqSource.cc.
| void DaqSource::setLumi | ( | LuminosityBlockNumber_t | lb | ) | [private, virtual] |
Reimplemented from edm::InputSource.
Definition at line 419 of file DaqSource.cc.
| void DaqSource::setRun | ( | RunNumber_t | r | ) | [private, virtual] |
Reimplemented from edm::InputSource.
Definition at line 373 of file DaqSource.cc.
| void DaqSource::signalWaitingThreadAndBlock | ( | ) | [private, virtual] |
Definition at line 484 of file DaqSource.cc.
References cond_, mutex_, and signal_lock_.
{
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 | ) | [private, virtual] |
Reimplemented from edm::InputSource.
Definition at line 433 of file DaqSource.cc.
bool edm::DaqSource::alignLsToLast_ [private] |
Definition at line 74 of file DaqSource.h.
pthread_cond_t edm::DaqSource::cond_ [private] |
Definition at line 78 of file DaqSource.h.
Referenced by closeBackDoor(), DaqSource(), openBackDoor(), and signalWaitingThreadAndBlock().
int edm::DaqSource::count [private] |
Definition at line 87 of file DaqSource.h.
Referenced by closeBackDoor(), DaqSource(), and openBackDoor().
bool edm::DaqSource::eventCached_ [private] |
Definition at line 73 of file DaqSource.h.
unsigned int edm::DaqSource::eventCounter_ [private] |
Definition at line 64 of file DaqSource.h.
bool edm::DaqSource::fakeLSid_ [private] |
Definition at line 66 of file DaqSource.h.
bool edm::DaqSource::goToStopping [private] |
Definition at line 89 of file DaqSource.h.
Referenced by defaultWebPage(), and getNextItemType().
xdata::InfoSpace* edm::DaqSource::is_ [private] |
Definition at line 85 of file DaqSource.h.
Referenced by publish().
bool edm::DaqSource::keepUsingPsidFromTrigger_ [private] |
Definition at line 65 of file DaqSource.h.
xdata::UnsignedInteger32* edm::DaqSource::lastLumiPrescaleIndex_ [private] |
Definition at line 81 of file DaqSource.h.
Referenced by publish().
xdata::UnsignedInteger32* edm::DaqSource::lastLumiUsingEol_ [private] |
Definition at line 82 of file DaqSource.h.
Referenced by publish().
xdata::Boolean* edm::DaqSource::lsTimedOut_ [private] |
Definition at line 83 of file DaqSource.h.
Referenced by closeBackDoor(), openBackDoor(), and publish().
xdata::Boolean* edm::DaqSource::lsToBeRecovered_ [private] |
Definition at line 84 of file DaqSource.h.
Referenced by publish().
Definition at line 69 of file DaqSource.h.
xdata::UnsignedInteger32* edm::DaqSource::lumiSectionIndex_ [private] |
Definition at line 79 of file DaqSource.h.
Referenced by publish().
unsigned int edm::DaqSource::lumiSegmentSizeInEvents_ [private] |
Definition at line 62 of file DaqSource.h.
xdata::InfoSpace* edm::DaqSource::mis_ [private] |
Definition at line 86 of file DaqSource.h.
Referenced by publishToXmas().
pthread_mutex_t edm::DaqSource::mutex_ [private] |
Definition at line 76 of file DaqSource.h.
Referenced by closeBackDoor(), DaqSource(), openBackDoor(), and signalWaitingThreadAndBlock().
bool edm::DaqSource::newLumi_ [private] |
Definition at line 72 of file DaqSource.h.
bool edm::DaqSource::newRun_ [private] |
Definition at line 71 of file DaqSource.h.
bool edm::DaqSource::noMoreEvents_ [private] |
Definition at line 70 of file DaqSource.h.
Referenced by getNextItemType().
xdata::UnsignedInteger32* edm::DaqSource::prescaleSetIndex_ [private] |
Definition at line 80 of file DaqSource.h.
Referenced by publish().
DaqBaseReader* edm::DaqSource::reader_ [private] |
Definition at line 61 of file DaqSource.h.
Referenced by DaqSource().
RunNumber_t edm::DaqSource::runNumber_ [private] |
Definition at line 68 of file DaqSource.h.
Referenced by DaqSource().
pthread_mutex_t edm::DaqSource::signal_lock_ [private] |
Definition at line 77 of file DaqSource.h.
Referenced by closeBackDoor(), DaqSource(), openBackDoor(), and signalWaitingThreadAndBlock().
unsigned int edm::DaqSource::thisEventLSid [private] |
Definition at line 88 of file DaqSource.h.
bool edm::DaqSource::useEventCounter_ [private] |
Definition at line 63 of file DaqSource.h.
1.7.3