11 #ifndef WRENCH_STORAGESERVICE_H
12 #define WRENCH_STORAGESERVICE_H
18 #include <wrench/services/Service.h>
19 #include <wrench/workflow/failure_causes/FailureCause.h>
20 #include <wrench/services/file_registry/FileRegistryService.h>
21 #include <wrench/workflow/job/StandardJob.h>
22 #include <wrench/services/storage/storage_helpers/LogicalFileSystem.h>
23 #include <wrench/services/storage/storage_helpers/FileLocation.h>
31 class FileRegistryService;
58 std::shared_ptr<FileRegistryService> file_registry_service =
nullptr);
70 std::shared_ptr<FileLocation> src_location,
71 std::shared_ptr<FileLocation> dst_location);
74 static void initiateFileCopy(std::string answer_mailbox,
76 std::shared_ptr<FileLocation> src_location,
77 std::shared_ptr<FileLocation> dst_location);
79 static void readFiles(std::map<
WorkflowFile *, std::shared_ptr<FileLocation>> locations);
81 static void writeFiles(std::map<
WorkflowFile *, std::shared_ptr<FileLocation>> locations);
85 const std::set<std::string> mount_points,
86 const std::string &service_name,
87 const std::string &data_mailbox_name_prefix);
93 friend class FileTransferThread;
95 static void stageFile(
WorkflowFile *file , std::shared_ptr<FileLocation> location);
98 unsigned long buffer_size;
101 std::map<std::string, std::unique_ptr<LogicalFileSystem>> file_systems;
116 static void writeOrReadFiles(FileOperation action,
117 std::map<
WorkflowFile *, std::shared_ptr<FileLocation>> locations);
119 void stageFile(
WorkflowFile *file , std::string mountpoint, std::string directory);
133 #endif //WRENCH_STORAGESERVICE_H
std::string getMountPoint()
Get the mount point (will throw is more than one)
Definition: StorageService.cpp:662
A file registry service (a.k.a. replica catalog) that holds a database of which files are available a...
Definition: FileRegistryService.h:35
bool hasMultipleMountPoints()
Checked whether the storage service has multiple mount points.
Definition: StorageService.cpp:686
static void deleteFile(WorkflowFile *file, std::shared_ptr< FileLocation > location, std::shared_ptr< FileRegistryService > file_registry_service=nullptr)
Synchronously delete a file at a location.
Definition: StorageService.cpp:491
std::set< std::string > getMountPoints()
Get the set of mount points.
Definition: StorageService.cpp:674
The storage service base class.
Definition: StorageService.h:36
virtual std::map< std::string, double > getTotalSpace()
Get the total static capacity of the storage service (in zero simulation time)
Definition: StorageService.cpp:650
bool hasMountPoint(std::string mp)
Checked whether the storage service has a particular mount point.
Definition: StorageService.cpp:696
void stop() override
Stop the service.
Definition: StorageService.cpp:112
static void writeFile(WorkflowFile *file, std::shared_ptr< FileLocation > location)
Synchronously write a file to the storage service.
Definition: StorageService.cpp:326
static bool lookupFile(WorkflowFile *file, std::shared_ptr< FileLocation > location)
Synchronously asks the storage service whether it holds a file.
Definition: StorageService.cpp:174
static void readFile(WorkflowFile *file, std::shared_ptr< FileLocation > location)
Synchronously read a file from the storage service.
Definition: StorageService.cpp:223
virtual std::map< std::string, double > getFreeSpace()
Synchronously asks the storage service for its capacity at all its mount points.
Definition: StorageService.cpp:132
A class that provides basic simulation methods. Once the simulation object has been explicitly or imp...
Definition: Simulation.h:46
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