From 1fa69670c3df7a3aefa800d693ef07cd9021ff2e Mon Sep 17 00:00:00 2001 From: Stephen Mardson McQuay Date: Sat, 2 Apr 2011 00:34:33 -0600 Subject: [PATCH] can now sent teardown to slaves via script, and renamed to iqmgr.py --HG-- rename : bin/iqstat.py => bin/iqmgr.py --- bin/iqmgr.py | 32 ++++++++++++++++++++++++++++++++ 1 file changed, 32 insertions(+) create mode 100755 bin/iqmgr.py diff --git a/bin/iqmgr.py b/bin/iqmgr.py new file mode 100755 index 0000000..19ba84a --- /dev/null +++ b/bin/iqmgr.py @@ -0,0 +1,32 @@ +#!/usr/bin/env python + +import sys +import interp.bootstrap +from interp.cluster import QueueManager, get_qs + +m = QueueManager(address=('localhost', 6666), authkey='asdf') +m.connect() + +tq,rq,mq,sq = get_qs(m) + +if len(sys.argv) == 1: + sys.argv.append("st") + + +if sys.argv[1].startswith("st"): + print "interp queue status:" + print " tasksq : %d" % tq.qsize() + print " resultsq : %d" % rq.qsize() + print " masterq : %d" % mq.qsize() + print " slavesq : %d" % sq.qsize() + +if sys.argv[1] == 'teardown': + for i in xrange(mq.qsize()): + print i, "killing", mq.get() + sq.put("teardown") + +if sys.argv[1] == 'clear': + for i in xrange(tq.qsize()): print tq.get() + for i in xrange(rq.qsize()): print rq.get() + for i in xrange(mq.qsize()): print mq.get() + for i in xrange(sq.qsize()): print sq.get()