examples/msg/icomms/peer.tesh

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