DataDelivery transfers data between specified physical locations. More...
#include <arc/data-staging/DataDelivery.h>
Public Member Functions | |
| DataDelivery () | |
| Constructor. More... | |
| ~DataDelivery () | |
| Destructor calls stop() and waits for cancelled processes to exit. More... | |
| 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. More... | |
| bool | start () |
| Start the Delivery thread, which runs until stop() is called. More... | |
| bool | stop () |
| Tell the delivery to stop all transfers and threads and exit. More... | |
| void | SetTransferParameters (const TransferParameters ¶ms) |
| Set transfer limits. More... | |
 Public Member Functions inherited from DataStaging::DTRCallback | |
| virtual | ~DTRCallback () |
| Empty virtual destructor. More... | |
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.
Constructor & Destructor Documentation
| DataStaging::DataDelivery::DataDelivery | ( | ) |
Constructor.
|
inline |
Destructor calls stop() and waits for cancelled processes to exit.
Member Function Documentation
| bool DataStaging::DataDelivery::cancelDTR | ( | DTR_ptr | request | ) |
Stop the transfer corresponding to the given DTR.
|
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.
| void DataStaging::DataDelivery::SetTransferParameters | ( | const TransferParameters & | params | ) |
Set transfer limits.
| bool DataStaging::DataDelivery::start | ( | ) |
Start the Delivery thread, which runs until stop() is called.
| bool DataStaging::DataDelivery::stop | ( | ) |
Tell the delivery to stop all transfers and threads and exit.
The documentation for this class was generated from the following file:
