src/surf/storage_interface.cpp

   1 #include "storage_interface.hpp"
   2 #include "surf_private.h"
   3
   4 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(surf_storage, surf,
   5                                 "Logging specific to the SURF storage module");
   6
   7 xbt_lib_t storage_lib;
   8 int ROUTING_STORAGE_LEVEL;      //Routing for storagelevel
   9 int ROUTING_STORAGE_HOST_LEVEL;
  10 int SURF_STORAGE_LEVEL;
  11 xbt_lib_t storage_type_lib;
  12 int ROUTING_STORAGE_TYPE_LEVEL; //Routing for storage_type level
  13
  14 xbt_dynar_t mount_list = NULL;
  15 StorageModelPtr surf_storage_model = NULL;
  16
  17 /*********
  18  * Model *
  19  *********/
  20
  21 StorageModel::StorageModel() : Model("Storage") {
  22   p_storageList = NULL;
  23 }
  24
  25 StorageModel::~StorageModel(){
  26   lmm_system_free(p_maxminSystem);
  27
  28   surf_storage_model = NULL;
  29
  30   xbt_dynar_free(&p_storageList);
  31 }
  32
  33 /************
  34  * Resource *
  35  ************/
  36
  37 Storage::Storage(const char* type_id, char *content_name, char *content_type, sg_size_t size)
  38 :  p_contentType(content_type),
  39    m_size(size), m_usedSize(0), p_typeId(xbt_strdup(type_id)), p_writeActions(xbt_dynar_new(sizeof(ActionPtr),NULL))
  40 {
  41   p_content = parseContent(content_name);
  42   m_stateCurrent = SURF_RESOURCE_ON;
  43 }
  44
  45 Storage::~Storage(){
  46   xbt_dict_free(&p_content);
  47   xbt_dynar_free(&p_writeActions);
  48   free(p_typeId);
  49   free(p_contentType);
  50 }
  51
  52 xbt_dict_t Storage::parseContent(char *filename)
  53 {
  54   m_usedSize = 0;
  55   if ((!filename) || (strcmp(filename, "") == 0))
  56     return NULL;
  57
  58   xbt_dict_t parse_content = xbt_dict_new_homogeneous(xbt_free);
  59   FILE *file = NULL;
  60
  61   file = surf_fopen(filename, "r");
  62   xbt_assert(file != NULL, "Cannot open file '%s' (path=%s)", filename,
  63               xbt_str_join(surf_path, ":"));
  64
  65   char *line = NULL;
  66   size_t len = 0;
  67   ssize_t read;
  68   char path[1024];
  69   sg_size_t size;
  70
  71
  72   while ((read = xbt_getline(&line, &len, file)) != -1) {
  73     if (read){
  74     if(sscanf(line,"%s %llu", path, &size) == 2) {
  75         m_usedSize += size;
  76         sg_size_t *psize = xbt_new(sg_size_t, 1);
  77         *psize = size;
  78         xbt_dict_set(parse_content,path,psize,NULL);
  79       } else {
  80         xbt_die("Be sure of passing a good format for content file.\n");
  81       }
  82     }
  83   }
  84   free(line);
  85   fclose(file);
  86   return parse_content;
  87 }
  88
  89 bool Storage::isUsed()
  90 {
  91   THROW_UNIMPLEMENTED;
  92   return false;
  93 }
  94
  95 void Storage::updateState(tmgr_trace_event_t /*event_type*/, double /*value*/, double /*date*/)
  96 {
  97   THROW_UNIMPLEMENTED;
  98 }
  99
 100 xbt_dict_t Storage::getContent()
 101 {
 102   /* For the moment this action has no cost, but in the future we could take in account access latency of the disk */
 103   /*surf_action_t action = storage_action_execute(storage,0, LS);*/
 104
 105   xbt_dict_t content_dict = xbt_dict_new_homogeneous(NULL);
 106   xbt_dict_cursor_t cursor = NULL;
 107   char *file;
 108   sg_size_t *psize;
 109
 110   xbt_dict_foreach(p_content, cursor, file, psize){
 111     xbt_dict_set(content_dict,file,psize,NULL);
 112   }
 113   return content_dict;
 114 }
 115
 116 sg_size_t Storage::getSize(){
 117   return m_size;
 118 }
 119
 120 StorageLmm::StorageLmm(lmm_system_t maxminSystem, double bread, double bwrite, double bconnection,
 121              const char* type_id, char *content_name, char *content_type, sg_size_t size)
 122  :  ResourceLmm(lmm_constraint_new(maxminSystem, this, bconnection)), Storage(type_id, content_name, content_type, size) {
 123   XBT_DEBUG("Create resource with Bconnection '%f' Bread '%f' Bwrite '%f' and Size '%llu'", bconnection, bread, bwrite, size);
 124   p_constraintRead  = lmm_constraint_new(maxminSystem, this, bread);
 125   p_constraintWrite = lmm_constraint_new(maxminSystem, this, bwrite);
 126 }
 127
 128 /**********
 129  * Action *
 130  **********/
 131 StorageAction::StorageAction(StoragePtr storage, e_surf_action_storage_type_t type)
 132 : m_type(type), p_storage(storage), p_file(NULL), p_lsDict(NULL)
 133 {
 134 };
 135
 136 StorageActionLmm::StorageActionLmm(StorageLmmPtr storage, e_surf_action_storage_type_t type, lmm_variable_t var)
 137   : StorageAction(storage, type), ActionLmm(var) {
 138 }
 139