#include <EvFDaqDirector.h>
Public Types | |
enum | FileStatus { noFile, sameFile, newFile, newLumi, runEnded, runAbort } |
Public Member Functions | |
std::string & | baseRunDir () |
std::string & | buBaseRunDir () |
std::string & | buBaseRunOpenDir () |
void | checkMergeTypePSet (edm::ProcessContext const &pc) |
void | checkTransferSystemPSet (edm::ProcessContext const &pc) |
void | createProcessingNotificationMaybe () const |
void | createRunOpendirMaybe () |
bool | emptyLumisectionMode () const |
EvFDaqDirector (const edm::ParameterSet &pset, edm::ActivityRegistry ®) | |
std::string | findCurrentRunDir () |
std::string | getBoLSFilePathOnFU (const unsigned int ls) const |
std::string | getDatFilePath (const unsigned int ls, std::string const &stream) const |
std::string | getEoLSFilePathOnBU (const unsigned int ls) const |
std::string | getEoLSFilePathOnFU (const unsigned int ls) const |
std::string | getEoRFilePath () const |
std::string | getEoRFilePathOnFU () const |
std::string | getInitFilePath (std::string const &stream) const |
std::string | getInputJsonFilePath (const unsigned int ls, const unsigned int index) const |
std::string | getMergedDatChecksumFilePath (const unsigned int ls, std::string const &stream) const |
std::string | getMergedDatFilePath (const unsigned int ls, std::string const &stream) const |
std::string | getMergedProtocolBufferHistogramFilePath (const unsigned int ls, std::string const &stream) const |
std::string | getMergedRootHistogramFilePath (const unsigned int ls, std::string const &stream) const |
std::string | getOpenDatFilePath (const unsigned int ls, std::string const &stream) const |
std::string | getOpenInitFilePath (std::string const &stream) const |
std::string | getOpenInputJsonFilePath (const unsigned int ls, const unsigned int index) const |
std::string | getOpenOutputJsonFilePath (const unsigned int ls, std::string const &stream) const |
std::string | getOpenProtocolBufferHistogramFilePath (const unsigned int ls, std::string const &stream) const |
std::string | getOpenRawFilePath (const unsigned int ls, const unsigned int index) const |
std::string | getOpenRootHistogramFilePath (const unsigned int ls, std::string const &stream) const |
std::string | getOutputJsonFilePath (const unsigned int ls, std::string const &stream) const |
std::string | getProtocolBufferHistogramFilePath (const unsigned int ls, std::string const &stream) const |
std::string | getRawFilePath (const unsigned int ls, const unsigned int index) const |
std::string | getRootHistogramFilePath (const unsigned int ls, std::string const &stream) const |
unsigned int | getRunNumber () const |
std::string | getRunOpenDirPath () const |
std::string | getStreamDestinations (std::string const &stream) const |
std::vector< int > * | getStreamFileTracker () |
std::string | getStreamMergeType (std::string const &stream, MergeType defaultType) |
void | initRun () |
bool | isSingleStreamThread () |
void | lockFULocal () |
void | lockFULocal2 () |
void | lockInitLock () |
FILE * | maybeCreateAndLockFileHeadForStream (unsigned int ls, std::string &stream) |
bool | microMergeDisabled () const |
bool | outputAdler32Recheck () const |
void | overrideRunNumber (unsigned int run) |
void | postEndRun (edm::GlobalContext const &globalContext) |
void | preallocate (edm::service::SystemBounds const &bounds) |
void | preBeginJob (edm::PathsAndConsumesOfModulesBase const &, edm::ProcessContext const &) |
void | preBeginRun (edm::GlobalContext const &globalContext) |
void | preGlobalEndLumi (edm::GlobalContext const &globalContext) |
void | preSourceEvent (edm::StreamID const &streamID) |
int | readLastLSEntry (std::string const &file) |
void | removeFile (unsigned int ls, unsigned int index) |
void | removeFile (std::string) |
void | setDeleteTracking (std::mutex *fileDeleteLock, std::list< std::pair< int, InputFile * >> *filesToDelete) |
void | setFMS (evf::FastMonitoringService *fms) |
void | tryInitializeFuLockFile () |
void | unlockAndCloseMergeStream () |
void | unlockFULocal () |
void | unlockFULocal2 () |
void | unlockInitLock () |
void | updateFileIndex (int const &fileIndex) |
FileStatus | updateFuLock (unsigned int &ls, std::string &nextFile, uint32_t &fsize, uint64_t &lockWaitTime) |
~EvFDaqDirector () | |
Static Public Member Functions | |
static void | fillDescriptions (edm::ConfigurationDescriptions &descriptions) |
Private Member Functions | |
bool | bumpFile (unsigned int &ls, unsigned int &index, std::string &nextFile, uint32_t &fsize, int maxLS) |
std::string | eolsFileName (const unsigned int ls) const |
std::string | eorFileName () const |
int | getNFilesFromEoLS (std::string BUEoLSFile) |
std::string | initFileName (std::string const &stream) const |
std::string | inputFileNameStem (const unsigned int ls, const unsigned int index) const |
std::string | mergedFileNameStem (const unsigned int ls, std::string const &stream) const |
void | openFULockfileStream (std::string &fuLockFilePath, bool create) |
std::string | outputFileNameStem (const unsigned int ls, std::string const &stream) const |
Static Private Attributes | |
static const std::vector < std::string > | MergeTypeNames_ = {"","DAT","PB","JSNDATA"} |
Definition at line 54 of file EvFDaqDirector.h.
Enumerator | |
---|---|
noFile | |
sameFile | |
newFile | |
newLumi | |
runEnded | |
runAbort |
Definition at line 58 of file EvFDaqDirector.h.
|
explicit |
Definition at line 47 of file EvFDaqDirector.cc.
References emptyLumisectionMode_, fuLockPollInterval_, hostname_, microMergeDisabled_, postEndRun(), preallocate(), preBeginJob(), preBeginRun(), preGlobalEndLumi(), preSourceEvent(), AlCaHLTBitMon_QueryRunRegistry::string, edm::ActivityRegistry::watchPostGlobalEndRun(), edm::ActivityRegistry::watchPreallocate(), edm::ActivityRegistry::watchPreBeginJob(), edm::ActivityRegistry::watchPreGlobalBeginRun(), edm::ActivityRegistry::watchPreGlobalEndLumi(), and edm::ActivityRegistry::watchPreSourceEvent().
evf::EvFDaqDirector::~EvFDaqDirector | ( | ) |
Definition at line 257 of file EvFDaqDirector.cc.
References fulocal_rwlock_fd2_, fulocal_rwlock_fd_, unlockFULocal(), and unlockFULocal2().
|
inline |
|
inline |
|
inline |
|
private |
Definition at line 718 of file EvFDaqDirector.cc.
References evf::FastMonitoringService::accumulateFileSize(), fms_, getEoLSFilePathOnBU(), getInputJsonFilePath(), getNFilesFromEoLS(), cmsHarvester::index, eostools::ls(), previousFileSize_, contentValuesCheck::ss, and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by updateFuLock().
void evf::EvFDaqDirector::checkMergeTypePSet | ( | edm::ProcessContext const & | pc | ) |
Definition at line 1007 of file EvFDaqDirector.cc.
References edm::ParameterSet::existsAs(), edm::ParameterSet::getParameterSet(), edm::getParameterSet(), mergeTypeMap_, mergeTypePset_, edm::ProcessContext::parameterSetID(), unpackData-CaloStage2::pname, and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by preBeginJob().
void evf::EvFDaqDirector::checkTransferSystemPSet | ( | edm::ProcessContext const & | pc | ) |
Definition at line 904 of file EvFDaqDirector.cc.
References Json::Value::append(), Json::arrayValue, alignCSCRings::dest, myMessageLogger_cff::destinations, Exception, edm::ParameterSet::existsAs(), edm::ParameterSet::getParameter(), edm::ParameterSet::getParameterSet(), edm::getParameterSet(), alignBH_cfg::mode, edm::ProcessContext::parameterSetID(), requireTSPSet_, and transferSystemJson_.
Referenced by preBeginJob().
void evf::EvFDaqDirector::createProcessingNotificationMaybe | ( | ) | const |
Definition at line 1035 of file EvFDaqDirector.cc.
References run_dir_, and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by FedRawDataInputSource::checkNextEvent().
void evf::EvFDaqDirector::createRunOpendirMaybe | ( | ) |
Definition at line 876 of file EvFDaqDirector.cc.
References getRunOpenDirPath(), LogDebug, and fed_dqm_sourceclient-live_cfg::path.
Referenced by initRun().
|
inline |
Definition at line 131 of file EvFDaqDirector.h.
References emptyLumisectionMode_.
Referenced by FedRawDataInputSource::checkNextEvent().
|
private |
|
private |
|
static |
Definition at line 283 of file EvFDaqDirector.cc.
References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addUntracked(), edm::ParameterSetDescription::setAllowAnything(), edm::ParameterSetDescription::setComment(), and AlCaHLTBitMon_QueryRunRegistry::string.
|
inline |
Definition at line 76 of file EvFDaqDirector.h.
References dirManager_, evf::DirManager::findRunDir(), and run_.
std::string evf::EvFDaqDirector::getBoLSFilePathOnFU | ( | const unsigned int | ls | ) | const |
Definition at line 458 of file EvFDaqDirector.cc.
References fffnaming::bolsFileName(), run_, and run_dir_.
Referenced by FedRawDataInputSource::createBoLSFile().
std::string evf::EvFDaqDirector::getDatFilePath | ( | const unsigned int | ls, |
std::string const & | stream | ||
) | const |
Definition at line 394 of file EvFDaqDirector.cc.
References run_, run_dir_, and fffnaming::streamerDataFileNameWithPid().
std::string evf::EvFDaqDirector::getEoLSFilePathOnBU | ( | const unsigned int | ls | ) | const |
Definition at line 450 of file EvFDaqDirector.cc.
References bu_run_dir_, fffnaming::eolsFileName(), and run_.
Referenced by bumpFile(), and FedRawDataInputSource::checkNextEvent().
std::string evf::EvFDaqDirector::getEoLSFilePathOnFU | ( | const unsigned int | ls | ) | const |
Definition at line 454 of file EvFDaqDirector.cc.
References fffnaming::eolsFileName(), run_, and run_dir_.
Referenced by FedRawDataInputSource::checkNextEvent(), FedRawDataInputSource::maybeOpenNewLumiSection(), and updateFuLock().
std::string evf::EvFDaqDirector::getEoRFilePath | ( | ) | const |
Definition at line 462 of file EvFDaqDirector.cc.
References bu_run_dir_, fffnaming::eorFileName(), and run_.
Referenced by updateFuLock().
std::string evf::EvFDaqDirector::getEoRFilePathOnFU | ( | ) | const |
Definition at line 467 of file EvFDaqDirector.cc.
References fffnaming::eorFileName(), run_, and run_dir_.
Referenced by FedRawDataInputSource::checkNextEvent().
std::string evf::EvFDaqDirector::getInitFilePath | ( | std::string const & | stream | ) | const |
Definition at line 422 of file EvFDaqDirector.cc.
References fffnaming::initFileNameWithPid(), run_, and run_dir_.
Referenced by DQMFileSaver::globalBeginRun().
std::string evf::EvFDaqDirector::getInputJsonFilePath | ( | const unsigned int | ls, |
const unsigned int | index | ||
) | const |
Definition at line 377 of file EvFDaqDirector.cc.
References bu_run_dir_, fffnaming::inputJsonFileName(), and run_.
Referenced by bumpFile().
std::string evf::EvFDaqDirector::getMergedDatChecksumFilePath | ( | const unsigned int | ls, |
std::string const & | stream | ||
) | const |
Definition at line 414 of file EvFDaqDirector.cc.
References hostname_, run_, run_dir_, and fffnaming::streamerDataChecksumFileNameWithInstance().
std::string evf::EvFDaqDirector::getMergedDatFilePath | ( | const unsigned int | ls, |
std::string const & | stream | ||
) | const |
Definition at line 410 of file EvFDaqDirector.cc.
References hostname_, run_, run_dir_, and fffnaming::streamerDataFileNameWithInstance().
Referenced by maybeCreateAndLockFileHeadForStream().
std::string evf::EvFDaqDirector::getMergedProtocolBufferHistogramFilePath | ( | const unsigned int | ls, |
std::string const & | stream | ||
) | const |
Definition at line 434 of file EvFDaqDirector.cc.
References hostname_, fffnaming::protocolBufferHistogramFileNameWithInstance(), run_, and run_dir_.
std::string evf::EvFDaqDirector::getMergedRootHistogramFilePath | ( | const unsigned int | ls, |
std::string const & | stream | ||
) | const |
Definition at line 446 of file EvFDaqDirector.cc.
References hostname_, fffnaming::rootHistogramFileNameWithInstance(), run_, and run_dir_.
|
private |
Definition at line 657 of file EvFDaqDirector.cc.
References bu_run_dir_, data, def, jsoncollector::DataPoint::deserialize(), reco::dp, eolsNFilesIndex_, jsoncollector::DataPoint::getData(), jsoncollector::DataPoint::getDefinition(), jsoncollector::DataPointDefinition::getNames(), i, Json::Reader::parse(), readEolsDefinition_, matplotRender::reader, and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by bumpFile().
std::string evf::EvFDaqDirector::getOpenDatFilePath | ( | const unsigned int | ls, |
std::string const & | stream | ||
) | const |
Definition at line 398 of file EvFDaqDirector.cc.
References run_, run_dir_, and fffnaming::streamerDataFileNameWithPid().
std::string evf::EvFDaqDirector::getOpenInitFilePath | ( | std::string const & | stream | ) | const |
Definition at line 418 of file EvFDaqDirector.cc.
References fffnaming::initFileNameWithPid(), run_, and run_dir_.
std::string evf::EvFDaqDirector::getOpenInputJsonFilePath | ( | const unsigned int | ls, |
const unsigned int | index | ||
) | const |
Definition at line 390 of file EvFDaqDirector.cc.
References bu_run_dir_, fffnaming::inputJsonFileName(), and run_.
std::string evf::EvFDaqDirector::getOpenOutputJsonFilePath | ( | const unsigned int | ls, |
std::string const & | stream | ||
) | const |
Definition at line 402 of file EvFDaqDirector.cc.
References run_, run_dir_, and fffnaming::streamerJsonFileNameWithPid().
std::string evf::EvFDaqDirector::getOpenProtocolBufferHistogramFilePath | ( | const unsigned int | ls, |
std::string const & | stream | ||
) | const |
Definition at line 426 of file EvFDaqDirector.cc.
References fffnaming::protocolBufferHistogramFileNameWithPid(), run_, and run_dir_.
std::string evf::EvFDaqDirector::getOpenRawFilePath | ( | const unsigned int | ls, |
const unsigned int | index | ||
) | const |
Definition at line 386 of file EvFDaqDirector.cc.
References bu_run_dir_, fffnaming::inputRawFileName(), and run_.
std::string evf::EvFDaqDirector::getOpenRootHistogramFilePath | ( | const unsigned int | ls, |
std::string const & | stream | ||
) | const |
Definition at line 438 of file EvFDaqDirector.cc.
References fffnaming::rootHistogramFileNameWithPid(), run_, and run_dir_.
std::string evf::EvFDaqDirector::getOutputJsonFilePath | ( | const unsigned int | ls, |
std::string const & | stream | ||
) | const |
Definition at line 406 of file EvFDaqDirector.cc.
References run_, run_dir_, and fffnaming::streamerJsonFileNameWithPid().
std::string evf::EvFDaqDirector::getProtocolBufferHistogramFilePath | ( | const unsigned int | ls, |
std::string const & | stream | ||
) | const |
Definition at line 430 of file EvFDaqDirector.cc.
References fffnaming::protocolBufferHistogramFileNameWithPid(), run_, and run_dir_.
std::string evf::EvFDaqDirector::getRawFilePath | ( | const unsigned int | ls, |
const unsigned int | index | ||
) | const |
Definition at line 382 of file EvFDaqDirector.cc.
References bu_run_dir_, fffnaming::inputRawFileName(), and run_.
Referenced by removeFile().
std::string evf::EvFDaqDirector::getRootHistogramFilePath | ( | const unsigned int | ls, |
std::string const & | stream | ||
) | const |
Definition at line 442 of file EvFDaqDirector.cc.
References fffnaming::rootHistogramFileNameWithPid(), run_, and run_dir_.
|
inline |
|
inline |
Definition at line 100 of file EvFDaqDirector.h.
References run_dir_.
Referenced by createRunOpendirMaybe(), and initRun().
std::string evf::EvFDaqDirector::getStreamDestinations | ( | std::string const & | stream | ) | const |
Definition at line 960 of file EvFDaqDirector.cc.
References Json::Value::begin(), Json::Value::end(), Exception, visualization-live-secondInstance_cfg::msg, requireTSPSet_, runTheMatrix::ret, selectedTransferMode_, AlCaHLTBitMon_QueryRunRegistry::string, and transferSystemJson_.
|
inline |
Definition at line 114 of file EvFDaqDirector.h.
References streamFileTracker_.
Referenced by FedRawDataInputSource::getNextEvent().
std::string evf::EvFDaqDirector::getStreamMergeType | ( | std::string const & | stream, |
MergeType | defaultType | ||
) |
Definition at line 1022 of file EvFDaqDirector.cc.
References assert(), mergeTypeMap_, MergeTypeNames_, and AlCaHLTBitMon_QueryRunRegistry::string.
|
private |
void evf::EvFDaqDirector::initRun | ( | void | ) |
Definition at line 130 of file EvFDaqDirector.cc.
References base_dir_, bu_base_dir_, bu_run_dir_, bu_run_open_dir_, bu_w_lock_stream, bu_writelock_fd_, eostools::chmod(), createRunOpendirMaybe(), directorBu_, Exception, fu_readwritelock_fd_, fu_rw_lock_stream, fulocal_rwlock_fd2_, fulocal_rwlock_fd_, getRunOpenDirPath(), hltSourceDirectory_, init_lock_, eostools::mkdir(), NULL, openFULockfileStream(), run_, run_dir_, run_string_, contentValuesCheck::ss, stopFilePath_, AlCaHLTBitMon_QueryRunRegistry::string, and tryInitializeFuLockFile().
Referenced by preallocate().
|
private |
|
inline |
Definition at line 115 of file EvFDaqDirector.h.
References nStreams_, and nThreads_.
Referenced by FedRawDataInputSource::getNextEvent().
void evf::EvFDaqDirector::lockFULocal | ( | ) |
Definition at line 854 of file EvFDaqDirector.cc.
References fulocal_rwlock_fd_.
Referenced by updateFuLock().
void evf::EvFDaqDirector::lockFULocal2 | ( | ) |
Definition at line 865 of file EvFDaqDirector.cc.
References fulocal_rwlock_fd2_.
Referenced by FedRawDataInputSource::checkNextEvent(), and FedRawDataInputSource::maybeOpenNewLumiSection().
void evf::EvFDaqDirector::lockInitLock | ( | ) |
FILE * evf::EvFDaqDirector::maybeCreateAndLockFileHeadForStream | ( | unsigned int | ls, |
std::string & | stream | ||
) |
Definition at line 826 of file EvFDaqDirector.cc.
References data_readwrite_fd_, data_rw_flk, data_rw_stream, getMergedDatFilePath(), and LogDebug.
|
private |
|
inline |
|
private |
Definition at line 807 of file EvFDaqDirector.cc.
References eostools::chmod(), fu_readwritelock_fd_, fu_rw_lock_stream, and LogDebug.
Referenced by initRun().
|
inline |
Definition at line 101 of file EvFDaqDirector.h.
References outputAdler32Recheck_.
|
private |
|
inline |
void evf::EvFDaqDirector::postEndRun | ( | edm::GlobalContext const & | globalContext | ) |
Definition at line 319 of file EvFDaqDirector.cc.
References bu_readlock_fd_, bu_run_dir_, bu_writelock_fd_, directorBu_, lut2db_cfg::filename, removeFile(), and AlCaHLTBitMon_QueryRunRegistry::string.
Referenced by EvFDaqDirector().
void evf::EvFDaqDirector::preallocate | ( | edm::service::SystemBounds const & | bounds | ) |
Definition at line 272 of file EvFDaqDirector.cc.
References i, initRun(), edm::service::SystemBounds::maxNumberOfStreams(), edm::service::SystemBounds::maxNumberOfThreads(), nStreams_, nThreads_, and streamFileTracker_.
Referenced by EvFDaqDirector().
void evf::EvFDaqDirector::preBeginJob | ( | edm::PathsAndConsumesOfModulesBase const & | , |
edm::ProcessContext const & | pc | ||
) |
Definition at line 301 of file EvFDaqDirector.cc.
References checkMergeTypePSet(), and checkTransferSystemPSet().
Referenced by EvFDaqDirector().
void evf::EvFDaqDirector::preBeginRun | ( | edm::GlobalContext const & | globalContext | ) |
Definition at line 307 of file EvFDaqDirector.cc.
References dirManager_, evf::DirManager::findHighestRunDir(), and run_dir_.
Referenced by EvFDaqDirector().
void evf::EvFDaqDirector::preGlobalEndLumi | ( | edm::GlobalContext const & | globalContext | ) |
Definition at line 328 of file EvFDaqDirector.cc.
References cppFunctionSkipper::exception, fileDeleteLockPtr_, filesToDeletePtr_, LogDebug, eostools::ls(), edm::LuminosityBlockID::luminosityBlock(), edm::GlobalContext::luminosityBlockID(), fed_dqm_sourceclient-live_cfg::path, and MatrixUtil::remove().
Referenced by EvFDaqDirector().
|
inline |
Definition at line 372 of file EvFDaqDirector.cc.
References currentFileIndex_, and streamFileTracker_.
Referenced by EvFDaqDirector().
int evf::EvFDaqDirector::readLastLSEntry | ( | std::string const & | file | ) |
Definition at line 887 of file EvFDaqDirector.cc.
References Json::Value::asInt(), mergeVDriftHistosByStation::file, Json::Value::get(), Json::Reader::parse(), matplotRender::reader, and runTheMatrix::ret.
Referenced by updateFuLock().
void evf::EvFDaqDirector::removeFile | ( | unsigned int | ls, |
unsigned int | index | ||
) |
Definition at line 478 of file EvFDaqDirector.cc.
References getRawFilePath().
Referenced by postEndRun().
void evf::EvFDaqDirector::removeFile | ( | std::string | filename | ) |
Definition at line 471 of file EvFDaqDirector.cc.
|
inline |
Definition at line 123 of file EvFDaqDirector.h.
References fileDeleteLockPtr_, and filesToDeletePtr_.
Referenced by FedRawDataInputSource::FedRawDataInputSource().
|
inline |
Definition at line 112 of file EvFDaqDirector.h.
References fms_.
Referenced by FedRawDataInputSource::FedRawDataInputSource().
void evf::EvFDaqDirector::tryInitializeFuLockFile | ( | ) |
Definition at line 796 of file EvFDaqDirector.cc.
References fu_rw_lock_stream, and getHLTprescales::readIndex().
Referenced by initRun().
void evf::EvFDaqDirector::unlockAndCloseMergeStream | ( | ) |
Definition at line 840 of file EvFDaqDirector.cc.
References data_readwrite_fd_, data_rw_fulk, and data_rw_stream.
void evf::EvFDaqDirector::unlockFULocal | ( | ) |
Definition at line 859 of file EvFDaqDirector.cc.
References fulocal_rwlock_fd_.
Referenced by FedRawDataInputSource::grabNextJsonFile(), and ~EvFDaqDirector().
void evf::EvFDaqDirector::unlockFULocal2 | ( | ) |
Definition at line 870 of file EvFDaqDirector.cc.
References fulocal_rwlock_fd2_.
Referenced by FedRawDataInputSource::checkNextEvent(), FedRawDataInputSource::maybeOpenNewLumiSection(), and ~EvFDaqDirector().
void evf::EvFDaqDirector::unlockInitLock | ( | ) |
|
inline |
Definition at line 113 of file EvFDaqDirector.h.
References currentFileIndex_.
Referenced by FedRawDataInputSource::getNextEvent().
EvFDaqDirector::FileStatus evf::EvFDaqDirector::updateFuLock | ( | unsigned int & | ls, |
std::string & | nextFile, | ||
uint32_t & | fsize, | ||
uint64_t & | lockWaitTime | ||
) |
Definition at line 482 of file EvFDaqDirector.cc.
References bu_run_dir_, bumpFile(), DDVectorGetter::check(), Exception, fu_readwritelock_fd_, fu_rw_flk, fu_rw_fulk, fu_rw_lock_stream, fuLockPollInterval_, getEoLSFilePathOnFU(), getEoRFilePath(), lockFULocal(), LogDebug, eostools::ls(), newFile, noFile, getHLTprescales::readIndex(), readLastLSEntry(), runEnded, stop_ls_override_, and stopFilePath_.
Referenced by FedRawDataInputSource::readSupervisor().
|
private |
Definition at line 148 of file EvFDaqDirector.h.
Referenced by initRun().
|
private |
Definition at line 149 of file EvFDaqDirector.h.
Referenced by initRun().
|
private |
Definition at line 186 of file EvFDaqDirector.h.
|
private |
Definition at line 188 of file EvFDaqDirector.h.
|
private |
Definition at line 175 of file EvFDaqDirector.h.
|
private |
Definition at line 167 of file EvFDaqDirector.h.
Referenced by postEndRun().
|
private |
Definition at line 164 of file EvFDaqDirector.h.
Referenced by buBaseRunDir(), getEoLSFilePathOnBU(), getEoRFilePath(), getInputJsonFilePath(), getNFilesFromEoLS(), getOpenInputJsonFilePath(), getOpenRawFilePath(), getRawFilePath(), initRun(), postEndRun(), and updateFuLock().
|
private |
Definition at line 165 of file EvFDaqDirector.h.
Referenced by buBaseRunOpenDir(), and initRun().
|
private |
Definition at line 178 of file EvFDaqDirector.h.
|
private |
Definition at line 185 of file EvFDaqDirector.h.
|
private |
Definition at line 187 of file EvFDaqDirector.h.
|
private |
Definition at line 174 of file EvFDaqDirector.h.
Referenced by initRun().
|
private |
Definition at line 177 of file EvFDaqDirector.h.
|
private |
Definition at line 168 of file EvFDaqDirector.h.
Referenced by initRun(), and postEndRun().
|
private |
Definition at line 200 of file EvFDaqDirector.h.
Referenced by preSourceEvent(), and updateFileIndex().
|
private |
Definition at line 170 of file EvFDaqDirector.h.
Referenced by maybeCreateAndLockFileHeadForStream(), and unlockAndCloseMergeStream().
|
private |
Definition at line 191 of file EvFDaqDirector.h.
Referenced by maybeCreateAndLockFileHeadForStream().
|
private |
Definition at line 192 of file EvFDaqDirector.h.
Referenced by unlockAndCloseMergeStream().
|
private |
Definition at line 179 of file EvFDaqDirector.h.
Referenced by maybeCreateAndLockFileHeadForStream(), and unlockAndCloseMergeStream().
|
private |
Definition at line 150 of file EvFDaqDirector.h.
Referenced by initRun(), and postEndRun().
|
private |
Definition at line 181 of file EvFDaqDirector.h.
Referenced by findCurrentRunDir(), and preBeginRun().
|
private |
Definition at line 157 of file EvFDaqDirector.h.
Referenced by emptyLumisectionMode(), and EvFDaqDirector().
|
private |
Definition at line 211 of file EvFDaqDirector.h.
Referenced by getNFilesFromEoLS().
|
private |
Definition at line 202 of file EvFDaqDirector.h.
Referenced by preGlobalEndLumi(), and setDeleteTracking().
Definition at line 203 of file EvFDaqDirector.h.
Referenced by preGlobalEndLumi(), and setDeleteTracking().
|
private |
Definition at line 198 of file EvFDaqDirector.h.
Referenced by bumpFile(), and setFMS().
|
private |
Definition at line 169 of file EvFDaqDirector.h.
Referenced by initRun(), openFULockfileStream(), and updateFuLock().
|
private |
Definition at line 189 of file EvFDaqDirector.h.
Referenced by updateFuLock().
|
private |
Definition at line 190 of file EvFDaqDirector.h.
Referenced by updateFuLock().
|
private |
Definition at line 176 of file EvFDaqDirector.h.
Referenced by initRun(), openFULockfileStream(), tryInitializeFuLockFile(), and updateFuLock().
|
private |
Definition at line 172 of file EvFDaqDirector.h.
Referenced by initRun(), lockFULocal2(), unlockFULocal2(), and ~EvFDaqDirector().
|
private |
Definition at line 171 of file EvFDaqDirector.h.
Referenced by initRun(), lockFULocal(), unlockFULocal(), and ~EvFDaqDirector().
|
private |
Definition at line 156 of file EvFDaqDirector.h.
Referenced by EvFDaqDirector(), and updateFuLock().
|
private |
Definition at line 155 of file EvFDaqDirector.h.
Referenced by initRun().
|
private |
Definition at line 161 of file EvFDaqDirector.h.
Referenced by EvFDaqDirector(), getMergedDatChecksumFilePath(), getMergedDatFilePath(), getMergedProtocolBufferHistogramFilePath(), and getMergedRootHistogramFilePath().
|
private |
Definition at line 205 of file EvFDaqDirector.h.
Referenced by initRun(), lockInitLock(), and unlockInitLock().
|
private |
Definition at line 216 of file EvFDaqDirector.h.
Referenced by checkMergeTypePSet(), and getStreamMergeType().
|
staticprivate |
Definition at line 219 of file EvFDaqDirector.h.
Referenced by getStreamMergeType().
|
private |
Definition at line 159 of file EvFDaqDirector.h.
Referenced by checkMergeTypePSet().
|
private |
Definition at line 158 of file EvFDaqDirector.h.
Referenced by EvFDaqDirector(), and microMergeDisabled().
|
private |
Definition at line 207 of file EvFDaqDirector.h.
Referenced by isSingleStreamThread(), and preallocate().
|
private |
Definition at line 208 of file EvFDaqDirector.h.
Referenced by isSingleStreamThread(), and preallocate().
|
private |
Definition at line 152 of file EvFDaqDirector.h.
Referenced by outputAdler32Recheck().
|
private |
Definition at line 183 of file EvFDaqDirector.h.
Referenced by bumpFile().
|
private |
Definition at line 210 of file EvFDaqDirector.h.
Referenced by getNFilesFromEoLS().
|
private |
Definition at line 153 of file EvFDaqDirector.h.
Referenced by checkTransferSystemPSet(), and getStreamDestinations().
|
private |
Definition at line 151 of file EvFDaqDirector.h.
Referenced by findCurrentRunDir(), getBoLSFilePathOnFU(), getDatFilePath(), getEoLSFilePathOnBU(), getEoLSFilePathOnFU(), getEoRFilePath(), getEoRFilePathOnFU(), getInitFilePath(), getInputJsonFilePath(), getMergedDatChecksumFilePath(), getMergedDatFilePath(), getMergedProtocolBufferHistogramFilePath(), getMergedRootHistogramFilePath(), getOpenDatFilePath(), getOpenInitFilePath(), getOpenInputJsonFilePath(), getOpenOutputJsonFilePath(), getOpenProtocolBufferHistogramFilePath(), getOpenRawFilePath(), getOpenRootHistogramFilePath(), getOutputJsonFilePath(), getProtocolBufferHistogramFilePath(), getRawFilePath(), getRootHistogramFilePath(), getRunNumber(), initRun(), and overrideRunNumber().
|
private |
Definition at line 163 of file EvFDaqDirector.h.
Referenced by baseRunDir(), createProcessingNotificationMaybe(), getBoLSFilePathOnFU(), getDatFilePath(), getEoLSFilePathOnFU(), getEoRFilePathOnFU(), getInitFilePath(), getMergedDatChecksumFilePath(), getMergedDatFilePath(), getMergedProtocolBufferHistogramFilePath(), getMergedRootHistogramFilePath(), getOpenDatFilePath(), getOpenInitFilePath(), getOpenOutputJsonFilePath(), getOpenProtocolBufferHistogramFilePath(), getOpenRootHistogramFilePath(), getOutputJsonFilePath(), getProtocolBufferHistogramFilePath(), getRootHistogramFilePath(), getRunOpenDirPath(), initRun(), and preBeginRun().
|
private |
Definition at line 162 of file EvFDaqDirector.h.
Referenced by initRun().
|
private |
Definition at line 154 of file EvFDaqDirector.h.
Referenced by getStreamDestinations().
|
private |
Definition at line 213 of file EvFDaqDirector.h.
Referenced by updateFuLock().
|
private |
Definition at line 212 of file EvFDaqDirector.h.
Referenced by initRun(), and updateFuLock().
|
private |
Definition at line 199 of file EvFDaqDirector.h.
Referenced by getStreamFileTracker(), preallocate(), and preSourceEvent().
|
private |
Definition at line 215 of file EvFDaqDirector.h.
Referenced by checkTransferSystemPSet(), and getStreamDestinations().