From: Frederic Suter Date: Sat, 9 Apr 2016 15:24:33 +0000 (+0200) Subject: Merge branch 'master' of git+ssh://scm.gforge.inria.fr//gitroot/simgrid/simgrid X-Git-Tag: v3_13~111 X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/commitdiff_plain/cfabbb6291efb5ef59d78d1751c5f770ef128637?hp=4e3cf537964f44e15188df5f0ba822b562c17a04 Merge branch 'master' of git+ssh://scm.gforge.inria.fr//gitroot/simgrid/simgrid --- diff --git a/.gitignore b/.gitignore index 9bd399f87e..84fa2b2948 100644 --- a/.gitignore +++ b/.gitignore @@ -167,7 +167,7 @@ examples/msg/task-priority/task-priority examples/msg/procmig.trace examples/msg/properties/properties examples/msg/synchro/synchro -examples/msg/sendrecv/sendrecv +examples/msg/app-pingpong/app-pingpong examples/msg/set-maestro/set-maestro examples/msg/simulation.trace examples/msg/process-startkilltime/process-startkilltime diff --git a/doc/Doxyfile.in b/doc/Doxyfile.in index ce9d4c7ae7..383a2bc081 100644 --- a/doc/Doxyfile.in +++ b/doc/Doxyfile.in @@ -695,7 +695,7 @@ INPUT = doxygen/index.doc \ ## PLEASE DON'T MESS WITH THE ORDER OF EXAMPLES ## (unless you know what you are doing, of course) ################################################### -INPUT += @CMAKE_HOME_DIRECTORY@/examples/msg/sendrecv/sendrecv.c \ +INPUT += @CMAKE_HOME_DIRECTORY@/examples/msg/app-pingpong/app-pingpong.c \ @CMAKE_HOME_DIRECTORY@/examples/msg/app-masterworker/app-masterworker.c \ @CMAKE_HOME_DIRECTORY@/examples/msg/process-migration/process-migration.c \ @CMAKE_HOME_DIRECTORY@/examples/msg/process-suspend/process-suspend.c \ diff --git a/examples/msg/CMakeLists.txt b/examples/msg/CMakeLists.txt index 6b7f617c02..2798344ba4 100644 --- a/examples/msg/CMakeLists.txt +++ b/examples/msg/CMakeLists.txt @@ -1,8 +1,8 @@ -foreach(x actions-comm actions-storage app-masterworker app-pmm app-token-ring async-wait async-waitall async-waitany - cloud-capping cloud-masterworker cloud-migration cloud-multicore cloud-simple cloud-two-tasks dht-chord - dht-pastry exception energy-consumption energy-onoff energy-pstate energy-ptask energy-vm failures io-file - io-file-unlink io-remote io-storage task-priority process-kill process-migration process-suspend - properties sendrecv set-maestro process-startkilltime synchro trace-categories +foreach(x actions-comm actions-storage app-masterworker app-pingpong app-pmm app-token-ring async-wait async-waitall + async-waitany cloud-capping cloud-masterworker cloud-migration cloud-multicore cloud-simple cloud-two-tasks + dht-chord dht-pastry exception energy-consumption energy-onoff energy-pstate energy-ptask energy-vm failures + io-file io-file-unlink io-remote io-storage task-priority process-kill process-migration process-suspend + properties set-maestro process-startkilltime synchro trace-categories trace-link-srcdst-user-variables trace-link-user-variables trace-masterworker trace-platform trace-process-migration trace-simple trace-user-variables) add_executable (${x} ${x}/${x}.c) @@ -39,8 +39,8 @@ foreach (file answer dht-kademlia node routing_table task) set(examples_src ${examples_src} ${CMAKE_CURRENT_SOURCE_DIR}/dht-kademlia/${file}.c ${CMAKE_CURRENT_SOURCE_DIR}/dht-kademlia/${file}.h) endforeach() -foreach (file actions-comm actions-storage app-bittorrent app-chainsend app-masterworker async-wait async-waitall - async-waitany dht-chord dht-kademlia dht-pastry io-remote properties sendrecv set-maestro task-priority) +foreach (file actions-comm actions-storage app-bittorrent app-chainsend app-masterworker app-pingpong async-wait + async-waitall async-waitany dht-chord dht-kademlia dht-pastry io-remote properties set-maestro task-priority) set(xml_files ${xml_files} ${CMAKE_CURRENT_SOURCE_DIR}/${file}/${file}_d.xml) endforeach() @@ -81,10 +81,10 @@ set(xml_files ${xml_files} ${CMAKE_CURRENT_SOURCE_DIR}/actions-comm/actio ${CMAKE_CURRENT_SOURCE_DIR}/process-startkilltime/start_d.xml ${CMAKE_CURRENT_SOURCE_DIR}/process-startkilltime/start_kill_d.xml PARENT_SCOPE) -foreach(x actions-comm actions-storage app-bittorrent app-chainsend app-masterworker app-token-ring async-wait - async-waitall async-waitany cloud-capping cloud-masterworker cloud-migration cloud-simple cloud-two-tasks - dht-chord dht-kademlia failures io-file io-file-unlink io-remote io-storage task-priority process-kill - process-migration process-suspend properties sendrecv synchro process-startkilltime) +foreach(x actions-comm actions-storage app-bittorrent app-chainsend app-masterworker app-pingpong app-token-ring + async-wait async-waitall async-waitany cloud-capping cloud-masterworker cloud-migration cloud-simple + cloud-two-tasks dht-chord dht-kademlia failures io-file io-file-unlink io-remote io-storage task-priority + process-kill process-migration process-suspend properties synchro process-startkilltime) ADD_TESH_FACTORIES(msg-${x} "thread;ucontext;raw;boost" --setenv bindir=${CMAKE_BINARY_DIR}/examples/msg/${x} --setenv srcdir=${CMAKE_HOME_DIRECTORY}/examples/platforms --cd ${CMAKE_HOME_DIRECTORY}/examples/msg/${x} ${x}.tesh) endforeach() diff --git a/examples/msg/app-pingpong/app-pingpong.c b/examples/msg/app-pingpong/app-pingpong.c new file mode 100644 index 0000000000..3b6a9cbcca --- /dev/null +++ b/examples/msg/app-pingpong/app-pingpong.c @@ -0,0 +1,92 @@ +/* Copyright (c) 2007-2015. 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 "simgrid/msg.h" + +/** @addtogroup MSG_examples + * + * - Ping-pong example: app-pingpong/app-pingpong.c . It's hard to think of a simpler example. The tesh file + * laying in the directory is instructive concerning the way to pass options to the simulators (see \ref options). + */ + +XBT_LOG_NEW_DEFAULT_CATEGORY(pingpong,"Messages specific for this msg example"); + +static int pinger(int argc, char *argv[]) +{ + XBT_INFO("Ping -> %s", argv[1]); + xbt_assert(MSG_host_by_name(argv[1]) != NULL, "Unknown host %s. Stopping Now! ", argv[1]); + + /** - Do the ping with a 1-Byte task (latency bound) ... */ + double time = MSG_get_clock(); + msg_task_t ping_task = MSG_task_create("small communication (latency bound)", 0.0, 1, NULL); + ping_task->data = xbt_new(double, 1); + *(double *) ping_task->data = time; + MSG_task_send(ping_task, argv[1]); + + /** - ... then wait for the (large) pong */ + msg_task_t pong_task = NULL; + int a = MSG_task_receive(&pong_task,MSG_host_get_name(MSG_host_self())); + xbt_assert(a == MSG_OK, "Unexpected behavior"); + + double sender_time = *((double *) (pong_task->data)); + double communication_time = MSG_get_clock() - sender_time; + XBT_INFO("Task received : %s", pong_task->name); + xbt_free(pong_task->data); + MSG_task_destroy(pong_task); + XBT_INFO("Pong time (bandwidth bound): %e", communication_time); + + return 0; +} + +static int ponger(int argc, char *argv[]) +{ + XBT_INFO("Pong -> %s", argv[1]); + xbt_assert(MSG_host_by_name(argv[1]) != NULL, "Unknown host %s. Stopping Now! ", argv[1]); + + /** - Receive the (small) ping first ....*/ + msg_task_t ping_task = NULL; + int a = MSG_task_receive(&ping_task, MSG_host_get_name(MSG_host_self())); + xbt_assert(a == MSG_OK, "Unexpected behavior"); + + double sender_time = *((double *) (ping_task->data)); + double communication_time = MSG_get_clock() - sender_time; + XBT_INFO("Task received : %s", ping_task->name); + xbt_free(ping_task->data); + MSG_task_destroy(ping_task); + XBT_INFO(" Ping time (latency bound) %e", communication_time); + + /** - ... Then send a 1GB pong back (bandwidth bound) */ + double time = MSG_get_clock(); + msg_task_t pong_task = MSG_task_create("large communication (bandwidth bound)", 0.0, 1e9, NULL); + pong_task->data = xbt_new(double, 1); + *(double *) pong_task->data = time; + XBT_INFO("task_bw->data = %e", *((double *) pong_task->data)); + MSG_task_send(pong_task, argv[1]); + + return 0; +} + +int main(int argc, char *argv[]) +{ + msg_error_t res = MSG_OK; + + MSG_init(&argc, argv); + + xbt_assert(argc > 2, "Usage: %s platform_file deployment_file\n" + "\tExample: %s ../../platform/small_platform.xml app-pingpong_d.xml\n", argv[0], argv[0]); + + MSG_create_environment(argv[1]); /** - Load the platform description */ + + MSG_function_register("pinger", pinger); /** - Register the function to be executed by the processes */ + MSG_function_register("ponger", ponger); + + MSG_launch_application(argv[2]); /** - Deploy the application */ + + res = MSG_main(); /** - Run the simulation */ + + XBT_INFO("Total simulation time: %e", MSG_get_clock()); + return res!=MSG_OK; +} diff --git a/examples/msg/app-pingpong/app-pingpong.tesh b/examples/msg/app-pingpong/app-pingpong.tesh new file mode 100644 index 0000000000..d7e1a3a52a --- /dev/null +++ b/examples/msg/app-pingpong/app-pingpong.tesh @@ -0,0 +1,57 @@ +#! ./tesh + +p Testing with default compound + +$ $SG_TEST_EXENV ${bindir:=.}/app-pingpong$EXEEXT ${srcdir:=.}/small_platform.xml ${srcdir:=.}/../msg/app-pingpong/app-pingpong_d.xml "--log=root.fmt:[%10.6r]%e(%i:%P@%h)%e%m%n" +> [ 0.000000] (1:pinger@Tremblay) Ping -> Jupiter +> [ 0.000000] (2:ponger@Jupiter) Pong -> Tremblay +> [ 0.019014] (2:ponger@Jupiter) Task received : small communication (latency bound) +> [ 0.019014] (2:ponger@Jupiter) Ping time (latency bound) 1.901449e-02 +> [ 0.019014] (2:ponger@Jupiter) task_bw->data = 1.901449e-02 +> [150.178356] (1:pinger@Tremblay) Task received : large communication (bandwidth bound) +> [150.178356] (1:pinger@Tremblay) Pong time (bandwidth bound): 1.501593e+02 +> [150.178356] (0:maestro@) Total simulation time: 1.501784e+02 + +p Testing the deprecated CM02 network model + +$ $SG_TEST_EXENV ${bindir:=.}/app-pingpong$EXEEXT ${srcdir:=.}/small_platform.xml ${srcdir:=.}/../msg/app-pingpong/app-pingpong_d.xml --cfg=cpu/model:Cas01 --cfg=network/model:CM02 "--log=root.fmt:[%10.6r]%e(%i:%P@%h)%e%m%n" +> [ 0.000000] (0:maestro@) Configuration change: Set 'cpu/model' to 'Cas01' +> [ 0.000000] (0:maestro@) Configuration change: Set 'network/model' to 'CM02' +> [ 0.000000] (1:pinger@Tremblay) Ping -> Jupiter +> [ 0.000000] (2:ponger@Jupiter) Pong -> Tremblay +> [ 0.001462] (2:ponger@Jupiter) Task received : small communication (latency bound) +> [ 0.001462] (2:ponger@Jupiter) Ping time (latency bound) 1.461663e-03 +> [ 0.001462] (2:ponger@Jupiter) task_bw->data = 1.461663e-03 +> [145.639041] (1:pinger@Tremblay) Task received : large communication (bandwidth bound) +> [145.639041] (1:pinger@Tremblay) Pong time (bandwidth bound): 1.456376e+02 +> [145.639041] (0:maestro@) Total simulation time: 1.456390e+02 + +p Testing the surf network Reno fairness model using lagrangian approach + +$ $SG_TEST_EXENV ${bindir:=.}/app-pingpong$EXEEXT ${srcdir:=.}/small_platform.xml ${srcdir:=.}/../msg/app-pingpong/app-pingpong_d.xml "--cfg=host/model:compound cpu/model:Cas01 network/model:Reno" --log=surf_lagrange.thres=critical "--log=root.fmt:[%10.6r]%e(%i:%P@%h)%e%m%n" +> [ 0.000000] (0:maestro@) Configuration change: Set 'host/model' to 'compound' +> [ 0.000000] (0:maestro@) Configuration change: Set 'cpu/model' to 'Cas01' +> [ 0.000000] (0:maestro@) Configuration change: Set 'network/model' to 'Reno' +> [ 0.000000] (1:pinger@Tremblay) Ping -> Jupiter +> [ 0.000000] (2:ponger@Jupiter) Pong -> Tremblay +> [ 0.015200] (2:ponger@Jupiter) Task received : small communication (latency bound) +> [ 0.015200] (2:ponger@Jupiter) Ping time (latency bound) 1.519994e-02 +> [ 0.015200] (2:ponger@Jupiter) task_bw->data = 1.519994e-02 +> [158.330528] (1:pinger@Tremblay) Task received : large communication (bandwidth bound) +> [158.330528] (1:pinger@Tremblay) Pong time (bandwidth bound): 1.583153e+02 +> [158.330528] (0:maestro@) Total simulation time: 1.583305e+02 + +p Testing the surf network Vegas fairness model using lagrangian approach + +$ $SG_TEST_EXENV ${bindir:=.}/app-pingpong$EXEEXT ${srcdir:=.}/small_platform.xml ${srcdir:=.}/../msg/app-pingpong/app-pingpong_d.xml "--cfg=host/model:compound cpu/model:Cas01 network/model:Vegas" "--log=root.fmt:[%10.6r]%e(%i:%P@%h)%e%m%n" +> [ 0.000000] (0:maestro@) Configuration change: Set 'host/model' to 'compound' +> [ 0.000000] (0:maestro@) Configuration change: Set 'cpu/model' to 'Cas01' +> [ 0.000000] (0:maestro@) Configuration change: Set 'network/model' to 'Vegas' +> [ 0.000000] (1:pinger@Tremblay) Ping -> Jupiter +> [ 0.000000] (2:ponger@Jupiter) Pong -> Tremblay +> [ 0.015200] (2:ponger@Jupiter) Task received : small communication (latency bound) +> [ 0.015200] (2:ponger@Jupiter) Ping time (latency bound) 1.519994e-02 +> [ 0.015200] (2:ponger@Jupiter) task_bw->data = 1.519994e-02 +> [158.330528] (1:pinger@Tremblay) Task received : large communication (bandwidth bound) +> [158.330528] (1:pinger@Tremblay) Pong time (bandwidth bound): 1.583153e+02 +> [158.330528] (0:maestro@) Total simulation time: 1.583305e+02 diff --git a/examples/msg/sendrecv/sendrecv_d.xml b/examples/msg/app-pingpong/app-pingpong_d.xml similarity index 52% rename from examples/msg/sendrecv/sendrecv_d.xml rename to examples/msg/app-pingpong/app-pingpong_d.xml index 1c4bf8b192..b48d8dd9f1 100644 --- a/examples/msg/sendrecv/sendrecv_d.xml +++ b/examples/msg/app-pingpong/app-pingpong_d.xml @@ -2,6 +2,6 @@ - - + + diff --git a/examples/msg/sendrecv/sendrecv.c b/examples/msg/sendrecv/sendrecv.c deleted file mode 100644 index 1c3f625d78..0000000000 --- a/examples/msg/sendrecv/sendrecv.c +++ /dev/null @@ -1,117 +0,0 @@ -/* Copyright (c) 2007-2015. 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 "simgrid/msg.h" - -/** @addtogroup MSG_examples - * - * - sendrecv/sendrecv.c: Ping-pong example. It's hard to - * think of a simpler example. The tesh files laying in the - * directory are instructive concerning the way to pass options to the simulators (as described in \ref options). - */ - -XBT_LOG_NEW_DEFAULT_CATEGORY(msg_test, "Messages specific for this msg example"); - -double task_comm_size_lat = 1; -double task_comm_size_bw = 10e8; - -static int sender(int argc, char *argv[]) -{ - msg_host_t host = NULL; - double time; - msg_task_t task_la = NULL; - msg_task_t task_bw = NULL; - char sprintf_buffer_la[64]; - char sprintf_buffer_bw[64]; - - XBT_INFO("sender"); - XBT_INFO("host = %s", argv[1]); - - host = MSG_host_by_name(argv[1]); - - xbt_assert(host != NULL, "Unknown host %s. Stopping Now! ", argv[1]); - - /* Latency */ - time = MSG_get_clock(); - sprintf(sprintf_buffer_la, "latency task"); - task_la = MSG_task_create(sprintf_buffer_la, 0.0, task_comm_size_lat, NULL); - task_la->data = xbt_new(double, 1); - *(double *) task_la->data = time; - XBT_INFO("task_la->data = %e", *((double *) task_la->data)); - MSG_task_send(task_la, argv[1]); - - /* Bandwidth */ - time = MSG_get_clock(); - sprintf(sprintf_buffer_bw, "bandwidth task"); - task_bw = MSG_task_create(sprintf_buffer_bw, 0.0, task_comm_size_bw, NULL); - task_bw->data = xbt_new(double, 1); - *(double *) task_bw->data = time; - XBT_INFO("task_bw->data = %e", *((double *) task_bw->data)); - MSG_task_send(task_bw, argv[1]); - - return 0; -} - -static int receiver(int argc, char *argv[]) -{ - msg_task_t task_la = NULL; - msg_task_t task_bw = NULL; - - XBT_INFO("receiver"); - - /* Get Latency */ - int a = MSG_task_receive(&task_la,MSG_host_get_name(MSG_host_self())); - - xbt_assert(a == MSG_OK, "Unexpected behavior"); - - double time1 = MSG_get_clock(); - double sender_time = *((double *) (task_la->data)); - double time = sender_time; - double communication_time = time1 - time; - XBT_INFO("Task received : %s", task_la->name); - xbt_free(task_la->data); - MSG_task_destroy(task_la); - XBT_INFO("Communic. time %e", communication_time); - XBT_INFO("--- la %f ----", communication_time); - - /* Get Bandwidth */ - a = MSG_task_receive(&task_bw,MSG_host_get_name(MSG_host_self())); - xbt_assert(a == MSG_OK, "Unexpected behavior"); - - time1 = MSG_get_clock(); - sender_time = *((double *) (task_bw->data)); - time = sender_time; - communication_time = time1 - time; - XBT_INFO("Task received : %s", task_bw->name); - xbt_free(task_bw->data); - MSG_task_destroy(task_bw); - XBT_INFO("Communic. time %e", communication_time); - XBT_INFO("--- bw %f ----", task_comm_size_bw / communication_time); - - return 0; -} - -int main(int argc, char *argv[]) -{ - msg_error_t res = MSG_OK; - - MSG_init(&argc, argv); - - xbt_assert(argc > 2, "Usage: %s platform_file deployment_file\n" - "\tExample: %s msg_platform.xml msg_deployment.xml\n", argv[0], argv[0]); - - MSG_create_environment(argv[1]); - - MSG_function_register("sender", sender); - MSG_function_register("receiver", receiver); - - MSG_launch_application(argv[2]); - - res = MSG_main(); - - XBT_INFO("Total simulation time: %e", MSG_get_clock()); - return res!=MSG_OK; -} diff --git a/examples/msg/sendrecv/sendrecv.tesh b/examples/msg/sendrecv/sendrecv.tesh deleted file mode 100644 index f542117675..0000000000 --- a/examples/msg/sendrecv/sendrecv.tesh +++ /dev/null @@ -1,73 +0,0 @@ -#! ./tesh - -p Testing with default compound - -$ $SG_TEST_EXENV ${bindir:=.}/sendrecv$EXEEXT ${srcdir:=.}/small_platform.xml ${srcdir:=.}/../msg/sendrecv/sendrecv_d.xml "--log=root.fmt:[%10.6r]%e(%i:%P@%h)%e%m%n" -> [ 0.000000] (1:sender@Tremblay) sender -> [ 0.000000] (1:sender@Tremblay) host = Jupiter -> [ 0.000000] (1:sender@Tremblay) task_la->data = 0.000000e+00 -> [ 0.000000] (2:receiver@Jupiter) receiver -> [ 0.019014] (2:receiver@Jupiter) Task received : latency task -> [ 0.019014] (2:receiver@Jupiter) Communic. time 1.901449e-02 -> [ 0.019014] (2:receiver@Jupiter) --- la 0.019014 ---- -> [ 0.019014] (1:sender@Tremblay) task_bw->data = 1.901449e-02 -> [150.178356] (2:receiver@Jupiter) Task received : bandwidth task -> [150.178356] (2:receiver@Jupiter) Communic. time 1.501593e+02 -> [150.178356] (2:receiver@Jupiter) --- bw 6659592.318450 ---- -> [150.178356] (0:maestro@) Total simulation time: 1.501784e+02 - -p Testing the deprecated CM02 network model - -$ $SG_TEST_EXENV ${bindir:=.}/sendrecv$EXEEXT ${srcdir:=.}/small_platform.xml ${srcdir:=.}/../msg/sendrecv/sendrecv_d.xml --cfg=cpu/model:Cas01 --cfg=network/model:CM02 "--log=root.fmt:[%10.6r]%e(%i:%P@%h)%e%m%n" -> [ 0.000000] (0:maestro@) Configuration change: Set 'cpu/model' to 'Cas01' -> [ 0.000000] (0:maestro@) Configuration change: Set 'network/model' to 'CM02' -> [ 0.000000] (1:sender@Tremblay) sender -> [ 0.000000] (1:sender@Tremblay) host = Jupiter -> [ 0.000000] (1:sender@Tremblay) task_la->data = 0.000000e+00 -> [ 0.000000] (2:receiver@Jupiter) receiver -> [ 0.001462] (2:receiver@Jupiter) Task received : latency task -> [ 0.001462] (2:receiver@Jupiter) Communic. time 1.461663e-03 -> [ 0.001462] (2:receiver@Jupiter) --- la 0.001462 ---- -> [ 0.001462] (1:sender@Tremblay) task_bw->data = 1.461663e-03 -> [145.639041] (2:receiver@Jupiter) Task received : bandwidth task -> [145.639041] (2:receiver@Jupiter) Communic. time 1.456376e+02 -> [145.639041] (2:receiver@Jupiter) --- bw 6866359.664748 ---- -> [145.639041] (0:maestro@) Total simulation time: 1.456390e+02 - -p Testing the surf network Reno fairness model using lagrangian approach - -$ $SG_TEST_EXENV ${bindir:=.}/sendrecv$EXEEXT ${srcdir:=.}/small_platform.xml ${srcdir:=.}/../msg/sendrecv/sendrecv_d.xml "--cfg=host/model:compound cpu/model:Cas01 network/model:Reno" --log=surf_lagrange.thres=critical "--log=root.fmt:[%10.6r]%e(%i:%P@%h)%e%m%n" -> [ 0.000000] (0:maestro@) Configuration change: Set 'host/model' to 'compound' -> [ 0.000000] (0:maestro@) Configuration change: Set 'cpu/model' to 'Cas01' -> [ 0.000000] (0:maestro@) Configuration change: Set 'network/model' to 'Reno' -> [ 0.000000] (1:sender@Tremblay) sender -> [ 0.000000] (1:sender@Tremblay) host = Jupiter -> [ 0.000000] (1:sender@Tremblay) task_la->data = 0.000000e+00 -> [ 0.000000] (2:receiver@Jupiter) receiver -> [ 0.015200] (2:receiver@Jupiter) Task received : latency task -> [ 0.015200] (2:receiver@Jupiter) Communic. time 1.519994e-02 -> [ 0.015200] (2:receiver@Jupiter) --- la 0.015200 ---- -> [ 0.015200] (1:sender@Tremblay) task_bw->data = 1.519994e-02 -> [158.330528] (2:receiver@Jupiter) Task received : bandwidth task -> [158.330528] (2:receiver@Jupiter) Communic. time 1.583153e+02 -> [158.330528] (2:receiver@Jupiter) --- bw 6316507.782677 ---- -> [158.330528] (0:maestro@) Total simulation time: 1.583305e+02 - -p Testing the surf network Vegas fairness model using lagrangian approach - -$ $SG_TEST_EXENV ${bindir:=.}/sendrecv$EXEEXT ${srcdir:=.}/small_platform.xml ${srcdir:=.}/../msg/sendrecv/sendrecv_d.xml "--cfg=host/model:compound cpu/model:Cas01 network/model:Vegas" "--log=root.fmt:[%10.6r]%e(%i:%P@%h)%e%m%n" -> [ 0.000000] (0:maestro@) Configuration change: Set 'host/model' to 'compound' -> [ 0.000000] (0:maestro@) Configuration change: Set 'cpu/model' to 'Cas01' -> [ 0.000000] (0:maestro@) Configuration change: Set 'network/model' to 'Vegas' -> [ 0.000000] (1:sender@Tremblay) sender -> [ 0.000000] (1:sender@Tremblay) host = Jupiter -> [ 0.000000] (1:sender@Tremblay) task_la->data = 0.000000e+00 -> [ 0.000000] (2:receiver@Jupiter) receiver -> [ 0.015200] (2:receiver@Jupiter) Task received : latency task -> [ 0.015200] (2:receiver@Jupiter) Communic. time 1.519994e-02 -> [ 0.015200] (2:receiver@Jupiter) --- la 0.015200 ---- -> [ 0.015200] (1:sender@Tremblay) task_bw->data = 1.519994e-02 -> [158.330528] (2:receiver@Jupiter) Task received : bandwidth task -> [158.330528] (2:receiver@Jupiter) Communic. time 1.583153e+02 -> [158.330528] (2:receiver@Jupiter) --- bw 6316507.782677 ---- -> [158.330528] (0:maestro@) Total simulation time: 1.583305e+02