examples/python/comm-ready/comm-ready.tesh

   1 #!/usr/bin/env tesh
   2
   3 p Peer sending and receiving
   4
   5 $ ${pythoncmd:=python3} ${PYTHON_TOOL_OPTIONS:=} ${bindir:=.}/comm-ready.py --platform ${platfdir}/small_platform_fatpipe.xml "--log=root.fmt:[%10.6r]%e(%i:%a@%h)%e%m%n"
   6 >[  0.000000] (1:peer@Tremblay) Send 'Message 0 from peer 0' to 'peer-1'
   7 >[  0.000000] (2:peer@Ruby) Send 'Message 0 from peer 1' to 'peer-0'
   8 >[  0.000000] (3:peer@Perl) Send 'finalize' to 'peer-0'
   9 >[  0.000000] (1:peer@Tremblay) Send 'Message 0 from peer 0' to 'peer-2'
  10 >[  0.000000] (2:peer@Ruby) Send 'Message 0 from peer 1' to 'peer-2'
  11 >[  0.000000] (3:peer@Perl) Send 'finalize' to 'peer-1'
  12 >[  0.000000] (3:peer@Perl) Done dispatching all messages
  13 >[  0.000000] (3:peer@Perl) Nothing ready to consume yet, I better sleep for a while
  14 >[  0.000000] (1:peer@Tremblay) Send 'Message 1 from peer 0' to 'peer-1'
  15 >[  0.000000] (2:peer@Ruby) Send 'Message 1 from peer 1' to 'peer-0'
  16 >[  0.000000] (1:peer@Tremblay) Send 'Message 1 from peer 0' to 'peer-2'
  17 >[  0.000000] (2:peer@Ruby) Send 'Message 1 from peer 1' to 'peer-2'
  18 >[  0.000000] (2:peer@Ruby) Send 'Message 2 from peer 1' to 'peer-0'
  19 >[  0.000000] (1:peer@Tremblay) Send 'finalize' to 'peer-1'
  20 >[  0.000000] (2:peer@Ruby) Send 'Message 2 from peer 1' to 'peer-2'
  21 >[  0.000000] (1:peer@Tremblay) Send 'finalize' to 'peer-2'
  22 >[  0.000000] (1:peer@Tremblay) Done dispatching all messages
  23 >[  0.000000] (1:peer@Tremblay) Nothing ready to consume yet, I better sleep for a while
  24 >[  0.000000] (2:peer@Ruby) Send 'Message 3 from peer 1' to 'peer-0'
  25 >[  0.000000] (2:peer@Ruby) Send 'Message 3 from peer 1' to 'peer-2'
  26 >[  0.000000] (2:peer@Ruby) Send 'Message 4 from peer 1' to 'peer-0'
  27 >[  0.000000] (2:peer@Ruby) Send 'Message 4 from peer 1' to 'peer-2'
  28 >[  0.000000] (2:peer@Ruby) Send 'Message 5 from peer 1' to 'peer-0'
  29 >[  0.000000] (2:peer@Ruby) Send 'Message 5 from peer 1' to 'peer-2'
  30 >[  0.000000] (2:peer@Ruby) Send 'finalize' to 'peer-0'
  31 >[  0.000000] (2:peer@Ruby) Send 'finalize' to 'peer-2'
  32 >[  0.000000] (2:peer@Ruby) Done dispatching all messages
  33 >[  0.000000] (2:peer@Ruby) Nothing ready to consume yet, I better sleep for a while
  34 >[  0.010000] (2:peer@Ruby) Nothing ready to consume yet, I better sleep for a while
  35 >[  0.010000] (3:peer@Perl) Nothing ready to consume yet, I better sleep for a while
  36 >[  0.010000] (1:peer@Tremblay) I got a 'Message 0 from peer 1'.
  37 >[  0.010000] (1:peer@Tremblay) Nothing ready to consume yet, I better sleep for a while
  38 >[  0.020000] (1:peer@Tremblay) Nothing ready to consume yet, I better sleep for a while
  39 >[  0.020000] (3:peer@Perl) Nothing ready to consume yet, I better sleep for a while
  40 >[  0.020000] (2:peer@Ruby) Nothing ready to consume yet, I better sleep for a while
  41 >[  0.030000] (2:peer@Ruby) Nothing ready to consume yet, I better sleep for a while
  42 >[  0.030000] (3:peer@Perl) Nothing ready to consume yet, I better sleep for a while
  43 >[  0.030000] (1:peer@Tremblay) Nothing ready to consume yet, I better sleep for a while
  44 >[  0.040000] (1:peer@Tremblay) Nothing ready to consume yet, I better sleep for a while
  45 >[  0.040000] (3:peer@Perl) Nothing ready to consume yet, I better sleep for a while
  46 >[  0.040000] (2:peer@Ruby) Nothing ready to consume yet, I better sleep for a while
  47 >[  0.050000] (2:peer@Ruby) Nothing ready to consume yet, I better sleep for a while
  48 >[  0.050000] (3:peer@Perl) Nothing ready to consume yet, I better sleep for a while
  49 >[  0.050000] (1:peer@Tremblay) Nothing ready to consume yet, I better sleep for a while
  50 >[  0.060000] (1:peer@Tremblay) Nothing ready to consume yet, I better sleep for a while
  51 >[  0.060000] (3:peer@Perl) Nothing ready to consume yet, I better sleep for a while
  52 >[  0.060000] (2:peer@Ruby) Nothing ready to consume yet, I better sleep for a while
  53 >[  0.070000] (2:peer@Ruby) Nothing ready to consume yet, I better sleep for a while
  54 >[  0.070000] (3:peer@Perl) Nothing ready to consume yet, I better sleep for a while
  55 >[  0.070000] (1:peer@Tremblay) Nothing ready to consume yet, I better sleep for a while
  56 >[  0.080000] (1:peer@Tremblay) Nothing ready to consume yet, I better sleep for a while
  57 >[  0.080000] (3:peer@Perl) Nothing ready to consume yet, I better sleep for a while
  58 >[  0.080000] (2:peer@Ruby) Nothing ready to consume yet, I better sleep for a while
  59 >[  0.090000] (2:peer@Ruby) Nothing ready to consume yet, I better sleep for a while
  60 >[  0.090000] (3:peer@Perl) Nothing ready to consume yet, I better sleep for a while
  61 >[  0.090000] (1:peer@Tremblay) Nothing ready to consume yet, I better sleep for a while
  62 >[  0.100000] (1:peer@Tremblay) Nothing ready to consume yet, I better sleep for a while
  63 >[  0.100000] (3:peer@Perl) Nothing ready to consume yet, I better sleep for a while
  64 >[  0.100000] (2:peer@Ruby) Nothing ready to consume yet, I better sleep for a while
  65 >[  0.110000] (2:peer@Ruby) I got a 'Message 0 from peer 0'.
  66 >[  0.110000] (3:peer@Perl) I got a 'Message 0 from peer 0'.
  67 >[  0.110000] (1:peer@Tremblay) I got a 'finalize'.
  68 >[  0.110000] (2:peer@Ruby) I got a 'finalize'.
  69 >[  0.110000] (3:peer@Perl) I got a 'Message 0 from peer 1'.
  70 >[  0.110000] (1:peer@Tremblay) I got a 'Message 1 from peer 1'.
  71 >[  0.110000] (2:peer@Ruby) I got a 'Message 1 from peer 0'.
  72 >[  0.110000] (3:peer@Perl) I got a 'Message 1 from peer 0'.
  73 >[  0.110000] (1:peer@Tremblay) I got a 'Message 2 from peer 1'.
  74 >[  0.110000] (2:peer@Ruby) I got a 'finalize'.
  75 >[  0.110000] (2:peer@Ruby) I'm done, just waiting for my peers to receive the messages before exiting
  76 >[  0.110000] (3:peer@Perl) I got a 'Message 1 from peer 1'.
  77 >[  0.110000] (1:peer@Tremblay) I got a 'Message 3 from peer 1'.
  78 >[  0.110000] (3:peer@Perl) I got a 'finalize'.
  79 >[  0.110000] (1:peer@Tremblay) I got a 'Message 4 from peer 1'.
  80 >[  0.110000] (3:peer@Perl) I got a 'Message 2 from peer 1'.
  81 >[  0.110000] (1:peer@Tremblay) I got a 'Message 5 from peer 1'.
  82 >[  0.110000] (3:peer@Perl) I got a 'Message 3 from peer 1'.
  83 >[  0.110000] (1:peer@Tremblay) I got a 'finalize'.
  84 >[  0.110000] (1:peer@Tremblay) I'm done, just waiting for my peers to receive the messages before exiting
  85 >[  0.110000] (3:peer@Perl) I got a 'Message 4 from peer 1'.
  86 >[  0.110000] (3:peer@Perl) I got a 'Message 5 from peer 1'.
  87 >[  0.110000] (3:peer@Perl) I got a 'finalize'.
  88 >[  0.110000] (3:peer@Perl) I'm done, just waiting for my peers to receive the messages before exiting
  89 >[  0.110000] (1:peer@Tremblay) Goodbye now!
  90 >[  0.110000] (2:peer@Ruby) Goodbye now!
  91 >[  0.110000] (3:peer@Perl) Goodbye now!