X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/61e948b810774df0ab0a52dd60ca1fb16af658c5..903d96f4c7e2f761608b4591faa573aab5891994:/examples/simdag/sd_avail.c diff --git a/examples/simdag/sd_avail.c b/examples/simdag/sd_avail.c index d0ff07815b..f966a04741 100644 --- a/examples/simdag/sd_avail.c +++ b/examples/simdag/sd_avail.c @@ -1,17 +1,12 @@ -/* Copyright (c) 2012-2015. The SimGrid Team. +/* Copyright (c) 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 "simgrid/simdag.h" -#include "xbt/ex.h" -#include "xbt/log.h" -XBT_LOG_NEW_DEFAULT_CATEGORY(sd_avail, - "Logging specific to this SimDag example"); +XBT_LOG_NEW_DEFAULT_CATEGORY(sd_avail, "Logging specific to this SimDag example"); /* Test of dynamic availability traces * Scenario: @@ -45,21 +40,20 @@ XBT_LOG_NEW_DEFAULT_CATEGORY(sd_avail, int main(int argc, char **argv) { unsigned int ctr; - const sg_host_t *workstations; - SD_task_t t1, c1, t2, c2, t3, c3, t4, task; + SD_task_t task; xbt_dynar_t changed_tasks; SD_init(&argc, argv); SD_create_environment(argv[1]); - workstations = sg_host_list(); + const sg_host_t *hosts = sg_host_list(); - t1 = SD_task_create_comp_seq("t1", NULL, 25000000); - c1 = SD_task_create_comm_e2e("c1", NULL, 125000000); - t2 = SD_task_create_comp_seq("t2", NULL, 25000000); - c2 = SD_task_create_comm_e2e("c2", NULL, 62500000); - t3 = SD_task_create_comp_seq("t3", NULL, 25000000); - c3 = SD_task_create_comm_e2e("c3", NULL, 31250000); - t4 = SD_task_create_comp_seq("t4", NULL, 25000000); + SD_task_t t1 = SD_task_create_comp_seq("t1", NULL, 25000000); + SD_task_t c1 = SD_task_create_comm_e2e("c1", NULL, 125000000); + SD_task_t t2 = SD_task_create_comp_seq("t2", NULL, 25000000); + SD_task_t c2 = SD_task_create_comm_e2e("c2", NULL, 62500000); + SD_task_t t3 = SD_task_create_comp_seq("t3", NULL, 25000000); + SD_task_t c3 = SD_task_create_comm_e2e("c3", NULL, 31250000); + SD_task_t t4 = SD_task_create_comp_seq("t4", NULL, 25000000); /* Add dependencies: t1->c1->t2->c2->t3 */ SD_task_dependency_add(NULL, NULL, t1, c1); @@ -71,10 +65,10 @@ int main(int argc, char **argv) /* Schedule tasks t1 and w3 on first host, t2 on second host */ /* Transfers are auto-scheduled */ - SD_task_schedulel(t1, 1, workstations[0]); - SD_task_schedulel(t2, 1, workstations[1]); - SD_task_schedulel(t3, 1, workstations[0]); - SD_task_schedulel(t4, 1, workstations[1]); + SD_task_schedulel(t1, 1, hosts[0]); + SD_task_schedulel(t2, 1, hosts[1]); + SD_task_schedulel(t3, 1, hosts[0]); + SD_task_schedulel(t4, 1, hosts[1]); /* Add some watchpoint upon task completion */ SD_task_watch(t1, SD_DONE); @@ -85,19 +79,13 @@ int main(int argc, char **argv) SD_task_watch(c3, SD_DONE); SD_task_watch(t4, SD_DONE); - while (!xbt_dynar_is_empty((changed_tasks = SD_simulate(-1.0)))) { - XBT_INFO("link1: bw=%.0f, lat=%f", - SD_route_get_bandwidth(workstations[0], workstations[1]), - SD_route_get_latency(workstations[0], workstations[1])); - XBT_INFO("Jupiter: speed=%.0f", - sg_host_speed(workstations[0])* - sg_host_get_available_speed(workstations[0])); - XBT_INFO("Tremblay: speed=%.0f", - sg_host_speed(workstations[1])* - sg_host_get_available_speed(workstations[1])); + while (!xbt_dynar_is_empty((changed_tasks = SD_simulate(-1.0)))) { + XBT_INFO("link1: bw=%.0f, lat=%f", SD_route_get_bandwidth(hosts[0], hosts[1]), + SD_route_get_latency(hosts[0], hosts[1])); + XBT_INFO("Jupiter: speed=%.0f", sg_host_speed(hosts[0])* sg_host_get_available_speed(hosts[0])); + XBT_INFO("Tremblay: speed=%.0f", sg_host_speed(hosts[1])* sg_host_get_available_speed(hosts[1])); xbt_dynar_foreach(changed_tasks, ctr, task) { - XBT_INFO("Task '%s' start time: %f, finish time: %f", - SD_task_get_name(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)); if (SD_task_get_state(task)==SD_DONE) SD_task_destroy(task);