Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
revisit examples/msg/sendrecv
authorFrederic Suter <frederic.suter@cc.in2p3.fr>
Sat, 9 Apr 2016 15:08:58 +0000 (17:08 +0200)
committerFrederic Suter <frederic.suter@cc.in2p3.fr>
Sat, 9 Apr 2016 15:24:28 +0000 (17:24 +0200)
 + now this really is a ping-pong example as stated in the
   "documentation"
 + We said "It's hard to think of a simpler example", well now this
   statement makes sense ...

.gitignore
doc/Doxyfile.in
examples/msg/CMakeLists.txt
examples/msg/app-pingpong/app-pingpong.c [new file with mode: 0644]
examples/msg/app-pingpong/app-pingpong.tesh [new file with mode: 0644]
examples/msg/app-pingpong/app-pingpong_d.xml [moved from examples/msg/sendrecv/sendrecv_d.xml with 52% similarity]
examples/msg/sendrecv/sendrecv.c [deleted file]
examples/msg/sendrecv/sendrecv.tesh [deleted file]

index 9bd399f..84fa2b2 100644 (file)
@@ -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
index ce9d4c7..383a2bc 100644 (file)
@@ -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 \
index 6b7f617..2798344 100644 (file)
@@ -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 (file)
index 0000000..3b6a9cb
--- /dev/null
@@ -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
+ *
+ *  - <b>Ping-pong example: app-pingpong/app-pingpong.c </b>. 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 (file)
index 0000000..d7e1a3a
--- /dev/null
@@ -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
similarity index 52%
rename from examples/msg/sendrecv/sendrecv_d.xml
rename to examples/msg/app-pingpong/app-pingpong_d.xml
index 1c4bf8b..b48d8dd 100644 (file)
@@ -2,6 +2,6 @@
 <!DOCTYPE platform SYSTEM "http://simgrid.gforge.inria.fr/simgrid/simgrid.dtd">
 <platform version="4">
 <!-- For using with ping_pong, platform_sendrecv.xml -->
-  <process host="Tremblay" function="sender"> <argument value="Jupiter"/> </process>
-  <process host="Jupiter" function="receiver"/>
+  <process host="Tremblay" function="pinger">  <argument value="Jupiter"/>  </process>
+  <process host="Jupiter"  function="ponger">  <argument value="Tremblay"/> </process>
 </platform>
diff --git a/examples/msg/sendrecv/sendrecv.c b/examples/msg/sendrecv/sendrecv.c
deleted file mode 100644 (file)
index 1c3f625..0000000
+++ /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
- *
- *  - <b>sendrecv/sendrecv.c: Ping-pong example</b>. 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 (file)
index f542117..0000000
+++ /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