#!/usr/bin/env tesh

p Testing Comm.wait_all_for()

$ ${pythoncmd:=python3} ${PYTHON_TOOL_OPTIONS:=} ${bindir:=.}/comm-waitallfor.py --platform ${platfdir}/small_platform_fatpipe.xml --workers 1 --wait-timeout 1 --jobs 1,2,3,4,5 "--log=root.fmt:[%10.6r]%e(%i:%a@%h)%e%m%n"
>[  0.000000] (2:worker@Ruby) worker-0 started
>[  0.000000] (1:client@Tremblay) client started
>[  0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=1.0s)
>[  0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 1.0s to complete)
>[  1.000000] (1:client@Tremblay) received 0/5 results
>[  1.000000] (1:client@Tremblay) job-0 status=pending result_payload=
>[  1.000000] (1:client@Tremblay) job-1 status=pending result_payload=
>[  1.000000] (1:client@Tremblay) job-2 status=pending result_payload=
>[  1.000000] (1:client@Tremblay) job-3 status=pending result_payload=
>[  1.000000] (1:client@Tremblay) job-4 status=pending result_payload=

$ ${pythoncmd:=python3} ${PYTHON_TOOL_OPTIONS:=} ${bindir:=.}/comm-waitallfor.py --platform ${platfdir}/small_platform_fatpipe.xml --workers 1 --wait-timeout 5 --jobs 1,2,3,4,5 "--log=root.fmt:[%10.6r]%e(%i:%a@%h)%e%m%n"
>[  0.000000] (2:worker@Ruby) worker-0 started
>[  0.000000] (1:client@Tremblay) client started
>[  0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=5.0s)
>[  0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 1.0s to complete)
>[  1.008029] (2:worker@Ruby) worker-0 working on job-1 (will take 2.0s to complete)
>[  3.014105] (2:worker@Ruby) worker-0 working on job-2 (will take 3.0s to complete)
>[  5.000000] (1:client@Tremblay) received 2/5 results
>[  5.000000] (1:client@Tremblay) job-0 status=complete result_payload=worker-0
>[  5.000000] (1:client@Tremblay) job-1 status=complete result_payload=worker-0
>[  5.000000] (1:client@Tremblay) job-2 status=pending result_payload=
>[  5.000000] (1:client@Tremblay) job-3 status=pending result_payload=
>[  5.000000] (1:client@Tremblay) job-4 status=pending result_payload=

$ ${pythoncmd:=python3} ${PYTHON_TOOL_OPTIONS:=} ${bindir:=.}/comm-waitallfor.py --platform ${platfdir}/small_platform_fatpipe.xml --workers 1 --wait-timeout -1 --jobs 1,2,3,4,5 "--log=root.fmt:[%10.6r]%e(%i:%a@%h)%e%m%n"
>[  0.000000] (2:worker@Ruby) worker-0 started
>[  0.000000] (1:client@Tremblay) client started
>[  0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=-1.0s)
>[  0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 1.0s to complete)
>[  1.008029] (2:worker@Ruby) worker-0 working on job-1 (will take 2.0s to complete)
>[  3.014105] (2:worker@Ruby) worker-0 working on job-2 (will take 3.0s to complete)
>[  6.020181] (2:worker@Ruby) worker-0 working on job-3 (will take 4.0s to complete)
>[ 10.026257] (2:worker@Ruby) worker-0 working on job-4 (will take 5.0s to complete)
>[ 15.030379] (1:client@Tremblay) received 5/5 results
>[ 15.030379] (1:client@Tremblay) job-0 status=complete result_payload=worker-0
>[ 15.030379] (1:client@Tremblay) job-1 status=complete result_payload=worker-0
>[ 15.030379] (1:client@Tremblay) job-2 status=complete result_payload=worker-0
>[ 15.030379] (1:client@Tremblay) job-3 status=complete result_payload=worker-0
>[ 15.030379] (1:client@Tremblay) job-4 status=complete result_payload=worker-0

$ ${pythoncmd:=python3} ${PYTHON_TOOL_OPTIONS:=} ${bindir:=.}/comm-waitallfor.py --platform ${platfdir}/small_platform_fatpipe.xml --workers 5 --wait-timeout 3 --jobs 1,2,3,4,5 "--log=root.fmt:[%10.6r]%e(%i:%a@%h)%e%m%n"
>[  0.000000] (2:worker@Ruby) worker-0 started
>[  0.000000] (3:worker@Ruby) worker-1 started
>[  0.000000] (4:worker@Ruby) worker-2 started
>[  0.000000] (5:worker@Ruby) worker-3 started
>[  0.000000] (6:worker@Ruby) worker-4 started
>[  0.000000] (1:client@Tremblay) client started
>[  0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=3.0s)
>[  0.001954] (6:worker@Ruby) worker-4 working on job-4 (will take 5.0s to complete)
>[  0.001954] (5:worker@Ruby) worker-3 working on job-3 (will take 4.0s to complete)
>[  0.001954] (4:worker@Ruby) worker-2 working on job-2 (will take 3.0s to complete)
>[  0.001954] (3:worker@Ruby) worker-1 working on job-1 (will take 2.0s to complete)
>[  0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 1.0s to complete)
>[  3.000000] (1:client@Tremblay) received 2/5 results
>[  3.000000] (1:client@Tremblay) job-0 status=complete result_payload=worker-0
>[  3.000000] (1:client@Tremblay) job-1 status=complete result_payload=worker-1
>[  3.000000] (1:client@Tremblay) job-2 status=pending result_payload=
>[  3.000000] (1:client@Tremblay) job-3 status=pending result_payload=
>[  3.000000] (1:client@Tremblay) job-4 status=pending result_payload=

$ ${pythoncmd:=python3} ${PYTHON_TOOL_OPTIONS:=} ${bindir:=.}/comm-waitallfor.py --platform ${platfdir}/small_platform_fatpipe.xml --workers 5 --wait-timeout -1 --jobs 5,10,5,20,5,40,5,80,5,160 "--log=root.fmt:[%10.6r]%e(%i:%a@%h)%e%m%n"
>[  0.000000] (2:worker@Ruby) worker-0 started
>[  0.000000] (3:worker@Ruby) worker-1 started
>[  0.000000] (4:worker@Ruby) worker-2 started
>[  0.000000] (5:worker@Ruby) worker-3 started
>[  0.000000] (6:worker@Ruby) worker-4 started
>[  0.000000] (1:client@Tremblay) client started
>[  0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=-1.0s)
>[  0.001954] (6:worker@Ruby) worker-4 working on job-4 (will take 5.0s to complete)
>[  0.001954] (5:worker@Ruby) worker-3 working on job-3 (will take 20.0s to complete)
>[  0.001954] (4:worker@Ruby) worker-2 working on job-2 (will take 5.0s to complete)
>[  0.001954] (3:worker@Ruby) worker-1 working on job-1 (will take 10.0s to complete)
>[  0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 5.0s to complete)
>[  5.008029] (2:worker@Ruby) worker-0 working on job-7 (will take 80.0s to complete)
>[  5.008029] (4:worker@Ruby) worker-2 working on job-6 (will take 5.0s to complete)
>[  5.008029] (6:worker@Ruby) worker-4 working on job-5 (will take 40.0s to complete)
>[ 10.008029] (3:worker@Ruby) worker-1 working on job-8 (will take 5.0s to complete)
>[ 10.014105] (4:worker@Ruby) worker-2 working on job-9 (will take 160.0s to complete)
>[170.018227] (1:client@Tremblay) received 10/10 results
>[170.018227] (1:client@Tremblay) job-0 status=complete result_payload=worker-0
>[170.018227] (1:client@Tremblay) job-1 status=complete result_payload=worker-1
>[170.018227] (1:client@Tremblay) job-2 status=complete result_payload=worker-2
>[170.018227] (1:client@Tremblay) job-3 status=complete result_payload=worker-3
>[170.018227] (1:client@Tremblay) job-4 status=complete result_payload=worker-4
>[170.018227] (1:client@Tremblay) job-5 status=complete result_payload=worker-4
>[170.018227] (1:client@Tremblay) job-6 status=complete result_payload=worker-2
>[170.018227] (1:client@Tremblay) job-7 status=complete result_payload=worker-0
>[170.018227] (1:client@Tremblay) job-8 status=complete result_payload=worker-1
>[170.018227] (1:client@Tremblay) job-9 status=complete result_payload=worker-2