X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ec16845133f5f1b5262d2d77d8ba22824fa8a446..a78b29bf9787d3544aadaa7970e349cd9810a81b:/src/simix/smx_process.c diff --git a/src/simix/smx_process.c b/src/simix/smx_process.c index a9e96fabfc..3296198782 100644 --- a/src/simix/smx_process.c +++ b/src/simix/smx_process.c @@ -136,7 +136,7 @@ void SIMIX_process_create(smx_process_t *process, else { *process = xbt_new0(s_smx_process_t, 1); - xbt_assert0(((code != NULL) && (host != NULL)), "Invalid parameters"); + xbt_assert(((code != NULL) && (host != NULL)), "Invalid parameters"); /* Process data */ (*process)->pid = simix_process_maxpid++; @@ -234,16 +234,17 @@ void SIMIX_process_killall(smx_process_t issuer) } void SIMIX_process_change_host(smx_process_t process, - const char *source, const char *dest) + smx_host_t dest) { - smx_host_t h1 = NULL; - smx_host_t h2 = NULL; - xbt_assert0((process != NULL), "Invalid parameters"); - h1 = SIMIX_host_get_by_name(source); - h2 = SIMIX_host_get_by_name(dest); - process->smx_host = h2; - xbt_swag_remove(process, h1->process_list); - xbt_swag_insert(process, h2->process_list); + xbt_assert((process != NULL), "Invalid parameters"); + xbt_swag_remove(process, process->smx_host->process_list); + process->smx_host = dest; + xbt_swag_insert(process, dest->process_list); +} + +void SIMIX_pre_process_change_host(smx_process_t process, smx_host_t dest) +{ + process->new_host = dest; } void SIMIX_pre_process_suspend(smx_req_t req) @@ -291,7 +292,7 @@ void SIMIX_process_suspend(smx_process_t process, smx_process_t issuer) void SIMIX_process_resume(smx_process_t process, smx_process_t issuer) { - xbt_assert0((process != NULL), "Invalid parameters"); + xbt_assert((process != NULL), "Invalid parameters"); process->suspended = 0; @@ -518,6 +519,11 @@ void SIMIX_process_yield(void) self->doexception = 0; RETHROW; } + + if (self->new_host) { + SIMIX_process_change_host(self, self->new_host); + self->new_host = NULL; + } } /* callback: context fetching */