wrench::DataMovementManager

class DataMovementManager : public wrench::Service

A helper daemon (co-located with an execution controler) that handles data movement operations.

Public Functions

void doSynchronousFileCopy(const std::shared_ptr<FileLocation> &src, const std::shared_ptr<FileLocation> &dst, const std::shared_ptr<FileRegistryService> &file_registry_service = nullptr)

Ask the data manager to perform a synchronous file copy.

Parameters:

• 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)

Throws:

• std::invalid_argument –

• ExecutionException –

void initiateAsynchronousFileCopy(const std::shared_ptr<FileLocation> &src, const std::shared_ptr<FileLocation> &dst, const std::shared_ptr<FileRegistryService> &file_registry_service = nullptr)

Ask the data manager to initiate an asynchronous file copy.

Parameters:

• 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)

Throws:

• std::invalid_argument –

• ExecutionException –

void initiateAsynchronousFileRead(const std::shared_ptr<FileLocation> &location)

Ask the data manager to initiate an asynchronous file read.

Parameters:

location – the location to read from

Throws:

• std::invalid_argument –

• ExecutionException –

void initiateAsynchronousFileRead(const std::shared_ptr<FileLocation> &location, const double num_bytes)

Ask the data manager to initiate an asynchronous file read.

Parameters:

• location – the location to read from

• num_bytes – the number of bytes to read

Throws:

• std::invalid_argument –

• ExecutionException –

void initiateAsynchronousFileWrite(const std::shared_ptr<FileLocation> &location, const std::shared_ptr<FileRegistryService> &file_registry_service)

Ask the data manager to initiate an asynchronous file write.

Parameters:

• location – the location to read from

• file_registry_service – a file registry service to update once the file write has (successfully) completed

Throws:

• std::invalid_argument –

• ExecutionException –

void kill()

Kill the manager (brutally terminate the daemon)

virtual void stop() override

Stop the manager.

Throws:

• ExecutionException –

• std::runtime_error –