X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0e9c0448c6566825b170b98ecff716b098bda10e..0c43de62fbe4bfc243d6512296e09207e80bcd54:/src/simix/smx_process.c diff --git a/src/simix/smx_process.c b/src/simix/smx_process.c index 62943b9704..0ac19c0df0 100644 --- a/src/simix/smx_process.c +++ b/src/simix/smx_process.c @@ -694,11 +694,9 @@ smx_action_t SIMIX_process_sleep(smx_process_t process, double duration) { smx_action_t action; smx_host_t host = process->smx_host; - surf_model_t ws_model = surf_resource_model(host, SURF_WKS_LEVEL); /* check if the host is active */ - if (ws_model->extension. - workstation.get_state(host) != SURF_RESOURCE_ON) { + if (surf_resource_get_state(surf_workstation_resource_priv(host)) != SURF_RESOURCE_ON) { THROWF(host_error, 0, "Host %s failed, you cannot call this function", sg_host_name(host)); } @@ -712,9 +710,9 @@ smx_action_t SIMIX_process_sleep(smx_process_t process, double duration) action->sleep.host = host; action->sleep.surf_sleep = - ws_model->extension.workstation.sleep(host, duration); + surf_workstation_sleep(host, duration); - ws_model->action_data_set(action->sleep.surf_sleep, action); + surf_action_set_data(action->sleep.surf_sleep, action); XBT_DEBUG("Create sleep action %p", action); return action; @@ -726,12 +724,10 @@ void SIMIX_post_process_sleep(smx_action_t action) e_smx_state_t state; xbt_assert(action->type == SIMIX_ACTION_SLEEP); - smx_host_t host = action->sleep.host; - surf_model_t ws_model = surf_resource_model(host, SURF_WKS_LEVEL); while ((simcall = xbt_fifo_shift(action->simcalls))) { - switch(ws_model->action_state_get(action->sleep.surf_sleep)){ + switch(surf_action_get_state(action->sleep.surf_sleep)){ case SURF_ACTION_FAILED: simcall->issuer->context->iwannadie = 1; //SMX_EXCEPTION(simcall->issuer, host_error, 0, "Host failed"); @@ -746,8 +742,7 @@ void SIMIX_post_process_sleep(smx_action_t action) THROW_IMPOSSIBLE; break; } - if (ws_model->extension. - workstation.get_state(simcall->issuer->smx_host) != SURF_RESOURCE_ON) { + if (surf_resource_get_state(surf_workstation_resource_priv(simcall->issuer->smx_host)) != SURF_RESOURCE_ON) { simcall->issuer->context->iwannadie = 1; } simcall_process_sleep__set__result(simcall, state); @@ -764,27 +759,20 @@ void SIMIX_process_sleep_destroy(smx_action_t action) xbt_assert(action->type == SIMIX_ACTION_SLEEP); if (action->sleep.surf_sleep) - action->sleep.surf_sleep->model_obj->action_unref(action->sleep.surf_sleep); + surf_action_unref(action->sleep.surf_sleep); xbt_mallocator_release(simix_global->action_mallocator, action); } void SIMIX_process_sleep_suspend(smx_action_t action) { xbt_assert(action->type == SIMIX_ACTION_SLEEP); - smx_host_t host = action->sleep.host; - surf_model_t ws_model = surf_resource_model(host, SURF_WKS_LEVEL); - - ws_model->suspend(action->sleep.surf_sleep); + surf_action_suspend(action->sleep.surf_sleep); } void SIMIX_process_sleep_resume(smx_action_t action) { xbt_assert(action->type == SIMIX_ACTION_SLEEP); - smx_host_t host = action->sleep.host; - surf_model_t ws_model = surf_resource_model(host, SURF_WKS_LEVEL); - XBT_DEBUG("%p ws_model", ws_model); - - ws_model->resume(action->sleep.surf_sleep); + surf_action_resume(action->sleep.surf_sleep); } /**