X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/c96b8ddfe1c923257f43ee40334ceb820226694c..a2cf3a7cbbc69e69e7c18c7168c7bb2396122cd1:/src/surf/storage_interface.cpp diff --git a/src/surf/storage_interface.cpp b/src/surf/storage_interface.cpp index 3edbbb78d6..dbbb601a02 100644 --- a/src/surf/storage_interface.cpp +++ b/src/surf/storage_interface.cpp @@ -11,8 +11,12 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY(surf_storage, surf, "Logging specific to the SURF storage module"); xbt_lib_t file_lib; +int MSG_FILE_LEVEL = -1; // Msg file level + xbt_lib_t storage_lib; -int ROUTING_STORAGE_LEVEL = -1; //Routing for storagelevel +int SIMIX_STORAGE_LEVEL = -1; // Simix storage level +int MSG_STORAGE_LEVEL = -1; // Msg storage level +int ROUTING_STORAGE_LEVEL = -1; // Routing for storage level int ROUTING_STORAGE_HOST_LEVEL = -1; int SURF_STORAGE_LEVEL = -1; xbt_lib_t storage_type_lib; @@ -37,6 +41,7 @@ simgrid::xbt::signal storage StorageModel::StorageModel(): Model() { + maxminSystem_ = lmm_system_new(true /* lazy update */); } StorageModel::~StorageModel(){ @@ -48,30 +53,15 @@ StorageModel::~StorageModel(){ * Resource * ************/ -Storage::Storage(Model *model, const char *name, xbt_dict_t props, - const char* type_id, const char *content_name, const char *content_type, - sg_size_t size) - : Resource(model, name) - , PropertyHolder(props) - , contentType_(xbt_strdup(content_type)) - , size_(size), usedSize_(0) - , typeId_(xbt_strdup(type_id)) - , writeActions_(std::vector()) -{ - content_ = parseContent(content_name); - turnOn(); -} - -Storage::Storage(Model *model, const char *name, xbt_dict_t props, - lmm_system_t maxminSystem, double bread, double bwrite, - double bconnection, const char* type_id, const char *content_name, - const char *content_type, sg_size_t size, const char *attach) - : Resource(model, name, lmm_constraint_new(maxminSystem, this, bconnection)) - , PropertyHolder(props) - , contentType_(xbt_strdup(content_type)) - , size_(size), usedSize_(0) - , typeId_(xbt_strdup(type_id)) - , writeActions_(std::vector()) +Storage::Storage(Model* model, const char* name, lmm_system_t maxminSystem, double bread, double bwrite, + double bconnection, const char* type_id, const char* content_name, const char* content_type, + sg_size_t size, const char* attach) + : Resource(model, name, lmm_constraint_new(maxminSystem, this, bconnection)) + , contentType_(xbt_strdup(content_type)) + , size_(size) + , usedSize_(0) + , typeId_(xbt_strdup(type_id)) + , writeActions_(std::vector()) { content_ = parseContent(content_name); attach_ = xbt_strdup(attach); @@ -175,18 +165,18 @@ sg_size_t Storage::getUsedSize(){ /********** * Action * **********/ -StorageAction::StorageAction(Model *model, double cost, bool failed, - Storage *storage, e_surf_action_storage_type_t type) -: Action(model, cost, failed) -, m_type(type), p_storage(storage), p_file(nullptr){ - progress = 0; +StorageAction::StorageAction(Model* model, double cost, bool failed, Storage* storage, + e_surf_action_storage_type_t type) + : Action(model, cost, failed), type_(type), storage_(storage), file_(nullptr) +{ + progress_ = 0; }; -StorageAction::StorageAction(Model *model, double cost, bool failed, lmm_variable_t var, - Storage *storage, e_surf_action_storage_type_t type) - : Action(model, cost, failed, var) - , m_type(type), p_storage(storage), p_file(nullptr){ - progress = 0; +StorageAction::StorageAction(Model* model, double cost, bool failed, lmm_variable_t var, Storage* storage, + e_surf_action_storage_type_t type) + : Action(model, cost, failed, var), type_(type), storage_(storage), file_(nullptr) +{ + progress_ = 0; } void StorageAction::setState(Action::State state){