DataMovementManager.h
39 void initiateAsynchronousFileCopy(WorkflowFile *file, StorageService *src, StorageService *dst, FileRegistryService *file_registry_service=nullptr);
45 void doSynchronousFileCopy(WorkflowFile *file, StorageService *src, StorageService *dst, FileRegistryService *file_registry_service=nullptr);
82 FileRegistryService *file_registry_service) : file(file), dst(dst), dst_partition(dst_partition), file_registry_service(file_registry_service) {}
DataMovementManager(WMS *wms)
Constructor.
Definition: DataMovementManager.cpp:35
A service that can be added to the simulation and that can be used by a WMS when executing a workflow...
Definition: Service.h:26
A data file used/produced by a WorkflowTask in a Workflow.
Definition: WorkflowFile.h:26
void doSynchronousFileCopy(WorkflowFile *file, StorageService *src, StorageService *dst, FileRegistryService *file_registry_service=nullptr)
Ask the data manager to perform a synchronous file copy.
Definition: DataMovementManager.cpp:147
void kill()
Kill the manager (brutally terminate the daemon)
Definition: DataMovementManager.cpp:53
A helper daemon (co-located with a WMS) that handles data movement operations.
Definition: DataMovementManager.h:31
A file registry service (a.k.a. replica catalog) that holds a database of which files are available a...
Definition: FileRegistryService.h:33
void initiateAsynchronousFileCopy(WorkflowFile *file, StorageService *src, StorageService *dst, FileRegistryService *file_registry_service=nullptr)
Ask the data manager to initiate an asynchronous file copy.
Definition: DataMovementManager.cpp:81
void stop()
Stop the manager.
Definition: DataMovementManager.cpp:63
Definition: TerminalOutput.cpp:15