X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5a5e8338f6d18da29438ec26f96970afb7579992..ed049f0370888f3b2ffd89f714492811aa8ef154:/src/simix/smx_host.c diff --git a/src/simix/smx_host.c b/src/simix/smx_host.c index 40f3c73e24..a98b38ba78 100644 --- a/src/simix/smx_host.c +++ b/src/simix/smx_host.c @@ -33,11 +33,11 @@ smx_host_t SIMIX_host_create(const char *name, /* Update global variables */ xbt_lib_set(host_lib,name,SIMIX_HOST_LEVEL,smx_host); - + return xbt_lib_get_elm_or_null(host_lib, name); } -void SIMIX_pre_host_on(smx_simcall_t simcall, smx_host_t h) +void simcall_HANDLER_host_on(smx_simcall_t simcall, smx_host_t h) { SIMIX_host_on(h); } @@ -53,42 +53,47 @@ void SIMIX_host_on(smx_host_t h) xbt_assert((host != NULL), "Invalid parameters"); if (surf_resource_get_state(surf_workstation_resource_priv(h))==SURF_RESOURCE_OFF) { - surf_resource_set_state(surf_workstation_resource_priv(h), SURF_RESOURCE_ON); + surf_resource_set_state(surf_workstation_resource_priv(h), SURF_RESOURCE_ON); + unsigned int cpt; smx_process_arg_t arg; xbt_dynar_foreach(host->boot_processes,cpt,arg) { smx_process_t process; + char** argv = xbt_new(char*, arg->argc); + for (int i=0; iargc; i++) + argv[i] = xbt_strdup(arg->argv[i]); + XBT_DEBUG("Booting 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], + argv[0], arg->code, NULL, arg->hostname, arg->kill_time, arg->argc, - arg->argv, + argv, arg->properties, - arg->auto_restart); - } - else { + arg->auto_restart, + NULL); + } 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[0], + arg->code, + NULL, + arg->hostname, + arg->kill_time, + arg->argc, + argv, + arg->properties, + arg->auto_restart); } } } } -void SIMIX_pre_host_off(smx_simcall_t simcall, smx_host_t h) +void simcall_HANDLER_host_off(smx_simcall_t simcall, smx_host_t h) { SIMIX_host_off(h, simcall->issuer); } @@ -102,7 +107,7 @@ void SIMIX_host_off(smx_host_t h, smx_process_t issuer) smx_host_priv_t host = SIMIX_host_priv(h); xbt_assert((host != NULL), "Invalid parameters"); - + if (surf_resource_get_state(surf_workstation_resource_priv(h))==SURF_RESOURCE_ON) { surf_resource_set_state(surf_workstation_resource_priv(h), SURF_RESOURCE_OFF); @@ -115,6 +120,14 @@ void SIMIX_host_off(smx_host_t h, smx_process_t issuer) } } } + /*xbt_dynar_t vms = surf_workstation_get_vms(h); + unsigned int cpt; + smx_host_t vm; + xbt_dynar_foreach(vms, cpt, vm) { + SIMIX_vm_shutdown(vm, issuer); + SIMIX_vm_destroy(vm); + } + xbt_dynar_free(&vms);*/ } /** @@ -147,29 +160,11 @@ void SIMIX_host_destroy(void *h) xbt_swag_free(host->process_list); /* Clean host structure */ - free(host); + free(host); return; } -///** -// * \brief Returns a dict of all hosts. -// * -// * \return List of all hosts (as a #xbt_dict_t) -// */ -//xbt_dict_t SIMIX_host_get_dict(void) -//{ -// xbt_dict_t host_dict = xbt_dict_new_homogeneous(NULL); -// xbt_lib_cursor_t cursor = NULL; -// char *name = NULL; -// void **host = NULL; -// -// xbt_lib_foreach(host_lib, cursor, name, host){ -// if(host[SIMIX_HOST_LEVEL]) -// xbt_dict_set(host_dict,name,host[SIMIX_HOST_LEVEL], NULL); -// } -// return host_dict; -//} -smx_host_t SIMIX_pre_host_get_by_name(smx_simcall_t simcall, const char *name){ +smx_host_t simcall_HANDLER_host_get_by_name(smx_simcall_t simcall, const char *name){ return SIMIX_host_get_by_name(name); } smx_host_t SIMIX_host_get_by_name(const char *name){ @@ -186,7 +181,7 @@ smx_host_t SIMIX_host_self(void) return (process == NULL) ? NULL : SIMIX_process_get_host(process); } -const char* SIMIX_pre_host_self_get_name(smx_simcall_t simcall){ +const char* simcall_HANDLER_host_self_get_name(smx_simcall_t simcall){ return SIMIX_host_self_get_name(); } /* needs to be public and without simcall because it is called @@ -200,7 +195,7 @@ const char* SIMIX_host_self_get_name(void) return SIMIX_host_get_name(host); } -const char* SIMIX_pre_host_get_name(smx_simcall_t simcall, smx_host_t host){ +const char* simcall_HANDLER_host_get_name(smx_simcall_t simcall, smx_host_t host){ return SIMIX_host_get_name(host); } const char* SIMIX_host_get_name(smx_host_t host){ @@ -209,7 +204,7 @@ const char* SIMIX_host_get_name(smx_host_t host){ return sg_host_name(host); } -xbt_dict_t SIMIX_pre_host_get_properties(smx_simcall_t simcall, smx_host_t host){ +xbt_dict_t simcall_HANDLER_host_get_properties(smx_simcall_t simcall, smx_host_t host){ return SIMIX_host_get_properties(host); } xbt_dict_t SIMIX_host_get_properties(smx_host_t host){ @@ -218,7 +213,7 @@ xbt_dict_t SIMIX_host_get_properties(smx_host_t host){ return surf_resource_get_properties(surf_workstation_resource_priv(host)); } -double SIMIX_pre_host_get_speed(smx_simcall_t simcall, smx_host_t host){ +double simcall_HANDLER_host_get_speed(smx_simcall_t simcall, smx_host_t host){ return SIMIX_host_get_speed(host); } double SIMIX_host_get_speed(smx_host_t host){ @@ -226,7 +221,7 @@ double SIMIX_host_get_speed(smx_host_t host){ return surf_workstation_get_speed(host, 1.0); } -int SIMIX_pre_host_get_core(smx_simcall_t simcall, smx_host_t host){ +int simcall_HANDLER_host_get_core(smx_simcall_t simcall, smx_host_t host){ return SIMIX_host_get_core(host); } int SIMIX_host_get_core(smx_host_t host){ @@ -235,7 +230,7 @@ int SIMIX_host_get_core(smx_host_t host){ return surf_workstation_get_core(host); } -xbt_swag_t SIMIX_pre_host_get_process_list(smx_simcall_t simcall, smx_host_t host){ +xbt_swag_t simcall_HANDLER_host_get_process_list(smx_simcall_t simcall, smx_host_t host){ return SIMIX_host_get_process_list(host); } @@ -247,7 +242,7 @@ xbt_swag_t SIMIX_host_get_process_list(smx_host_t host){ } -double SIMIX_pre_host_get_available_speed(smx_simcall_t simcall, smx_host_t host){ +double simcall_HANDLER_host_get_available_speed(smx_simcall_t simcall, smx_host_t host){ return SIMIX_host_get_available_speed(host); } double SIMIX_host_get_available_speed(smx_host_t host){ @@ -256,7 +251,7 @@ double SIMIX_host_get_available_speed(smx_host_t host){ return surf_workstation_get_available_speed(host); } -double SIMIX_pre_host_get_current_power_peak(smx_simcall_t simcall, smx_host_t host){ +double simcall_HANDLER_host_get_current_power_peak(smx_simcall_t simcall, smx_host_t host){ return SIMIX_host_get_current_power_peak(host); } double SIMIX_host_get_current_power_peak(smx_host_t host) { @@ -264,7 +259,7 @@ double SIMIX_host_get_current_power_peak(smx_host_t host) { return surf_workstation_get_current_power_peak(host); } -double SIMIX_pre_host_get_power_peak_at(smx_simcall_t simcall, smx_host_t host, int pstate_index){ +double simcall_HANDLER_host_get_power_peak_at(smx_simcall_t simcall, smx_host_t host, int pstate_index){ return SIMIX_host_get_power_peak_at(host, pstate_index); } double SIMIX_host_get_power_peak_at(smx_host_t host, int pstate_index) { @@ -273,7 +268,7 @@ double SIMIX_host_get_power_peak_at(smx_host_t host, int pstate_index) { return surf_workstation_get_power_peak_at(host, pstate_index); } -int SIMIX_pre_host_get_nb_pstates(smx_simcall_t simcall, smx_host_t host){ +int simcall_HANDLER_host_get_nb_pstates(smx_simcall_t simcall, smx_host_t host){ return SIMIX_host_get_nb_pstates(host); } int SIMIX_host_get_nb_pstates(smx_host_t host) { @@ -283,7 +278,7 @@ int SIMIX_host_get_nb_pstates(smx_host_t host) { } -void SIMIX_pre_host_set_power_peak_at(smx_simcall_t simcall, smx_host_t host, int pstate_index){ +void simcall_HANDLER_host_set_power_peak_at(smx_simcall_t simcall, smx_host_t host, int pstate_index){ SIMIX_host_set_power_peak_at(host, pstate_index); } void SIMIX_host_set_power_peak_at(smx_host_t host, int pstate_index) { @@ -292,7 +287,7 @@ void SIMIX_host_set_power_peak_at(smx_host_t host, int pstate_index) { surf_workstation_set_power_peak_at(host, pstate_index); } -double SIMIX_pre_host_get_consumed_energy(smx_simcall_t simcall, smx_host_t host){ +double simcall_HANDLER_host_get_consumed_energy(smx_simcall_t simcall, smx_host_t host){ return SIMIX_host_get_consumed_energy(host); } double SIMIX_host_get_consumed_energy(smx_host_t host) { @@ -300,7 +295,7 @@ double SIMIX_host_get_consumed_energy(smx_host_t host) { return surf_workstation_get_consumed_energy(host); } -int SIMIX_pre_host_get_state(smx_simcall_t simcall, smx_host_t host){ +int simcall_HANDLER_host_get_state(smx_simcall_t simcall, smx_host_t host){ return SIMIX_host_get_state(host); } int SIMIX_host_get_state(smx_host_t host){ @@ -391,7 +386,8 @@ void SIMIX_host_restart_processes(smx_host_t host) arg->argc, arg->argv, arg->properties, - arg->auto_restart); + arg->auto_restart, + NULL); } else { simcall_process_create(&process, arg->argv[0], @@ -422,7 +418,7 @@ void SIMIX_host_autorestart(smx_host_t host) xbt_die("No function for simix_global->autorestart"); } -smx_action_t SIMIX_pre_host_execute(smx_simcall_t simcall,const char *name, +smx_action_t simcall_HANDLER_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); } @@ -462,12 +458,12 @@ smx_action_t SIMIX_host_execute(const char *name, } } - XBT_DEBUG("Create execute action %p", action); + XBT_DEBUG("Create execute action %p: %s", action, action->name); return action; } -smx_action_t SIMIX_pre_host_parallel_execute(smx_simcall_t simcall, const char *name, +smx_action_t simcall_HANDLER_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){ @@ -524,7 +520,7 @@ smx_action_t SIMIX_host_parallel_execute(const char *name, return action; } -void SIMIX_pre_host_execution_destroy(smx_simcall_t simcall, smx_action_t action){ +void simcall_HANDLER_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){ @@ -538,7 +534,7 @@ void SIMIX_host_execution_destroy(smx_action_t action){ xbt_mallocator_release(simix_global->action_mallocator, action); } -void SIMIX_pre_host_execution_cancel(smx_simcall_t simcall, smx_action_t action){ +void simcall_HANDLER_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){ @@ -548,7 +544,7 @@ void SIMIX_host_execution_cancel(smx_action_t action){ surf_action_cancel(action->execution.surf_exec); } -double SIMIX_pre_host_execution_get_remains(smx_simcall_t simcall, smx_action_t action){ +double simcall_HANDLER_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){ @@ -560,14 +556,14 @@ double SIMIX_host_execution_get_remains(smx_action_t action){ return result; } -e_smx_state_t SIMIX_pre_host_execution_get_state(smx_simcall_t simcall, smx_action_t action){ +e_smx_state_t simcall_HANDLER_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, +void simcall_HANDLER_host_execution_set_priority(smx_simcall_t simcall, smx_action_t action, double priority){ SIMIX_host_execution_set_priority(action, priority); } @@ -577,7 +573,7 @@ void SIMIX_host_execution_set_priority(smx_action_t action, double priority){ surf_action_set_priority(action->execution.surf_exec, priority); } -void SIMIX_pre_host_execution_set_bound(smx_simcall_t simcall, smx_action_t action, +void simcall_HANDLER_host_execution_set_bound(smx_simcall_t simcall, smx_action_t action, double bound){ SIMIX_host_execution_set_bound(action, bound); } @@ -587,7 +583,7 @@ void SIMIX_host_execution_set_bound(smx_action_t action, double bound){ surf_cpu_action_set_bound(action->execution.surf_exec, bound); } -void SIMIX_pre_host_execution_set_affinity(smx_simcall_t simcall, +void simcall_HANDLER_host_execution_set_affinity(smx_simcall_t simcall, smx_action_t action, smx_host_t host, unsigned long mask){ SIMIX_host_execution_set_affinity(action, host, mask); } @@ -601,7 +597,7 @@ void SIMIX_host_execution_set_affinity(smx_action_t action, smx_host_t host, uns } } -void SIMIX_pre_host_execution_wait(smx_simcall_t simcall, smx_action_t action){ +void simcall_HANDLER_host_execution_wait(smx_simcall_t simcall, smx_action_t action){ XBT_DEBUG("Wait for execution of action %p, state %d", action, (int)action->state); @@ -706,7 +702,7 @@ void SIMIX_post_host_execute(smx_action_t action) #ifdef HAVE_TRACING -void SIMIX_pre_set_category(smx_simcall_t simcall, smx_action_t action, +void simcall_HANDLER_set_category(smx_simcall_t simcall, smx_action_t action, const char *category){ SIMIX_set_category(action, category); } @@ -733,7 +729,7 @@ void SIMIX_host_get_params(smx_host_t ind_vm, ws_params_t params) surf_workstation_get_params(ind_vm, params); } -void SIMIX_pre_host_get_params(smx_simcall_t simcall, smx_host_t ind_vm, ws_params_t params) +void simcall_HANDLER_host_get_params(smx_simcall_t simcall, smx_host_t ind_vm, ws_params_t params) { SIMIX_host_get_params(ind_vm, params); } @@ -744,12 +740,12 @@ void SIMIX_host_set_params(smx_host_t ind_vm, ws_params_t params) surf_workstation_set_params(ind_vm, params); } -void SIMIX_pre_host_set_params(smx_simcall_t simcall, smx_host_t ind_vm, ws_params_t params) +void simcall_HANDLER_host_set_params(smx_simcall_t simcall, smx_host_t ind_vm, ws_params_t params) { SIMIX_host_set_params(ind_vm, params); } -xbt_dict_t SIMIX_pre_host_get_mounted_storage_list(smx_simcall_t simcall, smx_host_t host){ +xbt_dict_t simcall_HANDLER_host_get_mounted_storage_list(smx_simcall_t simcall, smx_host_t host){ return SIMIX_host_get_mounted_storage_list(host); } @@ -759,7 +755,7 @@ xbt_dict_t SIMIX_host_get_mounted_storage_list(smx_host_t host){ return surf_workstation_get_mounted_storage_list(host); } -xbt_dynar_t SIMIX_pre_host_get_attached_storage_list(smx_simcall_t simcall, smx_host_t host){ +xbt_dynar_t simcall_HANDLER_host_get_attached_storage_list(smx_simcall_t simcall, smx_host_t host){ return SIMIX_host_get_attached_storage_list(host); }