sm/smbinterp
1
0
Fork 0
Code Issues Pull Requests Activity

some error detection: make sure the set of reported workers has no duplicate entries

Browse Source
This commit is contained in:
Stephen McQuay 2011-05-24 13:46:07 -06:00
parent d7aebc7be0
commit 4d60ca0c3c
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
bin/master.py
View File

@ -59,12 +59,15 @@ if __name__ == '__main__':
tasksq, resultsq, masterq, minionsq = get_qs(m) tasksq, resultsq, masterq, minionsq = get_qs(m)
workers = []
if not options.participants: if not options.participants:
print "wait on all announced participants" print "wait on all announced participants"
participants = 0 participants = 0
while not masterq.empty(): while not masterq.empty():
participants += 1 participants += 1
worker = masterq.get() worker = masterq.get()
workers.append(worker)
print "%d: %s is ready" % (participants, worker) print "%d: %s is ready" % (participants, worker)
if participants == 0: if participants == 0:
print "nobody found" print "nobody found"
@ -74,8 +77,14 @@ if __name__ == '__main__':
print "wait on %d participants" % participants print "wait on %d participants" % participants
for i in xrange(participants): for i in xrange(participants):
worker = masterq.get() worker = masterq.get()
workers.append(worker)
print "%d of %d: %s is ready" % (i+1, participants, worker) print "%d of %d: %s is ready" % (i+1, participants, worker)
if len(set(workers)) != len(workers):
for i in workers:
minionsq.put("slay")
raise Exception("duplicate workers reported")
results = [] results = []
widgets = ['submit jobs: ', Percentage(), ' ', Bar(), ' ', ETA()] widgets = ['submit jobs: ', Percentage(), ' ', Bar(), ' ', ETA()]