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
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
void kill()

Kill the manager (brutally terminate the daemon)

virtual void stop() override

Stop the manager.

Throws