X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5fe438f9179eb65e78159a803705f51f7f470b08..f2df13795e01302813a6aef10825ec7e922ce530:/src/simix/smx_io.c diff --git a/src/simix/smx_io.c b/src/simix/smx_io.c index f504da422f..5bfbe2060e 100644 --- a/src/simix/smx_io.c +++ b/src/simix/smx_io.c @@ -49,26 +49,6 @@ void SIMIX_storage_destroy(void *s) free(storage); } -void* SIMIX_pre_file_get_data(smx_simcall_t simcall,smx_file_t fd){ - return SIMIX_file_get_data(fd); -} - -void* SIMIX_file_get_data(smx_file_t fd){ - xbt_assert((fd != NULL), "Invalid parameters (simix file is NULL)"); - - return fd->data; -} - -void SIMIX_pre_file_set_data(smx_simcall_t simcall, smx_file_t fd, void *data) { - SIMIX_file_set_data(fd, data); -} - -void SIMIX_file_set_data(smx_file_t fd, void *data){ - xbt_assert((fd != NULL), "Invalid parameter"); - - fd->data = data; -} - //SIMIX FILE READ void SIMIX_pre_file_read(smx_simcall_t simcall, smx_file_t fd, sg_size_t size) { @@ -140,16 +120,14 @@ smx_action_t SIMIX_file_write(smx_process_t process, smx_file_t fd, sg_size_t si } //SIMIX FILE OPEN -void SIMIX_pre_file_open(smx_simcall_t simcall, const char* mount, - const char* path) +void SIMIX_pre_file_open(smx_simcall_t simcall, const char* fullpath) { - smx_action_t action = SIMIX_file_open(simcall->issuer, mount, path); + smx_action_t action = SIMIX_file_open(simcall->issuer, fullpath); xbt_fifo_push(action->simcalls, simcall); simcall->issuer->waiting_action = action; } -smx_action_t SIMIX_file_open(smx_process_t process ,const char* mount, - const char* path) +smx_action_t SIMIX_file_open(smx_process_t process, const char* fullpath) { smx_action_t action; smx_host_t host = process->smx_host; @@ -168,7 +146,7 @@ smx_action_t SIMIX_file_open(smx_process_t process ,const char* mount, #endif action->io.host = host; - action->io.surf_io = surf_workstation_open(host, mount, path); + action->io.surf_io = surf_workstation_open(host, fullpath); surf_action_set_data(action->io.surf_io, action); XBT_DEBUG("Create io action %p", action); @@ -361,26 +339,6 @@ const char* SIMIX_storage_get_name(smx_storage_t storage){ return sg_storage_name(storage); } -void SIMIX_pre_storage_set_data(smx_simcall_t simcall, smx_storage_t storage, void *data) { - SIMIX_storage_set_data(storage, data); -} -void SIMIX_storage_set_data(smx_storage_t storage, void *data){ - xbt_assert((storage != NULL), "Invalid parameters"); - xbt_assert((SIMIX_storage_priv(storage)->data == NULL), "Data already set"); - - SIMIX_storage_priv(storage)->data = data; -} - -void* SIMIX_pre_storage_get_data(smx_simcall_t simcall,smx_storage_t storage){ - return SIMIX_storage_get_data(storage); -} - -void* SIMIX_storage_get_data(smx_storage_t storage){ - xbt_assert((storage != NULL), "Invalid parameters (simix storage is NULL)"); - - return SIMIX_storage_priv(storage)->data; -} - xbt_dict_t SIMIX_pre_storage_get_content(smx_simcall_t simcall, smx_storage_t storage){ return SIMIX_storage_get_content(storage); } @@ -395,6 +353,15 @@ sg_size_t SIMIX_storage_get_size(smx_storage_t storage){ return surf_storage_get_size(storage); } +const char* SIMIX_pre_storage_get_host(smx_simcall_t simcall, smx_storage_t storage){ + return SIMIX_storage_get_host(storage); +} + +const char* SIMIX_storage_get_host(smx_storage_t storage){ + xbt_assert((storage != NULL), "Invalid parameters"); + return surf_storage_get_host(storage); +} + void SIMIX_post_io(smx_action_t action) { xbt_fifo_item_t i; @@ -406,12 +373,12 @@ void SIMIX_post_io(smx_action_t action) xbt_fifo_foreach(action->simcalls,i,simcall,smx_simcall_t) { switch (simcall->call) { - case SIMCALL_FILE_OPEN:; + case SIMCALL_FILE_OPEN: { smx_file_t tmp = xbt_new(s_smx_file_t,1); tmp->surf_file = surf_storage_action_get_file(action->io.surf_io); simcall_file_open__set__result(simcall, tmp); break; - + } case SIMCALL_FILE_CLOSE: xbt_free(simcall_file_close__get__fd(simcall)); simcall_file_close__set__result(simcall, 0);