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)

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)

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

void initiateAsynchronousFileRead(const std::shared_ptr<FileLocation> &location, const sg_size_t 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

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

void kill()

Kill the manager (brutally terminate the daemon)

virtual void stop() override

Stop the manager.