|
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. | |
| virtual | ~DataDeliveryLocalComm () |
| This stops the child process. | |
| virtual void | PullStatus () |
| Read from stdout of child to get status. | |
| virtual | operator bool () const |
| Returns true if child process exists. | |
| virtual bool | operator! () const |
| Returns true if child process does not exist. | |
Public Member Functions inherited from DataStaging::DataDeliveryComm | |
| virtual | ~DataDeliveryComm () |
| Destroy object. This stops any ongoing transfer and cleans up resources. | |
| Status | GetStatus () const |
| Obtain status of transfer. | |
| std::string | GetError () const |
| Get explanation of error. | |
Static Public Member Functions | |
| static bool | CheckComm (DTR_ptr dtr, std::vector< std::string > &allowed_dirs) |
| Returns "/" since local Delivery can access everywhere. | |
Static Public Member Functions inherited from DataStaging::DataDeliveryComm | |
| static DataDeliveryComm * | CreateInstance (DTR_ptr dtr, const TransferParameters ¶ms) |
| Factory method to get DataDeliveryComm instance. | |
| 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. | |
| Status | status_buf_ |
| Latest status of transfer is read into this buffer. | |
| unsigned int | status_pos_ |
| Reading position of Status buffer. | |
| Glib::Mutex | lock_ |
| Lock to protect access to status. | |
| DataDeliveryCommHandler * | handler_ |
| Pointer to singleton handler of all DataDeliveryComm objects. | |
| std::string | dtr_id |
| ID of the DTR this object is handling. Used in log messages. | |
| TransferParameters | transfer_params |
| Transfer limits. | |
| Arc::Time | start_ |
| Time transfer was started. | |
| DTRLogger | logger_ |
| Logger object. Pointer to DTR's Logger. | |
This class starts, monitors and controls a local Delivery process.
1.8.3.1