X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/45c3f1cfee86fb48c96d53f8267f99b6db6e3d7a..47418069ee9cb5ae4e5f14d86d9c93dfbec04d03:/examples/simdag/sd_fail.c diff --git a/examples/simdag/sd_fail.c b/examples/simdag/sd_fail.c index eb1fd82cd7..0bec7da11e 100644 --- a/examples/simdag/sd_fail.c +++ b/examples/simdag/sd_fail.c @@ -1,67 +1,52 @@ -/* Copyright (c) 2006-2010, 2012-2014. The SimGrid Team. +/* Copyright (c) 2006-2010, 2012-2016. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ -#include -#include -#include "simdag/simdag.h" -#include "xbt/ex.h" -#include "xbt/log.h" +#include "simgrid/simdag.h" -XBT_LOG_NEW_DEFAULT_CATEGORY(sd_fail, - "Logging specific to this SimDag example"); +XBT_LOG_NEW_DEFAULT_CATEGORY(sd_fail, "Logging specific to this SimDag example"); int main(int argc, char **argv) { - SD_task_t task; double computation_amount[1]; double communication_amount[2] = { 0 }; - SD_workstation_t workstation_list[1]; - xbt_dynar_t ret; + sg_host_t hosts[1]; /* initialization of SD */ SD_init(&argc, argv); /* creation of the environment */ - SD_create_environment("./faulty_host.xml"); - - /* creation of a single task that will poorly fail when the workstation - * will stop */ + SD_create_environment(argv[1]); + + /* creation of a single task that will poorly fail when the workstation will stop */ XBT_INFO("First test: COMP_SEQ task"); - task = SD_task_create_comp_seq("Poor task", NULL, 2e10); + SD_task_t task = SD_task_create_comp_seq("Poor task", NULL, 2e10); SD_task_watch(task, SD_FAILED); SD_task_watch(task, SD_DONE); - XBT_INFO("Schedule task '%s' on workstation 'Faulty Host'", - SD_task_get_name(task)); + XBT_INFO("Schedule task '%s' on 'Faulty Host'", SD_task_get_name(task)); - SD_task_schedulel(task, 1, SD_workstation_get_by_name("Faulty Host")); + SD_task_schedulel(task, 1, sg_host_by_name("Faulty Host")); - ret = SD_simulate(-1.0); - xbt_dynar_free(&ret); + SD_simulate(-1.0); SD_task_dump(task); - XBT_INFO("Task '%s' has failed. %.f flops remain to be done", - SD_task_get_name(task), + XBT_INFO("Task '%s' has failed. %.f flops remain to be done", SD_task_get_name(task), SD_task_get_remaining_amount(task)); - XBT_INFO("let's unschedule task '%s' and reschedule it on the 'Safe Host'", - SD_task_get_name(task)); + XBT_INFO("let's unschedule task '%s' and reschedule it on the 'Safe Host'", SD_task_get_name(task)); SD_task_unschedule(task); - SD_task_schedulel(task, 1, SD_workstation_get_by_name("Safe Host")); + SD_task_schedulel(task, 1, sg_host_by_name("Safe Host")); XBT_INFO("Run the simulation again"); - ret = SD_simulate(-1.0); - xbt_dynar_free(&ret); + SD_simulate(-1.0); SD_task_dump(task); - XBT_INFO("Task '%s' start time: %f, finish time: %f", - SD_task_get_name(task), - SD_task_get_start_time(task), - SD_task_get_finish_time(task)); + XBT_INFO("Task '%s' start time: %f, finish time: %f", SD_task_get_name(task), SD_task_get_start_time(task), + SD_task_get_finish_time(task)); SD_task_destroy(task); task=NULL; @@ -74,39 +59,30 @@ int main(int argc, char **argv) computation_amount[0] = 2e10; - XBT_INFO("Schedule task '%s' on workstation 'Faulty Host'", - SD_task_get_name(task)); + XBT_INFO("Schedule task '%s' on 'Faulty Host'", SD_task_get_name(task)); - workstation_list[0] = SD_workstation_get_by_name("Faulty Host"); - SD_task_schedule(task, 1, workstation_list, - computation_amount, communication_amount,-1); + hosts[0] = sg_host_by_name("Faulty Host"); + SD_task_schedule(task, 1, hosts, computation_amount, communication_amount,-1); - ret = SD_simulate(-1.0); - xbt_dynar_free(&ret); + SD_simulate(-1.0); SD_task_dump(task); - XBT_INFO("Task '%s' has failed. %.f flops remain to be done", - SD_task_get_name(task), + XBT_INFO("Task '%s' has failed. %.f flops remain to be done", SD_task_get_name(task), SD_task_get_remaining_amount(task)); - XBT_INFO("let's unschedule task '%s' and reschedule it on the 'Safe Host'", - SD_task_get_name(task)); + XBT_INFO("let's unschedule task '%s' and reschedule it on the 'Safe Host'", SD_task_get_name(task)); SD_task_unschedule(task); - workstation_list[0] = SD_workstation_get_by_name("Safe Host"); + hosts[0] = sg_host_by_name("Safe Host"); - SD_task_schedule(task, 1, workstation_list, - computation_amount, communication_amount,-1); + SD_task_schedule(task, 1, hosts, computation_amount, communication_amount,-1); XBT_INFO("Run the simulation again"); - ret = SD_simulate(-1.0); - xbt_dynar_free(&ret); + SD_simulate(-1.0); SD_task_dump(task); - XBT_INFO("Task '%s' start time: %f, finish time: %f", - SD_task_get_name(task), - SD_task_get_start_time(task), + XBT_INFO("Task '%s' start time: %f, finish time: %f", SD_task_get_name(task), SD_task_get_start_time(task), SD_task_get_finish_time(task)); SD_task_destroy(task);