CMS 3D CMS Logo
evf::EvFDaqDirector Member List

This is the complete list of members for evf::EvFDaqDirector, including all inherited members.

base_dir_evf::EvFDaqDirectorprivate
baseRunDir()evf::EvFDaqDirectorinline
bu_base_dir_evf::EvFDaqDirectorprivate
bu_base_dirs_all_evf::EvFDaqDirectorprivate
bu_base_dirs_nSources_evf::EvFDaqDirectorprivate
bu_r_flkevf::EvFDaqDirectorprivate
bu_r_fulkevf::EvFDaqDirectorprivate
bu_r_lock_streamevf::EvFDaqDirectorprivate
bu_readlock_fd_evf::EvFDaqDirectorprivate
bu_run_dir_evf::EvFDaqDirectorprivate
bu_run_open_dir_evf::EvFDaqDirectorprivate
bu_t_monitor_streamevf::EvFDaqDirectorprivate
bu_w_flkevf::EvFDaqDirectorprivate
bu_w_fulkevf::EvFDaqDirectorprivate
bu_w_lock_streamevf::EvFDaqDirectorprivate
bu_w_monitor_streamevf::EvFDaqDirectorprivate
bu_writelock_fd_evf::EvFDaqDirectorprivate
buBaseRunDir()evf::EvFDaqDirectorinline
buBaseRunOpenDir()evf::EvFDaqDirectorinline
bumpFile(unsigned int &ls, unsigned int &index, std::string &nextFile, uint32_t &fsize, uint16_t &rawHeaderSize, int maxLS, bool &setExceptionState)evf::EvFDaqDirectorprivate
checkFileRead(char *buf, int infile, std::size_t buf_sz, std::string const &path)evf::EvFDaqDirectorprivatestatic
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) constevf::EvFDaqDirector
createLumiSectionFiles(const uint32_t lumiSection, const uint32_t currentLumiSection, bool doCreateBoLS, bool doCreateEoLS)evf::EvFDaqDirector
createProcessingNotificationMaybe() constevf::EvFDaqDirector
createRunOpendirMaybe()evf::EvFDaqDirector
directorBU_evf::EvFDaqDirectorprivate
dirManager_evf::EvFDaqDirectorprivate
discard_ls_filestem_evf::EvFDaqDirectorprivate
dpd_evf::EvFDaqDirectorprivate
endpoint_iterator_evf::EvFDaqDirectorprivate
eolsFileName(const unsigned int ls) constevf::EvFDaqDirectorprivate
eolsNFilesIndex_evf::EvFDaqDirectorprivate
eorFileName() constevf::EvFDaqDirectorprivate
EvFDaqDirector(const edm::ParameterSet &pset, edm::ActivityRegistry &reg)evf::EvFDaqDirectorexplicit
fileBrokerHost_evf::EvFDaqDirectorprivate
fileBrokerHostFromCfg_evf::EvFDaqDirectorprivate
fileBrokerKeepAlive_evf::EvFDaqDirectorprivate
fileBrokerPort_evf::EvFDaqDirectorprivate
fileBrokerUseLocalLock_evf::EvFDaqDirectorprivate
fileDeleteLockPtr_evf::EvFDaqDirectorprivate
FileStatus enum nameevf::EvFDaqDirector
filesToDeletePtr_evf::EvFDaqDirectorprivate
fillDescriptions(edm::ConfigurationDescriptions &descriptions)evf::EvFDaqDirectorstatic
findCurrentRunDir()evf::EvFDaqDirectorinline
fms_evf::EvFDaqDirectorprivate
fu_readwritelock_fd_evf::EvFDaqDirectorprivate
fu_rw_flkevf::EvFDaqDirectorprivate
fu_rw_fulkevf::EvFDaqDirectorprivate
fu_rw_lock_streamevf::EvFDaqDirectorprivate
fulocal_rwlock_fd2_evf::EvFDaqDirectorprivate
fulocal_rwlock_fd_evf::EvFDaqDirectorprivate
fulockfile_evf::EvFDaqDirectorprivate
fuLockPollInterval_evf::EvFDaqDirectorprivate
getBoLSFilePathOnFU(const unsigned int ls) constevf::EvFDaqDirector
getBUBaseDirs() constevf::EvFDaqDirectorinline
getBUBaseDirsNSources() constevf::EvFDaqDirectorinline
getDatFilePath(const unsigned int ls, std::string const &stream) constevf::EvFDaqDirector
getEoLSFilePathOnBU(const unsigned int ls) constevf::EvFDaqDirector
getEoLSFilePathOnFU(const unsigned int ls) constevf::EvFDaqDirector
getEoRFileName() constevf::EvFDaqDirector
getEoRFilePath() constevf::EvFDaqDirector
getEoRFilePathOnFU() constevf::EvFDaqDirector
getFFFParamsFilePathOnBU() constevf::EvFDaqDirector
getInitFilePath(std::string const &stream) constevf::EvFDaqDirector
getInitTempFilePath(std::string const &stream) constevf::EvFDaqDirector
getInputJsonFilePath(const unsigned int ls, const unsigned int index) constevf::EvFDaqDirector
getLumisectionToStart() constevf::EvFDaqDirector
getMergedDatChecksumFilePath(const unsigned int ls, std::string const &stream) constevf::EvFDaqDirector
getMergedDatFilePath(const unsigned int ls, std::string const &stream) constevf::EvFDaqDirector
getMergedProtocolBufferHistogramFilePath(const unsigned int ls, std::string const &stream) constevf::EvFDaqDirector
getMergedRootHistogramFilePath(const unsigned int ls, std::string const &stream) constevf::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::EvFDaqDirectorprivate
getOpenDatFilePath(const unsigned int ls, std::string const &stream) constevf::EvFDaqDirector
getOpenInitFilePath(std::string const &stream) constevf::EvFDaqDirector
getOpenInputJsonFilePath(const unsigned int ls, const unsigned int index) constevf::EvFDaqDirector
getOpenOutputJsonFilePath(const unsigned int ls, std::string const &stream) constevf::EvFDaqDirector
getOpenProtocolBufferHistogramFilePath(const unsigned int ls, std::string const &stream) constevf::EvFDaqDirector
getOpenRawFilePath(const unsigned int ls, const unsigned int index) constevf::EvFDaqDirector
getOpenRootHistogramFilePath(const unsigned int ls, std::string const &stream) constevf::EvFDaqDirector
getOutputJsonFilePath(const unsigned int ls, std::string const &stream) constevf::EvFDaqDirector
getProtocolBufferHistogramFilePath(const unsigned int ls, std::string const &stream) constevf::EvFDaqDirector
getRawFilePath(const unsigned int ls, const unsigned int index) constevf::EvFDaqDirector
getRootHistogramFilePath(const unsigned int ls, std::string const &stream) constevf::EvFDaqDirector
getRunNumber() constevf::EvFDaqDirectorinline
getRunOpenDirPath() constevf::EvFDaqDirectorinline
getStartLumisectionFromEnv() constevf::EvFDaqDirectorinline
getStreamDestinations(std::string const &stream) constevf::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, bool requireHeader=true)evf::EvFDaqDirector
hltSourceDirectory_evf::EvFDaqDirectorprivate
hostname_evf::EvFDaqDirectorprivate
init_lock_evf::EvFDaqDirectorprivate
initFileName(std::string const &stream) constevf::EvFDaqDirectorprivate
initRun()evf::EvFDaqDirector
input_throttled_file_evf::EvFDaqDirectorprivate
inputFileNameStem(const unsigned int ls, const unsigned int index) constevf::EvFDaqDirectorprivate
inputThrottled()evf::EvFDaqDirector
io_service_evf::EvFDaqDirectorprivate
isSingleStreamThread()evf::EvFDaqDirectorinline
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::EvFDaqDirectorstatic
mergedFileNameStem(const unsigned int ls, std::string const &stream) constevf::EvFDaqDirectorprivate
mergeTypeMap_evf::EvFDaqDirectorprivate
MergeTypeNames_evf::EvFDaqDirectorprivatestatic
mergeTypePset_evf::EvFDaqDirectorprivate
nConcurrentLumis_evf::EvFDaqDirectorprivate
newFile enum valueevf::EvFDaqDirector
newLumi enum valueevf::EvFDaqDirector
noFile enum valueevf::EvFDaqDirector
nStreams_evf::EvFDaqDirectorprivate
nThreads_evf::EvFDaqDirectorprivate
numConcurrentLumis() constevf::EvFDaqDirectorinline
openFULockfileStream(bool create)evf::EvFDaqDirectorprivate
outputAdler32Recheck() constevf::EvFDaqDirectorinline
outputAdler32Recheck_evf::EvFDaqDirectorprivate
outputFileNameStem(const unsigned int ls, std::string const &stream) constevf::EvFDaqDirectorprivate
overrideRunNumber(unsigned int run)evf::EvFDaqDirectorinline
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::EvFDaqDirectorstatic
pid_evf::EvFDaqDirectorprivate
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::EvFDaqDirectorprivate
query_evf::EvFDaqDirectorprivate
rawFileHasHeader(std::string const &rawSourcePath, uint16_t &rawHeaderSize)evf::EvFDaqDirector
readEolsDefinition_evf::EvFDaqDirectorprivate
readLastLSEntry(std::string const &file)evf::EvFDaqDirector
removeFile(std::string)evf::EvFDaqDirector
requireTSPSet_evf::EvFDaqDirectorprivate
resolver_evf::EvFDaqDirectorprivate
run_evf::EvFDaqDirectorprivate
run_dir_evf::EvFDaqDirectorprivate
run_nstring_evf::EvFDaqDirectorprivate
run_string_evf::EvFDaqDirectorprivate
runAbort enum valueevf::EvFDaqDirector
runEnded enum valueevf::EvFDaqDirector
runString() constevf::EvFDaqDirectorinline
sameFile enum valueevf::EvFDaqDirector
selectedTransferMode_evf::EvFDaqDirectorprivate
setDeleteTracking(std::mutex *fileDeleteLock, std::list< std::pair< int, std::unique_ptr< InputFile >>> *filesToDelete)evf::EvFDaqDirectorinline
setFMS(evf::FastMonitoringService *fms)evf::EvFDaqDirectorinline
socket_evf::EvFDaqDirectorprivate
startFromLS_evf::EvFDaqDirectorprivate
stop_ls_override_evf::EvFDaqDirectorprivate
stopFilePath_evf::EvFDaqDirectorprivate
stopFilePathPid_evf::EvFDaqDirectorprivate
transferSystemJson_evf::EvFDaqDirectorprivate
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() constevf::EvFDaqDirectorinline
useFileBroker_evf::EvFDaqDirectorprivate
~EvFDaqDirector()evf::EvFDaqDirector
Generated for CMSSW Reference Manual by doxygen 1.8.14