examples/java/cloud/masterworker/cloud_masterworker.tesh

   1 #! tesh
   2
   3 ! output sort 19
   4
   5 $ java -classpath ${classpath:=.} cloud/masterworker/Main ${srcdir:=.}/../platforms/small_platform.xml "--log=root.fmt:[%10.6r]%e(%i:%P@%h)%e%m%n"
   6 > [  0.000000] (0:maestro@) Using regular java threads.
   7 > [  0.000000] (0:maestro@) Start 2 hosts
   8 > [  0.000000] (1:Master@Boivin) create VM00
   9 > [  0.000000] (1:Master@Boivin) Put Worker WRK00 on VM00
  10 > [  0.000000] (1:Master@Boivin) create VM01
  11 > [  0.000000] (1:Master@Boivin) Put Worker WRK01 on VM01
  12 > [  0.000000] (1:Master@Boivin) Launched 2 VMs
  13 > [  0.000000] (1:Master@Boivin) Send a first batch of work to everyone
  14 > [  0.000000] (1:Master@Boivin) Sending to WRK00
  15 > [  0.000000] (2:WRK00@VM00) WRK00 is listening on MBOX:WRK00
  16 > [  0.000000] (3:WRK01@VM01) WRK01 is listening on MBOX:WRK01
  17 > [  0.090194] (1:Master@Boivin) Sending to WRK01
  18 > [  0.090194] (2:WRK00@VM00) Received "Task00". Processing it.
  19 > [  0.090194] (2:WRK00@VM00) WRK00 executed task (Task00)
  20 > [  0.754233] (1:Master@Boivin) Suspend all VMs
  21 > [  0.754233] (1:Master@Boivin) Suspend VM00
  22 > [  0.754233] (1:Master@Boivin) Suspend VM01
  23 > [  0.754233] (1:Master@Boivin) Wait a while
  24 > [  0.754233] (3:WRK01@VM01) Received "Task01". Processing it.
  25 > [  2.754233] (1:Master@Boivin) Resume all VMs.
  26 > [  2.754233] (1:Master@Boivin) Sleep long enough for everyone to be done with previous batch of work
  27 > [  2.754234] (3:WRK01@VM01) WRK01 executed task (Task01)
  28 > [1000.000000] (1:Master@Boivin) Migrate everyone to Ginette
  29 > [1000.000000] (1:Master@Boivin) Migrate VM00fromBourassato Ginette
  30 > [1100.157755] (1:Master@Boivin) Migrate VM01fromFafardto Ginette
  31 > [1242.754111] (0:maestro@) MSG_main finished; Cleaning up the simulation...
  32 > [1242.754111] (1:Master@Boivin) Let's shut down the simulation and kill everyone.
  33 > [1242.754111] (1:Master@Boivin) Master done.