1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
#!/usr/bin/env python
import glob
import subprocess
import select
import os
import os.path
import time
DIRS=['bug*', 'sr*', 'deb*', 'ticket*', 'issue*']
NUMJOBS=4
class Job(object):
def __init__(self, dirname, poll):
self.dirname = dirname
self.poll = poll
self.out = ''
def start(self):
self.p = subprocess.Popen(
['./testsuite.sh'],
stdout=subprocess.PIPE, stderr=subprocess.STDOUT, close_fds=True,
cwd=self.dirname)
self.out_fd = self.p.stdout
self.poll.extend([self.out_fd])
def wait(self):
self.poll.remove(self.out_fd)
return self.p.wait()
def run():
# List of tests to run
tests = []
for d in DIRS:
tests.extend(glob.glob(d))
jobs = []
poll = []
num = 0
while len(tests) != 0 or len(jobs) != 0:
# Start as many jobs as possible
if len(tests) > 0 and len(jobs) < NUMJOBS:
test = tests.pop(0)
j = Job(test, poll)
jobs.append(j)
print('Starting {}'.format(test))
j.start()
elif len(jobs) > 0:
#print('polling {}'.format(poll))
assert len(poll) == NUMJOBS or len(tests) == 0
t1 = time.time()
res = select.select(poll, [], [])
t2 = time.time()
#print('poll res {}sec: {}'.format(t2 - t2, res[0]))
done = set()
for fd in res[0]:
d = os.read(fd.fileno(), 1024)
if len(d) == 0:
for j in jobs:
if fd == j.out_fd:
done.add(j)
break
else:
for j in jobs:
if fd == j.out_fd:
j.out += d
for j in done:
print('Finish: {}'.format(j.dirname))
print(j.out)
code = j.wait()
if code != 0:
print('############### Error for {}'.format(j.dirname))
jobs.remove(j)
num += 1
print('{} tests run'.format(num))
if __name__ == '__main__':
run()
|