blob: 04a6be0d1b870a448ef1ec8a6532f053a1a4ffb1 [file] [log] [blame]
import time
print "--SELFTEST-- loading test"
us = [
'127.0.0.1#P1',
'127.0.0.1#P2',
'127.0.0.1#P3',
'127.0.0.1#P4',
'127.0.0.1#P5'
]
def payload1(wait, n):
time.sleep(wait)
print "--STEPTEST-- payload1 start"
b = job.barrier('127.0.0.1#P%d' % (n), 'here', 60)
b.rendezvous(*us)
print "--STEPTEST-- payload1 complete"
def payload2(wait, n):
time.sleep(wait)
print "--STEPTEST-- payload2 start"
b = job.barrier('127.0.0.1#P%d' % (n), 'here', 60)
b.rendezvous(*us)
time.sleep(1)
print "--STEPTEST-- payload2 complete"
job.parallel(
[payload2, 5, 1],
[payload2, 10, 2],
[payload1, 15, 3],
[payload2, 20, 4],
[payload2, 25, 5]
)