X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0ca1291c2f63ca6235f4b4885c48413a900aade4..c17101fce25d0553c1bc7b48b5727c42b33cc217:/src/surf/workstation.c diff --git a/src/surf/workstation.c b/src/surf/workstation.c index 9aa3304dd8..eb89b6f3a4 100644 --- a/src/surf/workstation.c +++ b/src/surf/workstation.c @@ -8,6 +8,9 @@ #include "xbt/dict.h" #include "portable.h" #include "surf_private.h" +#include "surf/surf_resource.h" + + typedef struct workstation_CLM03 { s_surf_resource_t generic_resource; /* Must remain first to add this to a trace */ @@ -47,6 +50,7 @@ void create_workstations(void) static int ws_resource_used(void *resource_id) { THROW_IMPOSSIBLE; /* This model does not implement parallel tasks */ + return -1; } static void ws_parallel_action_cancel(surf_action_t action) @@ -57,6 +61,7 @@ static void ws_parallel_action_cancel(surf_action_t action) static int ws_parallel_action_free(surf_action_t action) { THROW_UNIMPLEMENTED; /* This model does not implement parallel tasks */ + return -1; } static int ws_action_unref(surf_action_t action) @@ -155,6 +160,7 @@ static int ws_action_is_suspended(surf_action_t action) if (action->model_type == surf_cpu_model) return surf_cpu_model->is_suspended(action); DIE_IMPOSSIBLE; + return -1; } static void ws_action_set_max_duration(surf_action_t action, @@ -207,6 +213,7 @@ static double ws_action_get_remains(surf_action_t action) if (action->model_type == surf_cpu_model) return surf_cpu_model->get_remains(action); DIE_IMPOSSIBLE; + return -1.0; } static surf_action_t ws_communicate(void *workstation_src, @@ -246,6 +253,7 @@ static surf_action_t ws_execute_parallel_task(int workstation_nb, double amount, double rate) { THROW_UNIMPLEMENTED; /* This model does not implement parallel tasks */ + return NULL; } @@ -253,7 +261,7 @@ static surf_action_t ws_execute_parallel_task(int workstation_nb, static xbt_dynar_t ws_get_route(void *src, void *dst) { return surf_network_model->extension. - network.get_route(surf_resource_name(src), surf_resource_name(src)); + network.get_route(surf_resource_name(src), surf_resource_name(dst)); } static double ws_get_link_bandwidth(const void *link) @@ -336,36 +344,23 @@ static void surf_workstation_model_init_internal(void) } -/********************************************************************/ -/* The model used in MSG and presented at CCGrid03 */ -/********************************************************************/ -/* @InProceedings{Casanova.CLM_03, */ -/* author = {Henri Casanova and Arnaud Legrand and Loris Marchal}, */ -/* title = {Scheduling Distributed Applications: the SimGrid Simulation Framework}, */ -/* booktitle = {Proceedings of the third IEEE International Symposium on Cluster Computing and the Grid (CCGrid'03)}, */ -/* publisher = {"IEEE Computer Society Press"}, */ -/* month = {may}, */ -/* year = {2003} */ -/* } */ -void surf_workstation_model_init_CLM03(const char *filename) +void surf_workstation_model_init_current_default(void) { surf_workstation_model_init_internal(); - surf_cpu_model_init_Cas01_im(filename); - surf_network_model_init_LegrandVelho(filename); - update_model_description(surf_workstation_model_description, - "CLM03", surf_workstation_model); + xbt_cfg_setdefault_int(_surf_cfg_set, "network/crosstraffic", 1); + surf_cpu_model_init_Cas01(); + surf_network_model_init_LegrandVelho(); + xbt_dynar_push(model_list, &surf_workstation_model); + sg_platf_postparse_add_cb(create_workstations); } -void surf_workstation_model_init_compound(const char *filename) +void surf_workstation_model_init_compound() { xbt_assert(surf_cpu_model, "No CPU model defined yet!"); xbt_assert(surf_network_model, "No network model defined yet!"); surf_workstation_model_init_internal(); - - update_model_description(surf_workstation_model_description, - "compound", surf_workstation_model); - xbt_dynar_push(model_list, &surf_workstation_model); + sg_platf_postparse_add_cb(create_workstations); }