2 namespace DataStaging {
42 #include <arc/data/DataHandle.h>
43 #include <arc/CheckSum.h>
44 #include <arc/data/URLMap.h>
45 #include <arc/DateTime.h>
46 #include <arc/Logger.h>
48 #include <arc/UserConfig.h>
49 #include <arc/Thread.h>
50 #include "DTRStatus.h"
62 namespace DataStaging {
142 std::vector<std::string> remote_caches,
143 std::vector<std::string> drain_caches);
219 std::string source_url_str;
221 std::string destination_url_str;
227 std::string cache_file;
243 std::string parent_job_id;
249 std::string transfershare;
255 std::string sub_share;
258 unsigned int tries_left;
261 unsigned int initial_tries;
271 bool force_registration;
275 std::string mapped_source;
284 unsigned long long int bytes_transferred;
304 bool source_supports_bulk;
311 std::vector<Arc::URL> problematic_delivery_endpoints;
314 bool use_host_cert_for_remote_delivery;
328 std::list<Arc::LogDestination*> log_destinations;
331 std::map<StagingProcesses,std::list<DTRCallback*> > proc_callback;
348 void mark_modification () { last_modified.
SetTime(time(NULL)); };
351 std::list<DTRCallback*> get_callbacks(
const std::map<
StagingProcesses, std::list<DTRCallback*> >& proc_callback,
355 DTR& operator=(
const DTR& dtr);
380 DTR(
const std::string& source,
381 const std::string& destination,
383 const std::string& jobid,
391 operator bool()
const {
392 return (!DTR_ID.empty());
396 return (DTR_ID.empty());
414 void set_id(
const std::string&
id);
416 std::string
get_id()
const {
return DTR_ID; };
493 const std::string& desc=
"");
612 const std::string& destination,
614 const std::string& jobid,
620 const std::string& subdomain);