base_dir_ | evf::EvFDaqDirector | private |
baseRunDir() | evf::EvFDaqDirector | inline |
bu_base_dir_ | evf::EvFDaqDirector | private |
bu_base_dirs_all_ | evf::EvFDaqDirector | private |
bu_base_dirs_nSources_ | evf::EvFDaqDirector | private |
bu_r_flk | evf::EvFDaqDirector | private |
bu_r_fulk | evf::EvFDaqDirector | private |
bu_r_lock_stream | evf::EvFDaqDirector | private |
bu_readlock_fd_ | evf::EvFDaqDirector | private |
bu_run_dir_ | evf::EvFDaqDirector | private |
bu_run_open_dir_ | evf::EvFDaqDirector | private |
bu_t_monitor_stream | evf::EvFDaqDirector | private |
bu_w_flk | evf::EvFDaqDirector | private |
bu_w_fulk | evf::EvFDaqDirector | private |
bu_w_lock_stream | evf::EvFDaqDirector | private |
bu_w_monitor_stream | evf::EvFDaqDirector | private |
bu_writelock_fd_ | evf::EvFDaqDirector | private |
buBaseRunDir() | evf::EvFDaqDirector | inline |
buBaseRunOpenDir() | evf::EvFDaqDirector | inline |
bumpFile(unsigned int &ls, unsigned int &index, std::string &nextFile, uint32_t &fsize, uint16_t &rawHeaderSize, int maxLS, bool &setExceptionState) | evf::EvFDaqDirector | private |
checkFileRead(char *buf, int infile, std::size_t buf_sz, std::string const &path) | evf::EvFDaqDirector | privatestatic |
contactFileBroker(unsigned int &serverHttpStatus, bool &serverState, uint32_t &serverLS, uint32_t &closedServerLS, std::string &nextFileJson, std::string &nextFileRaw, bool &rawHeader, int maxLS) | evf::EvFDaqDirector | |
createBoLSFile(const uint32_t lumiSection, bool checkIfExists) const | evf::EvFDaqDirector | |
createLumiSectionFiles(const uint32_t lumiSection, const uint32_t currentLumiSection, bool doCreateBoLS, bool doCreateEoLS) | evf::EvFDaqDirector | |
createProcessingNotificationMaybe() const | evf::EvFDaqDirector | |
createRunOpendirMaybe() | evf::EvFDaqDirector | |
directorBU_ | evf::EvFDaqDirector | private |
dirManager_ | evf::EvFDaqDirector | private |
discard_ls_filestem_ | evf::EvFDaqDirector | private |
dpd_ | evf::EvFDaqDirector | private |
endpoint_iterator_ | evf::EvFDaqDirector | private |
eolsFileName(const unsigned int ls) const | evf::EvFDaqDirector | private |
eolsNFilesIndex_ | evf::EvFDaqDirector | private |
eorFileName() const | evf::EvFDaqDirector | private |
EvFDaqDirector(const edm::ParameterSet &pset, edm::ActivityRegistry ®) | evf::EvFDaqDirector | explicit |
fileBrokerHost_ | evf::EvFDaqDirector | private |
fileBrokerHostFromCfg_ | evf::EvFDaqDirector | private |
fileBrokerKeepAlive_ | evf::EvFDaqDirector | private |
fileBrokerPort_ | evf::EvFDaqDirector | private |
fileBrokerUseLocalLock_ | evf::EvFDaqDirector | private |
fileDeleteLockPtr_ | evf::EvFDaqDirector | private |
FileStatus enum name | evf::EvFDaqDirector | |
filesToDeletePtr_ | evf::EvFDaqDirector | private |
fillDescriptions(edm::ConfigurationDescriptions &descriptions) | evf::EvFDaqDirector | static |
findCurrentRunDir() | evf::EvFDaqDirector | inline |
fms_ | evf::EvFDaqDirector | private |
fu_readwritelock_fd_ | evf::EvFDaqDirector | private |
fu_rw_flk | evf::EvFDaqDirector | private |
fu_rw_fulk | evf::EvFDaqDirector | private |
fu_rw_lock_stream | evf::EvFDaqDirector | private |
fulocal_rwlock_fd2_ | evf::EvFDaqDirector | private |
fulocal_rwlock_fd_ | evf::EvFDaqDirector | private |
fulockfile_ | evf::EvFDaqDirector | private |
fuLockPollInterval_ | evf::EvFDaqDirector | private |
getBoLSFilePathOnFU(const unsigned int ls) const | evf::EvFDaqDirector | |
getBUBaseDirs() const | evf::EvFDaqDirector | inline |
getBUBaseDirsNSources() const | evf::EvFDaqDirector | inline |
getDatFilePath(const unsigned int ls, std::string const &stream) const | evf::EvFDaqDirector | |
getEoLSFilePathOnBU(const unsigned int ls) const | evf::EvFDaqDirector | |
getEoLSFilePathOnFU(const unsigned int ls) const | evf::EvFDaqDirector | |
getEoRFileName() const | evf::EvFDaqDirector | |
getEoRFilePath() const | evf::EvFDaqDirector | |
getEoRFilePathOnFU() const | evf::EvFDaqDirector | |
getFFFParamsFilePathOnBU() const | evf::EvFDaqDirector | |
getInitFilePath(std::string const &stream) const | evf::EvFDaqDirector | |
getInitTempFilePath(std::string const &stream) const | evf::EvFDaqDirector | |
getInputJsonFilePath(const unsigned int ls, const unsigned int index) const | evf::EvFDaqDirector | |
getLumisectionToStart() const | evf::EvFDaqDirector | |
getMergedDatChecksumFilePath(const unsigned int ls, std::string const &stream) const | evf::EvFDaqDirector | |
getMergedDatFilePath(const unsigned int ls, std::string const &stream) const | evf::EvFDaqDirector | |
getMergedProtocolBufferHistogramFilePath(const unsigned int ls, std::string const &stream) const | evf::EvFDaqDirector | |
getMergedRootHistogramFilePath(const unsigned int ls, std::string const &stream) const | evf::EvFDaqDirector | |
getNextFromFileBroker(const unsigned int currentLumiSection, unsigned int &ls, std::string &nextFile, int &rawFd, uint16_t &rawHeaderSize, int32_t &serverEventsInNewFile_, int64_t &fileSize, uint64_t &thisLockWaitTimeUs, bool requireHeader=true) | evf::EvFDaqDirector | |
getNFilesFromEoLS(std::string BUEoLSFile) | evf::EvFDaqDirector | private |
getOpenDatFilePath(const unsigned int ls, std::string const &stream) const | evf::EvFDaqDirector | |
getOpenInitFilePath(std::string const &stream) const | evf::EvFDaqDirector | |
getOpenInputJsonFilePath(const unsigned int ls, const unsigned int index) const | evf::EvFDaqDirector | |
getOpenOutputJsonFilePath(const unsigned int ls, std::string const &stream) const | evf::EvFDaqDirector | |
getOpenProtocolBufferHistogramFilePath(const unsigned int ls, std::string const &stream) const | evf::EvFDaqDirector | |
getOpenRawFilePath(const unsigned int ls, const unsigned int index) const | evf::EvFDaqDirector | |
getOpenRootHistogramFilePath(const unsigned int ls, std::string const &stream) const | evf::EvFDaqDirector | |
getOutputJsonFilePath(const unsigned int ls, std::string const &stream) const | evf::EvFDaqDirector | |
getProtocolBufferHistogramFilePath(const unsigned int ls, std::string const &stream) const | evf::EvFDaqDirector | |
getRawFilePath(const unsigned int ls, const unsigned int index) const | evf::EvFDaqDirector | |
getRootHistogramFilePath(const unsigned int ls, std::string const &stream) const | evf::EvFDaqDirector | |
getRunNumber() const | evf::EvFDaqDirector | inline |
getRunOpenDirPath() const | evf::EvFDaqDirector | inline |
getStartLumisectionFromEnv() const | evf::EvFDaqDirector | inline |
getStreamDestinations(std::string const &) const | evf::EvFDaqDirector | inline |
getStreamMergeType(std::string const &, MergeType defaultType) const | evf::EvFDaqDirector | inline |
grabNextJsonFile(std::string const &jsonSourcePath, std::string const &rawSourcePath, int64_t &fileSizeFromJson, bool &fileFound) | evf::EvFDaqDirector | |
grabNextJsonFileAndUnlock(std::filesystem::path const &jsonSourcePath) | evf::EvFDaqDirector | |
grabNextJsonFromRaw(std::string const &rawSourcePath, int &rawFd, uint16_t &rawHeaderSize, int64_t &fileSizeFromHeader, bool &fileFound, uint32_t serverLS, bool closeFile, bool requireHeader=true) | evf::EvFDaqDirector | |
hltSourceDirectory_ | evf::EvFDaqDirector | private |
hostname_ | evf::EvFDaqDirector | private |
init_lock_ | evf::EvFDaqDirector | private |
initFileName(std::string const &stream) const | evf::EvFDaqDirector | private |
initRun() | evf::EvFDaqDirector | |
input_throttled_file_ | evf::EvFDaqDirector | private |
inputFileNameStem(const unsigned int ls, const unsigned int index) const | evf::EvFDaqDirector | private |
inputThrottled() | evf::EvFDaqDirector | |
io_service_ | evf::EvFDaqDirector | private |
isSingleStreamThread() | evf::EvFDaqDirector | inline |
lockFULocal() | evf::EvFDaqDirector | |
lockFULocal2() | evf::EvFDaqDirector | |
lockInitLock() | evf::EvFDaqDirector | |
lumisectionDiscarded(unsigned int ls) | evf::EvFDaqDirector | |
make_flock(short type, short whence, off_t start, off_t len, pid_t pid) | evf::EvFDaqDirector | static |
mergedFileNameStem(const unsigned int ls, std::string const &stream) const | evf::EvFDaqDirector | private |
MergeTypeNames_ | evf::EvFDaqDirector | privatestatic |
nConcurrentLumis_ | evf::EvFDaqDirector | private |
newFile enum value | evf::EvFDaqDirector | |
newLumi enum value | evf::EvFDaqDirector | |
noFile enum value | evf::EvFDaqDirector | |
nStreams_ | evf::EvFDaqDirector | private |
nThreads_ | evf::EvFDaqDirector | private |
numConcurrentLumis() const | evf::EvFDaqDirector | inline |
openFULockfileStream(bool create) | evf::EvFDaqDirector | private |
outputAdler32Recheck() const | evf::EvFDaqDirector | inline |
outputAdler32Recheck_ | evf::EvFDaqDirector | private |
outputFileNameStem(const unsigned int ls, std::string const &stream) const | evf::EvFDaqDirector | private |
overrideRunNumber(unsigned int run) | evf::EvFDaqDirector | inline |
parseFRDFileHeader(std::string const &rawSourcePath, int &rawFd, uint16_t &rawHeaderSize, uint16_t &rawDataType, uint32_t &lsFromHeader, int32_t &eventsFromHeader, int64_t &fileSizeFromHeader, bool requireHeader, bool retry, bool closeFile) | evf::EvFDaqDirector | static |
pid_ | evf::EvFDaqDirector | private |
postEndRun(edm::GlobalContext const &globalContext) | evf::EvFDaqDirector | |
preallocate(edm::service::SystemBounds const &bounds) | evf::EvFDaqDirector | |
preBeginRun(edm::GlobalContext const &globalContext) | evf::EvFDaqDirector | |
preGlobalEndLumi(edm::GlobalContext const &globalContext) | evf::EvFDaqDirector | |
previousFileSize_ | evf::EvFDaqDirector | private |
query_ | evf::EvFDaqDirector | private |
rawFileHasHeader(std::string const &rawSourcePath, uint16_t &rawHeaderSize) | evf::EvFDaqDirector | |
readEolsDefinition_ | evf::EvFDaqDirector | private |
readLastLSEntry(std::string const &file) | evf::EvFDaqDirector | |
removeFile(std::string) | evf::EvFDaqDirector | |
resolver_ | evf::EvFDaqDirector | private |
run_ | evf::EvFDaqDirector | private |
run_dir_ | evf::EvFDaqDirector | private |
run_nstring_ | evf::EvFDaqDirector | private |
run_string_ | evf::EvFDaqDirector | private |
runAbort enum value | evf::EvFDaqDirector | |
runEnded enum value | evf::EvFDaqDirector | |
runString() const | evf::EvFDaqDirector | inline |
sameFile enum value | evf::EvFDaqDirector | |
setDeleteTracking(std::mutex *fileDeleteLock, std::list< std::pair< int, std::unique_ptr< InputFile >>> *filesToDelete) | evf::EvFDaqDirector | inline |
setFMS(evf::FastMonitoringService *fms) | evf::EvFDaqDirector | inline |
socket_ | evf::EvFDaqDirector | private |
startFromLS_ | evf::EvFDaqDirector | private |
stop_ls_override_ | evf::EvFDaqDirector | private |
stopFilePath_ | evf::EvFDaqDirector | private |
stopFilePathPid_ | evf::EvFDaqDirector | private |
tryInitializeFuLockFile() | evf::EvFDaqDirector | |
unlockFULocal() | evf::EvFDaqDirector | |
unlockFULocal2() | evf::EvFDaqDirector | |
unlockInitLock() | evf::EvFDaqDirector | |
updateFuLock(unsigned int &ls, std::string &nextFile, uint32_t &fsize, uint16_t &rawHeaderSize, uint64_t &lockWaitTime, bool &setExceptionState) | evf::EvFDaqDirector | |
useFileBroker() const | evf::EvFDaqDirector | inline |
useFileBroker_ | evf::EvFDaqDirector | private |
~EvFDaqDirector() | evf::EvFDaqDirector | |