X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/9c6d72b5bbc9f9b0f9d61c8964fabacaaa2a9914..1187511bb7f9942605f779843be0adb52e46c1a7:/src/simix/smx_io.c diff --git a/src/simix/smx_io.c b/src/simix/smx_io.c index e6385305dc..438d87dca7 100644 --- a/src/simix/smx_io.c +++ b/src/simix/smx_io.c @@ -1,4 +1,4 @@ -/* Copyright (c) 2007, 2008, 2009, 2010. The SimGrid Team. +/* Copyright (c) 2007-2010, 2012-2013. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -55,16 +55,14 @@ void SIMIX_file_set_data(smx_file_t fd, void *data){ } //SIMIX FILE READ -void SIMIX_pre_file_read(smx_simcall_t simcall, size_t size, - smx_file_t fd) +void SIMIX_pre_file_read(smx_simcall_t simcall, smx_file_t fd, sg_storage_size_t size) { - smx_action_t action = SIMIX_file_read(simcall->issuer, size, fd); + smx_action_t action = SIMIX_file_read(simcall->issuer, fd, size); xbt_fifo_push(action->simcalls, simcall); simcall->issuer->waiting_action = action; } -smx_action_t SIMIX_file_read(smx_process_t process, size_t size, - smx_file_t fd) +smx_action_t SIMIX_file_read(smx_process_t process, smx_file_t fd, sg_storage_size_t size) { smx_action_t action; smx_host_t host = process->smx_host; @@ -85,8 +83,7 @@ smx_action_t SIMIX_file_read(smx_process_t process, size_t size, action->io.host = host; action->io.surf_io = - surf_workstation_model->extension.workstation.read(host, size, - fd->surf_file); + surf_workstation_model->extension.workstation.read(host, fd->surf_file, size); surf_workstation_model->action_data_set(action->io.surf_io, action); XBT_DEBUG("Create io action %p", action); @@ -95,16 +92,14 @@ smx_action_t SIMIX_file_read(smx_process_t process, size_t size, } //SIMIX FILE WRITE -void SIMIX_pre_file_write(smx_simcall_t simcall, size_t size, - smx_file_t fd) +void SIMIX_pre_file_write(smx_simcall_t simcall, smx_file_t fd, sg_storage_size_t size) { - smx_action_t action = SIMIX_file_write(simcall->issuer, size, fd); + smx_action_t action = SIMIX_file_write(simcall->issuer, fd, size); xbt_fifo_push(action->simcalls, simcall); simcall->issuer->waiting_action = action; } -smx_action_t SIMIX_file_write(smx_process_t process, - size_t size, smx_file_t fd) +smx_action_t SIMIX_file_write(smx_process_t process, smx_file_t fd, sg_storage_size_t size) { smx_action_t action; smx_host_t host = process->smx_host; @@ -125,8 +120,7 @@ smx_action_t SIMIX_file_write(smx_process_t process, action->io.host = host; action->io.surf_io = - surf_workstation_model->extension.workstation.write(host, size, - fd->surf_file); + surf_workstation_model->extension.workstation.write(host, fd->surf_file, size); surf_workstation_model->action_data_set(action->io.surf_io, action); XBT_DEBUG("Create io action %p", action); @@ -227,7 +221,7 @@ int SIMIX_file_unlink(smx_process_t process, smx_file_t fd) } if (surf_workstation_model->extension.workstation.unlink(host, fd->surf_file)){ - fd->surf_file = NULL; + xbt_free(fd); return 1; } else return 0; @@ -266,12 +260,12 @@ smx_action_t SIMIX_file_ls(smx_process_t process, const char* mount, const char return action; } -size_t SIMIX_pre_file_get_size(smx_simcall_t simcall, smx_file_t fd) +sg_storage_size_t SIMIX_pre_file_get_size(smx_simcall_t simcall, smx_file_t fd) { return SIMIX_file_get_size(simcall->issuer, fd); } -size_t SIMIX_file_get_size(smx_process_t process, smx_file_t fd) +sg_storage_size_t SIMIX_file_get_size(smx_process_t process, smx_file_t fd) { smx_host_t host = process->smx_host; return surf_workstation_model->extension.workstation.get_size(host, @@ -290,23 +284,23 @@ xbt_dynar_t SIMIX_file_get_info(smx_process_t process, smx_file_t fd) fd->surf_file); } -size_t SIMIX_pre_storage_get_free_size(smx_simcall_t simcall, const char* name) +sg_storage_size_t SIMIX_pre_storage_get_free_size(smx_simcall_t simcall, const char* name) { return SIMIX_storage_get_free_size(simcall->issuer, name); } -size_t SIMIX_storage_get_free_size(smx_process_t process, const char* name) +sg_storage_size_t SIMIX_storage_get_free_size(smx_process_t process, const char* name) { smx_host_t host = process->smx_host; return surf_workstation_model->extension.workstation.get_free_size(host,name); } -size_t SIMIX_pre_storage_get_used_size(smx_simcall_t simcall, const char* name) +sg_storage_size_t SIMIX_pre_storage_get_used_size(smx_simcall_t simcall, const char* name) { return SIMIX_storage_get_used_size(simcall->issuer, name); } -size_t SIMIX_storage_get_used_size(smx_process_t process, const char* name) +sg_storage_size_t SIMIX_storage_get_used_size(smx_process_t process, const char* name) { smx_host_t host = process->smx_host; return surf_workstation_model->extension.workstation.get_used_size(host,name);