X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/488dd54cbc91fad4cb04c9d0e92609a107ad1568..a2fc9093202ad92a65d242d6e5fe824106dc857a:/src/surf/storage.c diff --git a/src/surf/storage.c b/src/surf/storage.c index 268f141837..9de73f737b 100644 --- a/src/surf/storage.c +++ b/src/surf/storage.c @@ -36,6 +36,7 @@ static xbt_dynar_t storage_list; #define GENERIC_ACTION(action) GENERIC_LMM_ACTION(action).generic_action static xbt_dict_t parse_storage_content(char *filename, unsigned long *used_size); +static int storage_action_unref(surf_action_t action); static void storage_action_state_set(surf_action_t action, e_surf_action_state_t state); static surf_action_t storage_action_execute (void *storage, double size, e_surf_action_storage_type_t type); static void free_storage_content(void *p); @@ -102,7 +103,6 @@ static surf_action_t storage_action_unlink(void *storage, surf_file_t stream) xbt_dict_remove(content_dict,stream->name); free(stream->name); - stream->content = NULL; xbt_free(stream); return action; @@ -151,7 +151,6 @@ static surf_action_t storage_action_close(void *storage, surf_file_t fp) } free(fp->name); - fp->content = NULL; xbt_free(fp); surf_action_t action = storage_action_execute(storage,0, CLOSE); return action; @@ -231,7 +230,7 @@ static void* storage_create_resource(const char* id, const char* model,const cha { storage_t storage = NULL; - xbt_assert(!surf_storage_resource_by_name(id), + xbt_assert(!surf_storage_resource_priv(surf_storage_resource_by_name(id)), "Storage '%s' declared several times in the platform file", id); storage = (storage_t) surf_resource_new(sizeof(s_storage_t), @@ -276,8 +275,7 @@ static void storage_finalize(void) surf_model_exit(surf_storage_model); surf_storage_model = NULL; - if(storage_list) - xbt_dynar_free(&storage_list); + xbt_dynar_free(&storage_list); xbt_swag_free (storage_running_action_set_that_does_not_need_being_checked); @@ -517,7 +515,6 @@ static void surf_storage_model_init_internal(void) surf_storage_model->extension.storage.stat = storage_action_stat; surf_storage_model->extension.storage.unlink = storage_action_unlink; surf_storage_model->extension.storage.ls = storage_action_ls; - surf_storage_model->extension.storage.create_resource = storage_create_resource; if (!storage_maxmin_system) { storage_maxmin_system = lmm_system_new(storage_selective_update); @@ -593,25 +590,26 @@ static xbt_dict_t parse_storage_content(char *filename, unsigned long *used_size surf_stat_t content; - while ((read = getline(&line, &len, file)) != -1) { + while ((read = xbt_getline(&line, &len, file)) != -1) { + if (read){ content = xbt_new0(s_surf_stat_t,1); if(sscanf(line,"%s %d %s %s %ld %s %s %s",user_rights,&nb,user,group,&size,date,time,path)==8) { - content->stat.date = xbt_strdup(date); - content->stat.group = xbt_strdup(group); - content->stat.size = size; - content->stat.time = xbt_strdup(time); - content->stat.user = xbt_strdup(user); - content->stat.user_rights = xbt_strdup(user_rights); - *used_size += content->stat.size; - xbt_dict_set(parse_content,path,content,NULL); - } else { - xbt_die("Be sure of passing a good format for content file.\n"); - // You can generate this kind of file with command line: - // find /path/you/want -type f -exec ls -l {} \; 2>/dev/null > ./content.txt + content->stat.date = xbt_strdup(date); + content->stat.group = xbt_strdup(group); + content->stat.size = size; + content->stat.time = xbt_strdup(time); + content->stat.user = xbt_strdup(user); + content->stat.user_rights = xbt_strdup(user_rights); + *used_size += content->stat.size; + xbt_dict_set(parse_content,path,content,NULL); + } else { + xbt_die("Be sure of passing a good format for content file.\n"); + // You can generate this kind of file with command line: + // find /path/you/want -type f -exec ls -l {} \; 2>/dev/null > ./content.txt + } } } - if (line) - free(line); + free(line); fclose(file); return parse_content; } @@ -673,7 +671,7 @@ static void storage_parse_mount(sg_platf_mount_cbarg_t mount) XBT_DEBUG("ROUTING Mount '%s' on '%s'",mount->id, mount->name); s_mount_t mnt; - mnt.id = surf_storage_resource_by_name(mount->id); + mnt.id = surf_storage_resource_priv(surf_storage_resource_by_name(mount->id)); mnt.name = xbt_strdup(mount->name); if(!mount_list){