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(std::shared_ptr<DataFile> 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)

Throws

• std::invalid_argument –

• ExecutionException –

void initiateAsynchronousFileCopy(std::shared_ptr<DataFile> 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)

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 –