| apw | 89beac3 | 2006-09-25 22:06:10 +0000 | [diff] [blame] | 1 | import time |
| 2 | import random | ||||
| 3 | |||||
| 4 | print "--SELFTEST-- loading test" | ||||
| 5 | |||||
| 6 | max = 10 | ||||
| 7 | |||||
| 8 | def payload1(id): | ||||
| 9 | print "--STEPTEST-- payload1 start" | ||||
| 10 | |||||
| 11 | time.sleep(random.randint(1, 5)) | ||||
| 12 | |||||
| 13 | b = job.barrier('127.0.0.1#P%d' % (id), 'here', 60) | ||||
| 14 | b.rendevous(*us) | ||||
| 15 | |||||
| 16 | print "--STEPTEST-- payload1 complete" | ||||
| 17 | |||||
| 18 | us = [] | ||||
| 19 | jobs = [] | ||||
| 20 | for n in range(1, max+1): | ||||
| 21 | us.append('127.0.0.1#P%d' % (n)) | ||||
| 22 | jobs.append([payload1, n]) | ||||
| 23 | |||||
| 24 | job.parallel(*jobs) | ||||