src/simix/smx_action.c

   1 /*      $Id$     */
   2
   3 /* Copyright (c) 2007 Arnaud Legrand, Bruno Donnassolo.
   4    All rights reserved.                                          */
   5
   6 /* This program is free software; you can redistribute it and/or modify it
   7  * under the terms of the license (GNU LGPL) which comes with this package. */
   8
   9 #include "private.h"
  10 #include "xbt/log.h"
  11
  12 XBT_LOG_NEW_DEFAULT_SUBCATEGORY(simix_action, simix,
  13                                 "Logging specific to SIMIX (action)");
  14
  15 /************************************* Actions *********************************/
  16
  17 smx_action_t SIMIX_communicate(smx_host_t sender,smx_host_t receiver,char * name, double size, double rate)
  18 {
  19
  20         /* alloc structures */
  21         smx_action_t act = xbt_new0(s_smx_action_t,1);
  22         act->simdata = xbt_new0(s_simdata_action_t,1);
  23         simdata_action_t simdata = act->simdata;
  24         simdata->cond_list = xbt_fifo_new();
  25
  26         /* initialize them */
  27         act->name = xbt_strdup(name);
  28         simdata->action_block=0;
  29         simdata->cond_process=NULL;
  30         simdata->timeout_cond = NULL;
  31
  32
  33         simdata->surf_action = surf_workstation_resource->extension_public->
  34                 communicate(sender->simdata->host,
  35                                 receiver->simdata->host, size, rate);
  36         surf_workstation_resource->common_public->action_set_data(simdata->surf_action,act);
  37
  38         return act;
  39 }
  40
  41 smx_action_t SIMIX_execute(smx_host_t host, char * name, double amount)
  42 {
  43         CHECK_HOST();
  44         /* alloc structures */
  45         smx_action_t act = xbt_new0(s_smx_action_t,1);
  46         act->simdata = xbt_new0(s_simdata_action_t,1);
  47         simdata_action_t simdata = act->simdata;
  48         simdata->cond_list = xbt_fifo_new();
  49
  50         /* initialize them */
  51         simdata->source = host;
  52         act-> name = xbt_strdup(name);
  53         simdata->action_block=0;
  54         simdata->cond_process=NULL;
  55         simdata->timeout_cond = NULL;
  56
  57         /* set communication */
  58         simdata->surf_action = surf_workstation_resource->extension_public->
  59                 execute(host->simdata->host, amount);
  60
  61         surf_workstation_resource->common_public->action_set_data(simdata->surf_action,act);
  62
  63         return act;
  64 }
  65
  66 void SIMIX_action_cancel(smx_action_t action)
  67 {
  68   xbt_assert0((action != NULL), "Invalid parameter");
  69
  70   if(action->simdata->surf_action) {
  71     surf_workstation_resource->common_public->action_cancel(action->simdata->surf_action);
  72   }
  73   return;
  74 }
  75
  76 void SIMIX_action_set_priority(smx_action_t action, double priority)
  77 {
  78         xbt_assert0( (action != NULL) && (action->simdata != NULL), "Invalid parameter" );
  79
  80         surf_workstation_resource->common_public->
  81                 set_priority(action->simdata->surf_action, priority);
  82         return;
  83 }
  84
  85 void SIMIX_action_destroy(smx_action_t action)
  86 {
  87
  88         xbt_assert0((action != NULL), "Invalid parameter");
  89
  90         xbt_assert1((xbt_fifo_size(action->simdata->cond_list)==0),
  91                         "Conditional list not empty %d. There is a problem. Cannot destroy it now!", xbt_fifo_size(action->simdata->cond_list));
  92
  93         if(action->name) free(action->name);
  94
  95         xbt_fifo_free(action->simdata->cond_list);
  96
  97         if(action->simdata->surf_action)
  98                 action->simdata->surf_action->resource_type->common_public->action_free(action->simdata->surf_action);
  99
 100         return;
 101 }
 102
 103 void SIMIX_register_action_to_condition(smx_action_t action, smx_cond_t cond)
 104 {
 105         xbt_assert0( (action != NULL) && (cond != NULL), "Invalid parameters");
 106
 107         xbt_fifo_push(cond->actions,action);
 108 }
 109
 110 void __SIMIX_wait_for_action(smx_process_t process, smx_action_t action)
 111 {
 112         e_surf_action_state_t state = SURF_ACTION_NOT_IN_THE_SYSTEM;
 113         simdata_action_t simdata = action->simdata;
 114
 115         xbt_assert0(((process != NULL) && (action != NULL) && (action->simdata != NULL)), "Invalid parameters");
 116
 117         /* change context while the action is running  */
 118         do {
 119                 xbt_context_yield();
 120                 state=surf_workstation_resource->common_public->action_get_state(simdata->surf_action);
 121         } while (state==SURF_ACTION_RUNNING);
 122
 123         /* action finished, we can continue */
 124
 125         if(state == SURF_ACTION_DONE) {
 126                 if(surf_workstation_resource->common_public->action_free(simdata->surf_action))
 127                         simdata->surf_action = NULL;
 128         } else if(surf_workstation_resource->extension_public->
 129                         get_state(SIMIX_process_get_host(process)->simdata->host)
 130                         == SURF_CPU_OFF) {
 131                 if(surf_workstation_resource->common_public->action_free(simdata->surf_action))
 132                         simdata->surf_action = NULL;
 133         } else {
 134                 if(surf_workstation_resource->common_public->action_free(simdata->surf_action))
 135                         simdata->surf_action = NULL;
 136         }
 137         return;
 138
 139 }