3 p Testing Comm.wait_all_for()
5 $ ${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"
6 >[ 0.000000] (2:worker@Ruby) worker-0 started
7 >[ 0.000000] (1:client@Tremblay) client started
8 >[ 0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=1.0s)
9 >[ 0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 1.0s to complete)
10 >[ 1.000000] (1:client@Tremblay) received 0/5 results
11 >[ 1.000000] (1:client@Tremblay) job-0 status=pending result_payload=
12 >[ 1.000000] (1:client@Tremblay) job-1 status=pending result_payload=
13 >[ 1.000000] (1:client@Tremblay) job-2 status=pending result_payload=
14 >[ 1.000000] (1:client@Tremblay) job-3 status=pending result_payload=
15 >[ 1.000000] (1:client@Tremblay) job-4 status=pending result_payload=
17 $ ${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"
18 >[ 0.000000] (2:worker@Ruby) worker-0 started
19 >[ 0.000000] (1:client@Tremblay) client started
20 >[ 0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=5.0s)
21 >[ 0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 1.0s to complete)
22 >[ 1.008029] (2:worker@Ruby) worker-0 working on job-1 (will take 2.0s to complete)
23 >[ 3.014105] (2:worker@Ruby) worker-0 working on job-2 (will take 3.0s to complete)
24 >[ 5.000000] (1:client@Tremblay) received 2/5 results
25 >[ 5.000000] (1:client@Tremblay) job-0 status=complete result_payload=worker-0
26 >[ 5.000000] (1:client@Tremblay) job-1 status=complete result_payload=worker-0
27 >[ 5.000000] (1:client@Tremblay) job-2 status=pending result_payload=
28 >[ 5.000000] (1:client@Tremblay) job-3 status=pending result_payload=
29 >[ 5.000000] (1:client@Tremblay) job-4 status=pending result_payload=
31 $ ${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"
32 >[ 0.000000] (2:worker@Ruby) worker-0 started
33 >[ 0.000000] (1:client@Tremblay) client started
34 >[ 0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=-1.0s)
35 >[ 0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 1.0s to complete)
36 >[ 1.008029] (2:worker@Ruby) worker-0 working on job-1 (will take 2.0s to complete)
37 >[ 3.014105] (2:worker@Ruby) worker-0 working on job-2 (will take 3.0s to complete)
38 >[ 6.020181] (2:worker@Ruby) worker-0 working on job-3 (will take 4.0s to complete)
39 >[ 10.026257] (2:worker@Ruby) worker-0 working on job-4 (will take 5.0s to complete)
40 >[ 15.030379] (1:client@Tremblay) received 5/5 results
41 >[ 15.030379] (1:client@Tremblay) job-0 status=complete result_payload=worker-0
42 >[ 15.030379] (1:client@Tremblay) job-1 status=complete result_payload=worker-0
43 >[ 15.030379] (1:client@Tremblay) job-2 status=complete result_payload=worker-0
44 >[ 15.030379] (1:client@Tremblay) job-3 status=complete result_payload=worker-0
45 >[ 15.030379] (1:client@Tremblay) job-4 status=complete result_payload=worker-0
47 $ ${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"
48 >[ 0.000000] (2:worker@Ruby) worker-0 started
49 >[ 0.000000] (3:worker@Ruby) worker-1 started
50 >[ 0.000000] (4:worker@Ruby) worker-2 started
51 >[ 0.000000] (5:worker@Ruby) worker-3 started
52 >[ 0.000000] (6:worker@Ruby) worker-4 started
53 >[ 0.000000] (1:client@Tremblay) client started
54 >[ 0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=3.0s)
55 >[ 0.001954] (6:worker@Ruby) worker-4 working on job-4 (will take 5.0s to complete)
56 >[ 0.001954] (5:worker@Ruby) worker-3 working on job-3 (will take 4.0s to complete)
57 >[ 0.001954] (4:worker@Ruby) worker-2 working on job-2 (will take 3.0s to complete)
58 >[ 0.001954] (3:worker@Ruby) worker-1 working on job-1 (will take 2.0s to complete)
59 >[ 0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 1.0s to complete)
60 >[ 3.000000] (1:client@Tremblay) received 2/5 results
61 >[ 3.000000] (1:client@Tremblay) job-0 status=complete result_payload=worker-0
62 >[ 3.000000] (1:client@Tremblay) job-1 status=complete result_payload=worker-1
63 >[ 3.000000] (1:client@Tremblay) job-2 status=pending result_payload=
64 >[ 3.000000] (1:client@Tremblay) job-3 status=pending result_payload=
65 >[ 3.000000] (1:client@Tremblay) job-4 status=pending result_payload=
67 $ ${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"
68 >[ 0.000000] (2:worker@Ruby) worker-0 started
69 >[ 0.000000] (3:worker@Ruby) worker-1 started
70 >[ 0.000000] (4:worker@Ruby) worker-2 started
71 >[ 0.000000] (5:worker@Ruby) worker-3 started
72 >[ 0.000000] (6:worker@Ruby) worker-4 started
73 >[ 0.000000] (1:client@Tremblay) client started
74 >[ 0.000000] (1:client@Tremblay) awaiting results for all jobs (timeout=-1.0s)
75 >[ 0.001954] (6:worker@Ruby) worker-4 working on job-4 (will take 5.0s to complete)
76 >[ 0.001954] (5:worker@Ruby) worker-3 working on job-3 (will take 20.0s to complete)
77 >[ 0.001954] (4:worker@Ruby) worker-2 working on job-2 (will take 5.0s to complete)
78 >[ 0.001954] (3:worker@Ruby) worker-1 working on job-1 (will take 10.0s to complete)
79 >[ 0.001954] (2:worker@Ruby) worker-0 working on job-0 (will take 5.0s to complete)
80 >[ 5.008029] (2:worker@Ruby) worker-0 working on job-7 (will take 80.0s to complete)
81 >[ 5.008029] (4:worker@Ruby) worker-2 working on job-6 (will take 5.0s to complete)
82 >[ 5.008029] (6:worker@Ruby) worker-4 working on job-5 (will take 40.0s to complete)
83 >[ 10.008029] (3:worker@Ruby) worker-1 working on job-8 (will take 5.0s to complete)
84 >[ 10.014105] (4:worker@Ruby) worker-2 working on job-9 (will take 160.0s to complete)
85 >[170.018227] (1:client@Tremblay) received 10/10 results
86 >[170.018227] (1:client@Tremblay) job-0 status=complete result_payload=worker-0
87 >[170.018227] (1:client@Tremblay) job-1 status=complete result_payload=worker-1
88 >[170.018227] (1:client@Tremblay) job-2 status=complete result_payload=worker-2
89 >[170.018227] (1:client@Tremblay) job-3 status=complete result_payload=worker-3
90 >[170.018227] (1:client@Tremblay) job-4 status=complete result_payload=worker-4
91 >[170.018227] (1:client@Tremblay) job-5 status=complete result_payload=worker-4
92 >[170.018227] (1:client@Tremblay) job-6 status=complete result_payload=worker-2
93 >[170.018227] (1:client@Tremblay) job-7 status=complete result_payload=worker-0
94 >[170.018227] (1:client@Tremblay) job-8 status=complete result_payload=worker-1
95 >[170.018227] (1:client@Tremblay) job-9 status=complete result_payload=worker-2