X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/c4081e3a628c6ab697d7958f3f22bdf788c0c13c..e99273780a983ac4a6fafbfbe91e7fdfb954d35c:/include/simgrid/s4u/File.hpp diff --git a/include/simgrid/s4u/File.hpp b/include/simgrid/s4u/File.hpp index 278081f2db..2bdd632b79 100644 --- a/include/simgrid/s4u/File.hpp +++ b/include/simgrid/s4u/File.hpp @@ -6,10 +6,12 @@ #ifndef SIMGRID_S4U_FILE_HPP #define SIMGRID_S4U_FILE_HPP +#include "simgrid/plugins/file_system.h" +#include #include -#include "src/surf/StorageImpl.hpp" #include +#include namespace simgrid { namespace s4u { @@ -25,60 +27,67 @@ namespace s4u { XBT_PUBLIC_CLASS File { public: - File(const char* fullpath, void* userdata); - ~File(); + File(std::string fullpath, void* userdata); + File(std::string fullpath, sg_host_t host, void* userdata); + ~File() = default; /** Retrieves the path to the file */ - const char* path() { return path_; } + const char* getPath() { return fullpath_.c_str(); } - /** Simulates a read action. Returns the size of data actually read - * - * FIXME: reading from a remotely mounted disk is not implemented yet. - * Any storage is considered as local, and no network communication ever occur. - */ + /** Simulates a local read action. Returns the size of data actually read */ sg_size_t read(sg_size_t size); - /** Simulates a write action. Returns the size of data actually written. - * - * FIXME: reading from a remotely mounted disk is not implemented yet. - * Any storage is considered as local, and no network communication ever occur. - */ + + /** Simulates a write action. Returns the size of data actually written. */ sg_size_t write(sg_size_t size); /** Allows to store user data on that host */ void setUserdata(void* data) { userdata_ = data; } /** Retrieves the previously stored data */ - void* userdata() { return userdata_; } + void* getUserdata() { return userdata_; } /** Retrieve the datasize */ sg_size_t size(); /** Sets the file head to the given position. */ - void seek(sg_size_t pos); + void seek(sg_offset_t pos); + void seek(sg_offset_t pos, int origin); + /** Retrieves the current file position */ sg_size_t tell(); - /** Rename a file - * - * WARNING: It is forbidden to move the file to another mount point */ - void move(const char* fullpath); + /** Rename a file. WARNING: It is forbidden to move the file to another mount point */ + void move(std::string fullpath); /** Remove a file from disk */ - void unlink(); - - /* FIXME: add these to the S4U API: - XBT_PUBLIC(const char *) MSG_file_get_name(msg_file_t file); - XBT_PUBLIC(msg_error_t) MSG_file_rcopy(msg_file_t fd, msg_host_t host, const char* fullpath); - XBT_PUBLIC(msg_error_t) MSG_file_rmove(msg_file_t fd, msg_host_t host, const char* fullpath); - */ - char* storage_type; - char* storageId; - char* mount_point; + int unlink(); + int desc_id = 0; + Storage* localStorage; + std::string mount_point_; private: - smx_file_t pimpl_ = nullptr; - const char* path_ = nullptr; - void* userdata_ = nullptr; + sg_size_t size_; + std::string path_; + std::string fullpath_; + sg_size_t current_position_ = SEEK_SET; + void* userdata_ = nullptr; +}; + +class FileSystemStorageExt { +public: + static simgrid::xbt::Extension EXTENSION_ID; + explicit FileSystemStorageExt(simgrid::s4u::Storage* ptr); + ~FileSystemStorageExt(); + std::map* parseContent(std::string filename); + std::map* getContent() { return content_; } + sg_size_t getSize() { return size_; } + sg_size_t getUsedSize() { return usedSize_; } + void decrUsedSize(sg_size_t size) { usedSize_ -= size; } + void incrUsedSize(sg_size_t size) { usedSize_ += size; } +private: + std::map* content_; + sg_size_t usedSize_ = 0; + sg_size_t size_ = 0; }; } } // namespace simgrid::s4u