X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/67c91d5b8652b0e76801e9cfc7d965a360237152..5b3677b425b9cc6949c1573d59ac772540cbf4b2:/src/simix/smx_synchro.c diff --git a/src/simix/smx_synchro.c b/src/simix/smx_synchro.c index c9d14d0a46..22e718069d 100644 --- a/src/simix/smx_synchro.c +++ b/src/simix/smx_synchro.c @@ -1,4 +1,4 @@ -/* Copyright (c) 2007-2013. The SimGrid Team. +/* Copyright (c) 2007-2014. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -23,14 +23,15 @@ static void _SIMIX_sem_wait(smx_sem_t sem, double timeout, smx_process_t issuer, static smx_action_t SIMIX_synchro_wait(smx_host_t smx_host, double timeout) { XBT_IN("(%p, %f)",smx_host,timeout); + smx_action_t action; action = xbt_mallocator_get(simix_global->action_mallocator); action->type = SIMIX_ACTION_SYNCHRO; action->name = xbt_strdup("synchro"); action->synchro.sleep = - surf_workstation_model->extension.workstation.sleep(smx_host, timeout); + surf_workstation_sleep(smx_host, timeout); - surf_workstation_model->action_data_set(action->synchro.sleep, action); + surf_action_set_data(action->synchro.sleep, action); XBT_OUT(); return action; } @@ -70,7 +71,8 @@ void SIMIX_synchro_destroy(smx_action_t action) { XBT_IN("(%p)",action); XBT_DEBUG("Destroying synchro %p", action); - action->synchro.sleep->model_type->action_unref(action->synchro.sleep); + xbt_assert(action->type == SIMIX_ACTION_SYNCHRO); + surf_action_unref(action->synchro.sleep); xbt_free(action->name); xbt_mallocator_release(simix_global->action_mallocator, action); XBT_OUT(); @@ -79,9 +81,10 @@ void SIMIX_synchro_destroy(smx_action_t action) void SIMIX_post_synchro(smx_action_t action) { XBT_IN("(%p)",action); - if (surf_workstation_model->action_state_get(action->synchro.sleep) == SURF_ACTION_FAILED) + xbt_assert(action->type == SIMIX_ACTION_SYNCHRO); + if (surf_action_get_state(action->synchro.sleep) == SURF_ACTION_FAILED) action->state = SIMIX_FAILED; - else if(surf_workstation_model->action_state_get(action->synchro.sleep) == SURF_ACTION_DONE) + else if(surf_action_get_state(action->synchro.sleep) == SURF_ACTION_DONE) action->state = SIMIX_SRC_TIMEOUT; SIMIX_synchro_finish(action);