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:
wrench::Service

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=false)
 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

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
filethe file to copy
srcthe source storage service (using the "/" partition)
dstthe destination storage service (using the "/" partition)
file_registry_servicea file registry service to update once the file copy has (successfully) completed (none if nullptr)
Exceptions
std::invalid_argument
WorkflowExecutionException
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
filethe file to copy
srcthe source storage service
dstthe destination storage service
file_registry_servicea file registry service to update once the file copy has (successfully) completed (none if nullptr)
Exceptions
std::invalid_argument
WorkflowExecutionException
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
filethe file to copy
srcthe source storage service (using the "/" partition)
dstthe destination storage service (using the "/" partition)
file_registry_servicea file registry service to update once the file copy has (successfully) completed (none if nullptr)
Exceptions
std::invalid_argument
WorkflowExecutionException
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
filethe file to copy
srcthe source storage service
src_partitionthe source partition
dstthe destination storage service
dst_partitionthe destination partition
file_registry_servicea file registry service to update once the file copy has (successfully) completed (none if nullptr)
Exceptions
std::invalid_argument
WorkflowExecutionException
void wrench::DataMovementManager::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:
  • /home/wrench/wrench/include/wrench/managers/DataMovementManager.h
  • /home/wrench/wrench/src/wrench/managers/DataMovementManager.cpp