added a mechanism to the iqmgr to help correct an artificially empty masterq
This commit is contained in:
parent
d5a0d969f8
commit
5c46b568ae
@ -20,6 +20,10 @@ if sys.argv[1].startswith("st"):
|
|||||||
print " masterq : %d" % mq.qsize()
|
print " masterq : %d" % mq.qsize()
|
||||||
print " slavesq : %d" % sq.qsize()
|
print " slavesq : %d" % sq.qsize()
|
||||||
|
|
||||||
|
if sys.argv[1] == 'add':
|
||||||
|
for i in xrange(int(sys.argv[2])):
|
||||||
|
mq.put('jane')
|
||||||
|
|
||||||
if sys.argv[1] == 'slay':
|
if sys.argv[1] == 'slay':
|
||||||
if len(sys.argv) == 2:
|
if len(sys.argv) == 2:
|
||||||
for i in xrange(mq.qsize()):
|
for i in xrange(mq.qsize()):
|
||||||
|
Loading…
Reference in New Issue
Block a user