X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/073f8bce5afb1febdc3580607be8819b90705280..d7417d92e963c0d6ed8443454a56c85a3728d214:/testsuite/surf/surf_usage2.c diff --git a/testsuite/surf/surf_usage2.c b/testsuite/surf/surf_usage2.c index 443e5e18eb..8201a45b13 100644 --- a/testsuite/surf/surf_usage2.c +++ b/testsuite/surf/surf_usage2.c @@ -14,7 +14,7 @@ #include "surf/surf.h" #include "xbt/log.h" -XBT_LOG_NEW_DEFAULT_CATEGORY(surf_test,"Messages specific for surf example"); +XBT_LOG_NEW_DEFAULT_CATEGORY(surf_test, "Messages specific for surf example"); const char *string_action(e_surf_action_state_t state); const char *string_action(e_surf_action_state_t state) @@ -47,64 +47,66 @@ void test(char *platform) surf_action_t commAB = NULL; double now = -1.0; - surf_workstation_model_init_CLM03(platform); + int workstation_id = + find_model_description(surf_workstation_model_description, "CLM03"); + + surf_workstation_model_description[workstation_id].model_init(platform); + parse_platform_file(platform); + if (surf_workstation_model_description[workstation_id].create_ws) + surf_workstation_model_description[workstation_id].create_ws(); /*********************** WORKSTATION ***********************************/ - workstationA = - surf_workstation_model->common_public->name_service("Cpu A"); - workstationB = - surf_workstation_model->common_public->name_service("Cpu B"); + workstationA = surf_workstation_model->common_public->name_service("Cpu A"); + workstationB = surf_workstation_model->common_public->name_service("Cpu B"); /* Let's check that those two processors exist */ - DEBUG2("%s : %p\n", - surf_workstation_model->common_public-> - get_model_name(workstationA), workstationA); - DEBUG2("%s : %p\n", - surf_workstation_model->common_public-> - get_model_name(workstationB), workstationB); + DEBUG2("%s : %p", + surf_workstation_model-> + common_public->get_resource_name(workstationA), workstationA); + DEBUG2("%s : %p", + surf_workstation_model-> + common_public->get_resource_name(workstationB), workstationB); /* Let's do something on it */ actionA = - surf_workstation_model->extension_public->execute(workstationA, - 1000.0); + surf_workstation_model->extension_public->execute(workstationA, 1000.0); actionB = - surf_workstation_model->extension_public->execute(workstationB, - 1000.0); + surf_workstation_model->extension_public->execute(workstationB, 1000.0); actionC = - surf_workstation_model->extension_public->sleep(workstationB, - 7.32); + surf_workstation_model->extension_public->sleep(workstationB, 7.32); commAB = - surf_workstation_model->extension_public-> - communicate(workstationA, workstationB, 150.0, -1.0); + surf_workstation_model->extension_public->communicate(workstationA, + workstationB, 150.0, + -1.0); - surf_solve(); /* Takes traces into account. Returns 0.0 */ + surf_solve(); /* Takes traces into account. Returns 0.0 */ do { surf_action_t action = NULL; - int i; + unsigned int iter; surf_model_t model = NULL; now = surf_get_clock(); - DEBUG1("Next Event : " "%g" "\n", now); + DEBUG1("Next Event : %g", now); - xbt_dynar_foreach(model_list, i, model) { - DEBUG1("\t %s actions\n", model->common_public->name); + xbt_dynar_foreach(model_list, iter, model) { + DEBUG1("\t %s actions", model->common_public->name); while ((action = - xbt_swag_extract(model->common_public->states. - failed_action_set))) { - DEBUG1("\t * Failed : %p\n", action); - model->common_public->action_free(action); + xbt_swag_extract(model->common_public-> + states.failed_action_set))) { + DEBUG1("\t * Failed : %p", action); + model->common_public->action_unref(action); } while ((action = - xbt_swag_extract(model->common_public->states. - done_action_set))) { - DEBUG1("\t * Done : %p\n", action); - model->common_public->action_free(action); + xbt_swag_extract(model->common_public-> + states.done_action_set))) { + DEBUG1("\t * Done : %p", action); + model->common_public->action_unref(action); } } - } while (surf_solve()>=0.0); + } while (surf_solve() >= 0.0); - DEBUG0("Simulation Terminated\n"); + DEBUG0("Simulation Terminated"); } @@ -114,11 +116,11 @@ void test(char *platform) int main(int argc, char **argv) { - surf_init(&argc, argv); /* Initialize some common structures */ - if(argc==1) { - fprintf(stderr,"Usage : %s platform.txt\n",argv[0]); - surf_exit(); - return 1; + surf_init(&argc, argv); /* Initialize some common structures */ + if (argc == 1) { + fprintf(stderr, "Usage : %s platform.txt\n", argv[0]); + surf_exit(); + return 1; } test(argv[1]);