Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
Fix initialization order.
[simgrid.git] / src / simix / smx_process.c
index 62943b9..0ac19c0 100644 (file)
@@ -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);
 }
 
 /**