wrench::DataMovementManager Class Reference
A helper daemon (co-located with a WMS) that handles data movement operations. More...
#include <DataMovementManager.h>
Inheritance diagram for wrench::DataMovementManager:
Public Member Functions | |
void | doSynchronousFileCopy (WorkflowFile *file, StorageService *src, StorageService *dst, FileRegistryService *file_registry_service=nullptr) |
Ask the data manager to perform a synchronous file copy. More... | |
void | doSynchronousFileCopy (WorkflowFile *file, StorageService *src, std::string src_partition, StorageService *dst, std::string dst_partition, FileRegistryService *file_registry_service=nullptr) |
Ask the data manager to perform a synchronous file copy. More... | |
void | initiateAsynchronousFileCopy (WorkflowFile *file, StorageService *src, StorageService *dst, FileRegistryService *file_registry_service=nullptr) |
Ask the data manager to initiate an asynchronous file copy. More... | |
void | initiateAsynchronousFileCopy (WorkflowFile *file, StorageService *src, std::string src_partition, StorageService *dst, std::string dst_partition, FileRegistryService *file_registry_service=nullptr) |
Ask the data manager to initiate an asynchronous file copy. More... | |
void | kill () |
Kill the manager (brutally terminate the daemon) | |
void | stop () |
Stop the manager. More... | |
Public Member Functions inherited from wrench::Service | |
std::string | getHostname () |
Get the name of the host on which the service is / will be running. More... | |
double | getNetworkTimeoutValue () |
Returns the service's network timeout value. More... | |
bool | getPropertyValueAsBoolean (std::string) |
Get a property of the Service as a boolean. More... | |
double | getPropertyValueAsDouble (std::string) |
Get a property of the Service as a double. More... | |
std::string | getPropertyValueAsString (std::string) |
Get a property of the Service as a string. More... | |
bool | isUp () |
Returns true if the service is UP, false otherwise. More... | |
void | setNetworkTimeoutValue (double value) |
Sets the service's network timeout value. More... | |
void | start (std::shared_ptr< Service > this_service, bool daemonize, bool auto_restart) |
Start the service. More... | |
Additional Inherited Members | |
Public Types inherited from wrench::Service | |
enum | State { UP, DOWN } |
Service states. More... | |
Detailed Description
A helper daemon (co-located with a WMS) that handles data movement operations.
Member Function Documentation
◆ doSynchronousFileCopy() [1/2]
void wrench::DataMovementManager::doSynchronousFileCopy | ( | WorkflowFile * | file, |
StorageService * | src, | ||
StorageService * | dst, | ||
FileRegistryService * | file_registry_service = nullptr |
||
) |
Ask the data manager to perform a synchronous file copy.
- Parameters
-
file the file to copy src the source storage service (using the "/" partition) dst the destination storage service (using the "/" partition) file_registry_service a file registry service to update once the file copy has (successfully) completed (none if nullptr)
- Exceptions
-
std::invalid_argument WorkflowExecutionException
◆ doSynchronousFileCopy() [2/2]
void wrench::DataMovementManager::doSynchronousFileCopy | ( | WorkflowFile * | file, |
StorageService * | src, | ||
std::string | src_partition, | ||
StorageService * | dst, | ||
std::string | dst_partition, | ||
FileRegistryService * | file_registry_service = nullptr |
||
) |
Ask the data manager to perform a synchronous file copy.
- Parameters
-
file the file to copy src the source storage service dst the destination storage service file_registry_service a file registry service to update once the file copy has (successfully) completed (none if nullptr)
- Exceptions
-
std::invalid_argument WorkflowExecutionException
◆ initiateAsynchronousFileCopy() [1/2]
void wrench::DataMovementManager::initiateAsynchronousFileCopy | ( | WorkflowFile * | file, |
StorageService * | src, | ||
StorageService * | dst, | ||
FileRegistryService * | file_registry_service = nullptr |
||
) |
Ask the data manager to initiate an asynchronous file copy.
- Parameters
-
file the file to copy src the source storage service (using the "/" partition) dst the destination storage service (using the "/" partition) file_registry_service a file registry service to update once the file copy has (successfully) completed (none if nullptr)
- Exceptions
-
std::invalid_argument WorkflowExecutionException
◆ initiateAsynchronousFileCopy() [2/2]
void wrench::DataMovementManager::initiateAsynchronousFileCopy | ( | WorkflowFile * | file, |
StorageService * | src, | ||
std::string | src_partition, | ||
StorageService * | dst, | ||
std::string | dst_partition, | ||
FileRegistryService * | file_registry_service = nullptr |
||
) |
Ask the data manager to initiate an asynchronous file copy.
- Parameters
-
file the file to copy src the source storage service src_partition the source partition dst the destination storage service dst_partition the destination partition file_registry_service a file registry service to update once the file copy has (successfully) completed (none if nullptr)
- Exceptions
-
std::invalid_argument WorkflowExecutionException
◆ stop()
|
virtual |
Stop the manager.
- Exceptions
-
WorkflowExecutionException std::runtime_error
Reimplemented from wrench::Service.
The documentation for this class was generated from the following files:
- /Users/rafsilva/Documents/isi/workspace/wrench/wrench/include/wrench/managers/DataMovementManager.h
- /Users/rafsilva/Documents/isi/workspace/wrench/wrench/src/wrench/managers/DataMovementManager.cpp