+ unsigned int cpt;
+ smx_process_arg_t arg;
+ xbt_dynar_t process_list = SIMIX_host_priv(host)->auto_restart_processes;
+ if (!process_list)
+ return;
+
+ xbt_dynar_foreach (process_list, cpt, arg) {
+
+ smx_process_t process;
+
+ XBT_DEBUG("Restarting Process %s(%s) right now", arg->argv[0], arg->hostname);
+ if (simix_global->create_process_function) {
+ simix_global->create_process_function(&process,
+ arg->argv[0],
+ arg->code,
+ NULL,
+ arg->hostname,
+ arg->kill_time,
+ arg->argc,
+ arg->argv,
+ arg->properties,
+ arg->auto_restart);
+ } else {
+ simcall_process_create(&process,
+ arg->argv[0],
+ arg->code,
+ NULL,
+ arg->hostname,
+ arg->kill_time,
+ arg->argc,
+ arg->argv,
+ arg->properties,
+ arg->auto_restart);
+
+ }
+ /* arg->argv is used by the process created above. Hide it to
+ * _SIMIX_host_free_process_arg() which is called by xbt_dynar_reset()
+ * below. */
+ arg->argc = 0;
+ arg->argv = NULL;
+ }
+ xbt_dynar_reset(process_list);
+}
+
+void SIMIX_host_autorestart(smx_host_t host)
+{
+ if(simix_global->autorestart)
+ simix_global->autorestart(host);
+ else
+ xbt_die("No function for simix_global->autorestart");
+}
+
+void SIMIX_pre_host_set_data(smx_simcall_t simcall, smx_host_t host, void *data) {
+ SIMIX_host_set_data(host, data);
+}
+void SIMIX_host_set_data(smx_host_t host, void *data){
+ xbt_assert((host != NULL), "Invalid parameters");
+ xbt_assert((SIMIX_host_priv(host)->data == NULL), "Data already set");
+
+ SIMIX_host_priv(host)->data = data;
+}
+
+smx_action_t SIMIX_pre_host_execute(smx_simcall_t simcall,const char *name,
+ smx_host_t host, double computation_amount, double priority, double bound, unsigned long affinity_mask){
+ return SIMIX_host_execute(name, host, computation_amount, priority, bound, affinity_mask);
+}
+smx_action_t SIMIX_host_execute(const char *name,
+ smx_host_t host, double computation_amount, double priority, double bound, unsigned long affinity_mask){
+
+ /* alloc structures and initialize */
+ smx_action_t action = xbt_mallocator_get(simix_global->action_mallocator);
+ action->type = SIMIX_ACTION_EXECUTE;
+ action->name = xbt_strdup(name);
+ action->state = SIMIX_RUNNING;
+ action->execution.host = host;
+
+#ifdef HAVE_TRACING
+ action->category = NULL;
+#endif
+
+ surf_model_t ws_model = surf_resource_model(host, SURF_WKS_LEVEL);
+ /* set surf's action */
+ if (!MC_is_active()) {
+ action->execution.surf_exec = ws_model->extension.workstation.execute(host, computation_amount);
+ ws_model->action_data_set(action->execution.surf_exec, action);
+ ws_model->set_priority(action->execution.surf_exec, priority);
+
+ /* Note (hypervisor): for multicore, the bound value being passed to the
+ * surf layer should not be zero (i.e., unlimited). It should be the
+ * capacity of a CPU core. */
+ if (bound == 0)
+ ws_model->set_bound(action->execution.surf_exec, SIMIX_host_get_speed(host));
+ else
+ ws_model->set_bound(action->execution.surf_exec, bound);
+
+ if (affinity_mask != 0) {
+ /* just a double check to confirm that this host is the host where this task is running. */
+ xbt_assert(action->execution.host == host);
+ ws_model->set_affinity(action->execution.surf_exec, host, affinity_mask);
+ }
+ }
+
+ XBT_DEBUG("Create execute action %p", action);
+
+ return action;
+}
+
+smx_action_t SIMIX_pre_host_parallel_execute(smx_simcall_t simcall, const char *name,
+ int host_nb, smx_host_t *host_list,
+ double *computation_amount, double *communication_amount,
+ double amount, double rate){
+ return SIMIX_host_parallel_execute(name, host_nb, host_list, computation_amount,
+ communication_amount, amount, rate);
+}
+smx_action_t SIMIX_host_parallel_execute(const char *name,
+ int host_nb, smx_host_t *host_list,
+ double *computation_amount, double *communication_amount,
+ double amount, double rate){
+
+ void **workstation_list = NULL;
+ int i;
+
+ /* alloc structures and initialize */
+ smx_action_t action = xbt_mallocator_get(simix_global->action_mallocator);
+ action->type = SIMIX_ACTION_PARALLEL_EXECUTE;
+ action->name = xbt_strdup(name);
+ action->state = SIMIX_RUNNING;
+ action->execution.host = NULL; /* FIXME: do we need the list of hosts? */
+
+#ifdef HAVE_TRACING
+ action->category = NULL;
+#endif
+
+ /* set surf's action */
+ workstation_list = xbt_new0(void *, host_nb);
+ for (i = 0; i < host_nb; i++)
+ workstation_list[i] = host_list[i];
+
+
+ /* FIXME: what happens if host_list contains VMs and PMs. If
+ * execute_parallel_task() does not change the state of the model, we can mix
+ * them. */
+ surf_model_t ws_model = surf_resource_model(host_list[0], SURF_WKS_LEVEL);
+ for (i = 1; i < host_nb; i++) {
+ surf_model_t ws_model_tmp = surf_resource_model(host_list[i], SURF_WKS_LEVEL);
+ if (ws_model_tmp != ws_model) {
+ XBT_CRITICAL("mixing VMs and PMs is not supported");
+ DIE_IMPOSSIBLE;
+ }
+ }
+
+ /* set surf's action */
+ if (!MC_is_active()) {
+ action->execution.surf_exec =
+ ws_model->extension.workstation.
+ execute_parallel_task(host_nb, workstation_list, computation_amount,
+ communication_amount, rate);
+
+ ws_model->action_data_set(action->execution.surf_exec, action);
+ }
+ XBT_DEBUG("Create parallel execute action %p", action);
+
+ return action;
+}
+
+static surf_model_t get_ws_model_from_action(smx_action_t action)
+{
+ xbt_assert(action->type == SIMIX_ACTION_EXECUTE);
+ smx_host_t host = action->execution.host;
+ surf_model_t model = surf_resource_model(host, SURF_WKS_LEVEL);
+
+ xbt_assert((model == surf_workstation_model) || (model == surf_vm_workstation_model));
+
+ return model;
+}
+
+void SIMIX_pre_host_execution_destroy(smx_simcall_t simcall, smx_action_t action){
+ SIMIX_host_execution_destroy(action);
+}
+void SIMIX_host_execution_destroy(smx_action_t action){
+ XBT_DEBUG("Destroy action %p", action);
+
+ surf_model_t ws_model = get_ws_model_from_action(action);
+
+ if (action->execution.surf_exec) {
+ ws_model->action_unref(action->execution.surf_exec);
+ action->execution.surf_exec = NULL;
+ }
+ xbt_free(action->name);
+ xbt_mallocator_release(simix_global->action_mallocator, action);
+}
+
+void SIMIX_pre_host_execution_cancel(smx_simcall_t simcall, smx_action_t action){
+ SIMIX_host_execution_cancel(action);
+}
+void SIMIX_host_execution_cancel(smx_action_t action){
+ XBT_DEBUG("Cancel action %p", action);
+
+ surf_model_t ws_model = get_ws_model_from_action(action);
+
+ if (action->execution.surf_exec)
+ ws_model->action_cancel(action->execution.surf_exec);
+}
+
+double SIMIX_pre_host_execution_get_remains(smx_simcall_t simcall, smx_action_t action){
+ return SIMIX_host_execution_get_remains(action);
+}
+double SIMIX_host_execution_get_remains(smx_action_t action){
+ double result = 0.0;
+ surf_model_t ws_model = get_ws_model_from_action(action);
+
+ if (action->state == SIMIX_RUNNING)
+ result = ws_model->get_remains(action->execution.surf_exec);
+
+ return result;
+}
+
+e_smx_state_t SIMIX_pre_host_execution_get_state(smx_simcall_t simcall, smx_action_t action){
+ return SIMIX_host_execution_get_state(action);
+}
+e_smx_state_t SIMIX_host_execution_get_state(smx_action_t action){
+ return action->state;
+}
+
+void SIMIX_pre_host_execution_set_priority(smx_simcall_t simcall, smx_action_t action,
+ double priority){
+ SIMIX_host_execution_set_priority(action, priority);
+}
+void SIMIX_host_execution_set_priority(smx_action_t action, double priority){
+ surf_model_t ws_model = get_ws_model_from_action(action);
+
+ if(action->execution.surf_exec)
+ ws_model->set_priority(action->execution.surf_exec, priority);
+}
+
+void SIMIX_pre_host_execution_set_bound(smx_simcall_t simcall, smx_action_t action,
+ double bound){
+ SIMIX_host_execution_set_bound(action, bound);
+}
+void SIMIX_host_execution_set_bound(smx_action_t action, double bound){
+ surf_model_t ws_model = get_ws_model_from_action(action);