4 #include <arc/Thread.h> 22 std::list<DTR_ptr> DTRs;
32 std::map<std::string, int> CachingSources;
71 std::list<DTR_ptr>& FilteredList);
void dumpState(const std::string &path)
Dump state of all current DTRs to a destination, eg file, database, url...
unsigned int size()
Return the size of the DTR list.
bool add_dtr(DTR_ptr DTRToAdd)
Put a new DTR into the list.
DTRStatusType
Possible state values.
Definition: DTRStatus.h:21
Simple triggered condition.
Definition: Thread.h:150
int number_of_dtrs_by_owner(StagingProcesses OwnerToFilter)
Returns the number of DTRs owned by a particular process.
StagingProcesses
Components of the data staging framework.
Definition: DTR.h:69
bool delete_dtr(DTR_ptr DTRToDelete)
Remove a DTR from the list.
bool filter_dtrs_by_next_receiver(StagingProcesses NextReceiver, std::list< DTR_ptr > &FilteredList)
Select DTRs that are about to go to the specified process.
Global list of all active DTRs in the system.
Definition: DTRList.h:17
void caching_started(DTR_ptr request)
Update the caching set, add a DTR (only if it is CACHEABLE).
bool filter_dtrs_by_statuses(const std::vector< DTRStatus::DTRStatusType > &StatusesToFilter, std::list< DTR_ptr > &FilteredList)
Filter the queue to select DTRs with particular statuses.
void caching_finished(DTR_ptr request)
Update the caching set, removing a DTR.
DataStaging contains all components for data transfer scheduling and execution.
Definition: DataDelivery.h:12
bool is_being_cached(DTR_ptr DTRToCheck)
Returns true if the DTR's source is currently in the caching set.
bool filter_pending_dtrs(std::list< DTR_ptr > &FilteredList)
Select DTRs that have just arrived from pre-, post-processor, delivery or generator.
bool filter_dtrs_by_job(const std::string &jobid, std::list< DTR_ptr > &FilteredList)
Get the list of DTRs corresponding to the given job ID.
bool filter_dtrs_by_status(DTRStatus::DTRStatusType StatusToFilter, std::list< DTR_ptr > &FilteredList)
Filter the queue to select DTRs with particular status.
bool filter_dtrs_by_owner(StagingProcesses OwnerToFilter, std::list< DTR_ptr > &FilteredList)
Filter the queue to select DTRs owned by a specified process.
void check_priority_changes(const std::string &filename)
Check for requested changes in priority in filename.
bool empty()
Returns true if there are no DTRs in the list.
std::list< std::string > all_jobs()
Get the list of all job IDs.