| base_dir_ | evf::EvFDaqDirector | private |
| baseRunDir() | evf::EvFDaqDirector | inline |
| bu_base_dir_ | 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 |
| checkMergeTypePSet(edm::ProcessContext const &pc) | evf::EvFDaqDirector | |
| checkTransferSystemPSet(edm::ProcessContext const &pc) | evf::EvFDaqDirector | |
| 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 |
| 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 | |
| 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 | |
| getEoRFilePath() const | evf::EvFDaqDirector | |
| getEoRFilePathOnFU() const | evf::EvFDaqDirector | |
| getFFFParamsFilePathOnBU() const | evf::EvFDaqDirector | |
| getInitFilePath(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) | 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 &stream) const | evf::EvFDaqDirector | |
| getStreamMergeType(std::string const &stream, MergeType defaultType) | evf::EvFDaqDirector | |
| 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) | 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 | |
| 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 |
| mergeTypeMap_ | evf::EvFDaqDirector | private |
| MergeTypeNames_ | evf::EvFDaqDirector | privatestatic |
| mergeTypePset_ | 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 |
| 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, 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 | |
| preBeginJob(edm::PathsAndConsumesOfModulesBase const &, edm::ProcessContext const &) | 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(unsigned int ls, unsigned int index) | evf::EvFDaqDirector | |
| removeFile(std::string) | evf::EvFDaqDirector | |
| requireTSPSet_ | evf::EvFDaqDirector | private |
| 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 | |
| sameFile enum value | evf::EvFDaqDirector | |
| selectedTransferMode_ | evf::EvFDaqDirector | private |
| 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 |
| transferSystemJson_ | 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 | |
1.8.5
