|
ARC SDK
|
This class starts, monitors and controls a local Delivery process. More...
#include <arc/data-staging/DataDeliveryLocalComm.h>
Public Member Functions | |
| DataDeliveryLocalComm (DTR_ptr dtr, const TransferParameters ¶ms) | |
| Starts child process. More... | |
| virtual | ~DataDeliveryLocalComm () |
| This stops the child process. More... | |
| virtual void | PullStatus () |
| Read from stdout of child to get status. More... | |
| virtual | operator bool () const |
| Returns true if child process exists. More... | |
| virtual bool | operator! () const |
| Returns true if child process does not exist. More... | |
Public Member Functions inherited from DataStaging::DataDeliveryComm | |
| virtual | ~DataDeliveryComm () |
| Destroy object. This stops any ongoing transfer and cleans up resources. More... | |
| Status | GetStatus () const |
| Obtain status of transfer. More... | |
| std::string | GetError () const |
| Get explanation of error. More... | |
Static Public Member Functions | |
| static bool | CheckComm (DTR_ptr dtr, std::vector< std::string > &allowed_dirs) |
| Returns "/" since local Delivery can access everywhere. More... | |
Static Public Member Functions inherited from DataStaging::DataDeliveryComm | |
| static DataDeliveryComm * | CreateInstance (DTR_ptr dtr, const TransferParameters ¶ms) |
| Factory method to get DataDeliveryComm instance. More... | |
| static bool | CheckComm (DTR_ptr dtr, std::vector< std::string > &allowed_dirs) |
| Check the delivery method is available. Calls CheckComm of the appropriate subclass. More... | |
Additional Inherited Members | |
Public Types inherited from DataStaging::DataDeliveryComm | |
| enum | CommStatusType { CommInit, CommNoError, CommTimeout, CommClosed, CommExited, CommFailed } |
| Communication status with transfer. More... | |
Protected Member Functions inherited from DataStaging::DataDeliveryComm | |
| DataDeliveryComm (DTR_ptr dtr, const TransferParameters ¶ms) | |
| Start transfer with parameters taken from DTR and supplied transfer limits. More... | |
Protected Attributes inherited from DataStaging::DataDeliveryComm | |
| Status | status_ |
| Current status of transfer. More... | |
| Status | status_buf_ |
| Latest status of transfer is read into this buffer. More... | |
| unsigned int | status_pos_ |
| Reading position of Status buffer. More... | |
| Glib::Mutex | lock_ |
| Lock to protect access to status. More... | |
| DataDeliveryCommHandler * | handler_ |
| Pointer to singleton handler of all DataDeliveryComm objects. More... | |
| TransferParameters | transfer_params |
| Transfer limits. More... | |
| Arc::Time | start_ |
| Time transfer was started. More... | |
| DTRLogger | logger_ |
| Logger object. Pointer to DTR's Logger. More... | |
This class starts, monitors and controls a local Delivery process.
| DataStaging::DataDeliveryLocalComm::DataDeliveryLocalComm | ( | DTR_ptr | dtr, |
| const TransferParameters & | params | ||
| ) |
Starts child process.
|
virtual |
This stops the child process.
|
static |
Returns "/" since local Delivery can access everywhere.
|
inlinevirtual |
Returns true if child process exists.
Implements DataStaging::DataDeliveryComm.
|
inlinevirtual |
Returns true if child process does not exist.
Implements DataStaging::DataDeliveryComm.
|
virtual |
Read from stdout of child to get status.
Implements DataStaging::DataDeliveryComm.
1.8.3.1-20130209