ARC SDK
Public Member Functions
DataStaging::DataDelivery Class Reference

DataDelivery transfers data between specified physical locations. More...

#include <arc/data-staging/DataDelivery.h>

Inheritance diagram for DataStaging::DataDelivery:
DataStaging::DTRCallback

Public Member Functions

 DataDelivery ()
 Constructor.
 
 ~DataDelivery ()
 Destructor calls stop() and waits for cancelled processes to exit.
 
virtual void receiveDTR (DTR_ptr request)
 Pass a DTR to Delivery. More...
 
bool cancelDTR (DTR_ptr request)
 Stop the transfer corresponding to the given DTR.
 
bool start ()
 Start the Delivery thread, which runs until stop() is called.
 
bool stop ()
 Tell the delivery to stop all transfers and threads and exit.
 
void SetTransferParameters (const TransferParameters &params)
 Set transfer limits.
 
- Public Member Functions inherited from DataStaging::DTRCallback
virtual ~DTRCallback ()
 Empty virtual destructor.
 

Detailed Description

DataDelivery transfers data between specified physical locations.

start() must be called to start the delivery thread for processing DTRs and stop() should be called to stop it (this waits for all data transfers to exit). stop() is also called in the destructor.

All meta-operations for a DTR such as resolving replicas must be done before sending to DataDelivery. Calling receiveDTR() starts a new process which performs data transfer as specified in DTR.

Member Function Documentation

virtual void DataStaging::DataDelivery::receiveDTR ( DTR_ptr  request)
virtual

Pass a DTR to Delivery.

This method is called by the scheduler to pass a DTR to the delivery. The DataDelivery starts the data transfer either using a local process or by sending a request to a remote delivery service, and then returns. DataDelivery's own thread then monitors the transfer.

Implements DataStaging::DTRCallback.


The documentation for this class was generated from the following file: