examples/msg/icomms/peer.tesh

   1 #! ./tesh
   2
   3
   4
   5 p Test1 MSG_comm_test() with Sleep_sender > Sleep_receiver
   6
   7 $ ./peer small_platform.xml deployment_peer01.xml
   8 > [Tremblay:sender:(1) 0.000000] [msg_test/INFO] sleep_start_time : 5.000000 , sleep_test_time : 0.100000
   9 > [Ruby:receiver:(2) 0.000000] [msg_test/INFO] sleep_start_time : 1.000000 , sleep_test_time : 0.100000
  10 > [Ruby:receiver:(2) 1.000000] [msg_test/INFO] Wait to receive a task
  11 > [Tremblay:sender:(1) 5.000000] [msg_test/INFO] Send to receiver-0 Task_0
  12 > [Ruby:receiver:(2) 5.100000] [msg_test/INFO] Received "Task_0"
  13 > [Ruby:receiver:(2) 5.100000] [msg_test/INFO] Processing "Task_0"
  14 > [Tremblay:sender:(1) 5.100000] [msg_test/INFO] Send to receiver-0 Task_1
  15 > [Ruby:receiver:(2) 5.609710] [msg_test/INFO] "Task_0" done
  16 > [Ruby:receiver:(2) 5.609710] [msg_test/INFO] Wait to receive a task
  17 > [Tremblay:sender:(1) 5.700000] [msg_test/INFO] Send to receiver-0 Task_2
  18 > [Ruby:receiver:(2) 5.709710] [msg_test/INFO] Received "Task_1"
  19 > [Ruby:receiver:(2) 5.709710] [msg_test/INFO] Processing "Task_1"
  20 > [Ruby:receiver:(2) 6.219420] [msg_test/INFO] "Task_1" done
  21 > [Ruby:receiver:(2) 6.219420] [msg_test/INFO] Wait to receive a task
  22 > [Tremblay:sender:(1) 6.300000] [msg_test/INFO] Send to receiver-0 finalize
  23 > [Ruby:receiver:(2) 6.319420] [msg_test/INFO] Received "Task_2"
  24 > [Ruby:receiver:(2) 6.319420] [msg_test/INFO] Processing "Task_2"
  25 > [Ruby:receiver:(2) 6.829130] [msg_test/INFO] "Task_2" done
  26 > [Ruby:receiver:(2) 6.829130] [msg_test/INFO] Wait to receive a task
  27 > [Tremblay:sender:(1) 6.900000] [msg_test/INFO] Goodbye now!
  28 > [Ruby:receiver:(2) 6.929130] [msg_test/INFO] Received "finalize"
  29 > [Ruby:receiver:(2) 6.929130] [msg_test/INFO] I'm done. See you!
  30 > [6.929130] [msg_test/INFO] Simulation time 6.92913
  31
  32
  33 p Test2 MSG_comm_test() with Sleep_sender < Sleep_receiver
  34
  35 $ ./peer small_platform.xml deployment_peer02.xml
  36 > [Tremblay:sender:(1) 0.000000] [msg_test/INFO] sleep_start_time : 1.000000 , sleep_test_time : 0.100000
  37 > [Ruby:receiver:(2) 0.000000] [msg_test/INFO] sleep_start_time : 5.000000 , sleep_test_time : 0.100000
  38 > [Tremblay:sender:(1) 1.000000] [msg_test/INFO] Send to receiver-0 Task_0
  39 > [Ruby:receiver:(2) 5.000000] [msg_test/INFO] Wait to receive a task
  40 > [Tremblay:sender:(1) 5.100000] [msg_test/INFO] Send to receiver-0 Task_1
  41 > [Ruby:receiver:(2) 5.100000] [msg_test/INFO] Received "Task_0"
  42 > [Ruby:receiver:(2) 5.100000] [msg_test/INFO] Processing "Task_0"
  43 > [Ruby:receiver:(2) 5.609710] [msg_test/INFO] "Task_0" done
  44 > [Ruby:receiver:(2) 5.609710] [msg_test/INFO] Wait to receive a task
  45 > [Tremblay:sender:(1) 5.700000] [msg_test/INFO] Send to receiver-0 Task_2
  46 > [Ruby:receiver:(2) 5.709710] [msg_test/INFO] Received "Task_1"
  47 > [Ruby:receiver:(2) 5.709710] [msg_test/INFO] Processing "Task_1"
  48 > [Ruby:receiver:(2) 6.219420] [msg_test/INFO] "Task_1" done
  49 > [Ruby:receiver:(2) 6.219420] [msg_test/INFO] Wait to receive a task
  50 > [Tremblay:sender:(1) 6.300000] [msg_test/INFO] Send to receiver-0 finalize
  51 > [Ruby:receiver:(2) 6.319420] [msg_test/INFO] Received "Task_2"
  52 > [Ruby:receiver:(2) 6.319420] [msg_test/INFO] Processing "Task_2"
  53 > [Ruby:receiver:(2) 6.829130] [msg_test/INFO] "Task_2" done
  54 > [Ruby:receiver:(2) 6.829130] [msg_test/INFO] Wait to receive a task
  55 > [Tremblay:sender:(1) 6.900000] [msg_test/INFO] Goodbye now!
  56 > [Ruby:receiver:(2) 6.929130] [msg_test/INFO] Received "finalize"
  57 > [Ruby:receiver:(2) 6.929130] [msg_test/INFO] I'm done. See you!
  58 > [6.929130] [msg_test/INFO] Simulation time 6.92913
  59
  60
  61 p Test1 MSG_comm_wait() with Sleep_sender > Sleep_receiver
  62
  63 $ ./peer small_platform.xml deployment_peer03.xml
  64 > [Tremblay:sender:(1) 0.000000] [msg_test/INFO] sleep_start_time : 5.000000 , sleep_test_time : 0.000000
  65 > [Ruby:receiver:(2) 0.000000] [msg_test/INFO] sleep_start_time : 1.000000 , sleep_test_time : 0.000000
  66 > [Ruby:receiver:(2) 1.000000] [msg_test/INFO] Wait to receive a task
  67 > [Tremblay:sender:(1) 5.000000] [msg_test/INFO] Send to receiver-0 Task_0
  68 > [Ruby:receiver:(2) 5.016560] [msg_test/INFO] Received "Task_0"
  69 > [Ruby:receiver:(2) 5.016560] [msg_test/INFO] Processing "Task_0"
  70 > [Tremblay:sender:(1) 5.016560] [msg_test/INFO] Send to receiver-0 Task_1
  71 > [Ruby:receiver:(2) 5.526270] [msg_test/INFO] "Task_0" done
  72 > [Ruby:receiver:(2) 5.526270] [msg_test/INFO] Wait to receive a task
  73 > [Tremblay:sender:(1) 5.542830] [msg_test/INFO] Send to receiver-0 Task_2
  74 > [Ruby:receiver:(2) 5.542830] [msg_test/INFO] Received "Task_1"
  75 > [Ruby:receiver:(2) 5.542830] [msg_test/INFO] Processing "Task_1"
  76 > [Ruby:receiver:(2) 6.052540] [msg_test/INFO] "Task_1" done
  77 > [Ruby:receiver:(2) 6.052540] [msg_test/INFO] Wait to receive a task
  78 > [Tremblay:sender:(1) 6.069100] [msg_test/INFO] Send to receiver-0 finalize
  79 > [Ruby:receiver:(2) 6.069100] [msg_test/INFO] Received "Task_2"
  80 > [Ruby:receiver:(2) 6.069100] [msg_test/INFO] Processing "Task_2"
  81 > [Ruby:receiver:(2) 6.578810] [msg_test/INFO] "Task_2" done
  82 > [Ruby:receiver:(2) 6.578810] [msg_test/INFO] Wait to receive a task
  83 > [Tremblay:sender:(1) 6.580370] [msg_test/INFO] Goodbye now!
  84 > [Ruby:receiver:(2) 6.580370] [msg_test/INFO] Received "finalize"
  85 > [Ruby:receiver:(2) 6.580370] [msg_test/INFO] I'm done. See you!
  86 > [6.580370] [msg_test/INFO] Simulation time 6.58037
  87
  88
  89 p Test2 MSG_comm_wait() with Sleep_sender < Sleep_receiver
  90
  91 $ ./peer small_platform.xml deployment_peer04.xml
  92 > [Tremblay:sender:(1) 0.000000] [msg_test/INFO] sleep_start_time : 1.000000 , sleep_test_time : 0.000000
  93 > [Ruby:receiver:(2) 0.000000] [msg_test/INFO] sleep_start_time : 5.000000 , sleep_test_time : 0.000000
  94 > [Tremblay:sender:(1) 1.000000] [msg_test/INFO] Send to receiver-0 Task_0
  95 > [Ruby:receiver:(2) 5.000000] [msg_test/INFO] Wait to receive a task
  96 > [Tremblay:sender:(1) 5.016560] [msg_test/INFO] Send to receiver-0 Task_1
  97 > [Ruby:receiver:(2) 5.016560] [msg_test/INFO] Received "Task_0"
  98 > [Ruby:receiver:(2) 5.016560] [msg_test/INFO] Processing "Task_0"
  99 > [Ruby:receiver:(2) 5.526270] [msg_test/INFO] "Task_0" done
 100 > [Ruby:receiver:(2) 5.526270] [msg_test/INFO] Wait to receive a task
 101 > [Tremblay:sender:(1) 5.542830] [msg_test/INFO] Send to receiver-0 Task_2
 102 > [Ruby:receiver:(2) 5.542830] [msg_test/INFO] Received "Task_1"
 103 > [Ruby:receiver:(2) 5.542830] [msg_test/INFO] Processing "Task_1"
 104 > [Ruby:receiver:(2) 6.052540] [msg_test/INFO] "Task_1" done
 105 > [Ruby:receiver:(2) 6.052540] [msg_test/INFO] Wait to receive a task
 106 > [Tremblay:sender:(1) 6.069100] [msg_test/INFO] Send to receiver-0 finalize
 107 > [Ruby:receiver:(2) 6.069100] [msg_test/INFO] Received "Task_2"
 108 > [Ruby:receiver:(2) 6.069100] [msg_test/INFO] Processing "Task_2"
 109 > [Ruby:receiver:(2) 6.578810] [msg_test/INFO] "Task_2" done
 110 > [Ruby:receiver:(2) 6.578810] [msg_test/INFO] Wait to receive a task
 111 > [Tremblay:sender:(1) 6.580370] [msg_test/INFO] Goodbye now!
 112 > [Ruby:receiver:(2) 6.580370] [msg_test/INFO] Received "finalize"
 113 > [Ruby:receiver:(2) 6.580370] [msg_test/INFO] I'm done. See you!
 114 > [6.580370] [msg_test/INFO] Simulation time 6.58037
 115
 116
 117 p Test1 MSG_comm_waitall() for sender
 118
 119 $ ./peer2 small_platform.xml deployment_peer.xml
 120 > [Tremblay:sender:(1) 0.000000] [msg_test/INFO] Send to receiver-0 Task_0
 121 > [Tremblay:sender:(1) 0.000000] [msg_test/INFO] Send to receiver-0 Task_1
 122 > [Tremblay:sender:(1) 0.000000] [msg_test/INFO] Send to receiver-0 Task_2
 123 > [Tremblay:sender:(1) 0.000000] [msg_test/INFO] Send to receiver-0 finalize
 124 > [Tremblay:sender:(1) 0.000000] [msg_gos/INFO] NB_WAIT_TO_DO : 4
 125 > [Ruby:receiver:(2) 10.000000] [msg_test/INFO] Wait to receive a task
 126 > [Ruby:receiver:(2) 10.016560] [msg_test/INFO] Received "Task_0"
 127 > [Ruby:receiver:(2) 10.016560] [msg_test/INFO] Processing "Task_0"
 128 > [Ruby:receiver:(2) 10.526270] [msg_test/INFO] "Task_0" done
 129 > [Ruby:receiver:(2) 10.526270] [msg_test/INFO] Wait to receive a task
 130 > [Ruby:receiver:(2) 10.542830] [msg_test/INFO] Received "Task_1"
 131 > [Ruby:receiver:(2) 10.542830] [msg_test/INFO] Processing "Task_1"
 132 > [Ruby:receiver:(2) 11.052540] [msg_test/INFO] "Task_1" done
 133 > [Ruby:receiver:(2) 11.052540] [msg_test/INFO] Wait to receive a task
 134 > [Ruby:receiver:(2) 11.069100] [msg_test/INFO] Received "Task_2"
 135 > [Ruby:receiver:(2) 11.069100] [msg_test/INFO] Processing "Task_2"
 136 > [Ruby:receiver:(2) 11.578810] [msg_test/INFO] "Task_2" done
 137 > [Ruby:receiver:(2) 11.578810] [msg_test/INFO] Wait to receive a task
 138 > [Tremblay:sender:(1) 11.580370] [msg_test/INFO] Goodbye now!
 139 > [Ruby:receiver:(2) 11.580370] [msg_test/INFO] Received "finalize"
 140 > [Ruby:receiver:(2) 11.580370] [msg_test/INFO] I'm done. See you!
 141 > [11.580370] [msg_test/INFO] Simulation time 11.5804
 142
 143