DataStaging contains all components for data transfer scheduling and execution. More...

Data Structures
class	DataDelivery
	DataDelivery transfers data between specified physical locations. More...

class	DataDeliveryComm
	This class provides an abstract interface for the Delivery layer. More...

class	DataDeliveryCommHandler
	Singleton class handling all active DataDeliveryComm objects. More...

class	DataDeliveryLocalComm
	This class starts, monitors and controls a local Delivery process. More...

class	DataDeliveryRemoteComm
	This class contacts a remote service to make a Delivery request. More...

class	TransferParameters
	Represents limits and properties of a DTR transfer. These generally apply to all DTRs. More...

class	DTRCacheParameters
	The configured cache directories. More...

class	DTRCallback
	The base class from which all callback-enabled classes should be derived. More...

class	DTR
	Data Transfer Request. More...

class	DTRList
	Global list of all active DTRs in the system. More...

class	DTRStatus
	Class representing the status of a DTR. More...

class	DTRErrorStatus
	A class to represent error states reported by various components. More...

class	Processor
	The Processor performs pre- and post-transfer operations. More...

class	Scheduler
	The Scheduler is the control centre of the data staging framework. More...

class	TransferSharesConf
	TransferSharesConf describes the configuration of TransferShares. More...

class	TransferShares
	TransferShares is used to implement fair-sharing and priorities. More...

Typedefs
typedef Arc::ThreadedPointer< DTR >	DTR_ptr
	Provides automatic memory management of DTRs and thread-safe destruction. More...

typedef Arc::ThreadedPointer < Arc::Logger >	DTRLogger
	The DTR's Logger object can be used outside the DTR object with DTRLogger. More...

Enumerations
enum	StagingProcesses { GENERATOR, SCHEDULER, PRE_PROCESSOR, DELIVERY, POST_PROCESSOR }
	Components of the data staging framework. More...

enum	ProcessState { INITIATED, RUNNING, TO_STOP, STOPPED }
	Internal state of StagingProcesses. More...

enum	CacheState { CACHEABLE, NON_CACHEABLE, CACHE_ALREADY_PRESENT, CACHE_DOWNLOADED, CACHE_LOCKED, CACHE_SKIP, CACHE_NOT_USED }
	Represents possible cache states of this DTR. More...

Functions
DTR_ptr	createDTRPtr (const std::string &source, const std::string &destination, const Arc::UserConfig &usercfg, const std::string &jobid, const uid_t &uid, DTRLogger log)
	Helper method to create smart pointer, only for swig bindings. More...

DTRLogger	createDTRLogger (Arc::Logger &parent, const std::string &subdomain)
	Helper method to create smart pointer, only for swig bindings. More...

Detailed Description

DataStaging contains all components for data transfer scheduling and execution.

Function Documentation

DTRLogger DataStaging::createDTRLogger	(	Arc::Logger &	parent,
		const std::string &	subdomain
	)

Helper method to create smart pointer, only for swig bindings.

DTR_ptr DataStaging::createDTRPtr	(	const std::string &	source,
		const std::string &	destination,
		const Arc::UserConfig &	usercfg,
		const std::string &	jobid,
		const uid_t &	uid,
		DTRLogger	log
	)

Helper method to create smart pointer, only for swig bindings.