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, std::shared_ptr< FileLocation > src, std::shared_ptr< FileLocation > dst, std::shared_ptr< FileRegistryService > file_registry_service=nullptr)
	Ask the data manager to perform a synchronous file copy. More...
void	initiateAsynchronousFileCopy (WorkflowFile *file, std::shared_ptr< FileLocation > src, std::shared_ptr< FileLocation > dst, std::shared_ptr< 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
void	assertServiceIsUp ()
	Throws an exception if the service is not up. More...
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...
unsigned long	getPropertyValueAsUnsignedLong (std::string)
	Get a property of the Service as an unsigned long. More...
bool	isUp ()
	Returns true if the service is UP, false otherwise. More...
void	resume ()
	Resume the service. 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...
void	suspend ()
	Suspend the service.

Detailed Description

A helper daemon (co-located with a WMS) that handles data movement operations.

Member Function Documentation

doSynchronousFileCopy()

void wrench::DataMovementManager::doSynchronousFileCopy	(	WorkflowFile *	file,
		std::shared_ptr< FileLocation >	src,
		std::shared_ptr< FileLocation >	dst,
		std::shared_ptr< FileRegistryService >	file_registry_service = nullptr
	)

Ask the data manager to perform a synchronous file copy.

Parameters

file	the file to copy
src	the source location
dst	the destination location
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()

void wrench::DataMovementManager::initiateAsynchronousFileCopy	(	WorkflowFile *	file,
		std::shared_ptr< FileLocation >	src,
		std::shared_ptr< FileLocation >	dst,
		std::shared_ptr< FileRegistryService >	file_registry_service = nullptr
	)

Ask the data manager to initiate an asynchronous file copy.

Parameters

file	the file to copy
src	the source location
dst	the destination location
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()

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:

• DataMovementManager.h
• DataMovementManager.cpp