diff --git a/bin/iqmgr.py b/bin/iqmgr.py index ba5bf3b..544a441 100755 --- a/bin/iqmgr.py +++ b/bin/iqmgr.py @@ -21,9 +21,15 @@ if sys.argv[1].startswith("st"): print " slavesq : %d" % sq.qsize() if sys.argv[1] == 'slay': - for i in xrange(mq.qsize()): - print i, "killing", mq.get() - sq.put("slay") + if len(sys.argv) == 2: + for i in xrange(mq.qsize()): + print i, "killing", mq.get() + sq.put("slay") + elif len(sys.argv) == 3: + for i in xrange(int(sys.argv[2])): + print i, "killing ... jane?" + sq.put("slay") + if sys.argv[1] == 'clear': for i in xrange(tq.qsize()): print tq.get()