X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/8d0922724a3108d9535ea82a1cceab9782eb60f4..a1ba88402bfb88a278d2e7c849441a9ed4a26120:/src/simix/smx_host.c diff --git a/src/simix/smx_host.c b/src/simix/smx_host.c index afc406c6d2..de979ccc90 100644 --- a/src/simix/smx_host.c +++ b/src/simix/smx_host.c @@ -178,7 +178,8 @@ void SIMIX_host_set_data(smx_host_t host, void *data) } smx_action_t SIMIX_host_execute(const char *name, smx_host_t host, - double computation_amount) + double computation_amount, + double priority) { /* alloc structures and initialize */ smx_action_t action = xbt_new0(s_smx_action_t, 1); @@ -198,6 +199,7 @@ smx_action_t SIMIX_host_execute(const char *name, smx_host_t host, surf_workstation_model->extension.workstation.execute(host->host, computation_amount); surf_workstation_model->action_data_set(action->execution.surf_exec, action); + surf_workstation_model->set_priority(action->execution.surf_exec, priority); } #ifdef HAVE_TRACING @@ -311,6 +313,7 @@ void SIMIX_pre_host_execution_wait(smx_req_t req) if (MC_IS_ENABLED){ action->state = SIMIX_DONE; SIMIX_execution_finish(action); + return; } /* If the action is already finished then perform the error handling */ @@ -368,8 +371,12 @@ void SIMIX_execution_finish(smx_action_t action) THROW_IMPOSSIBLE; } req->issuer->waiting_action = NULL; + req->host_execution_wait.result = action->state; SIMIX_request_answer(req); } + + /* We no longer need it */ + SIMIX_host_execution_destroy(action); } void SIMIX_post_host_execute(smx_action_t action)