From 314142b11aa7d008e3b3fc4cbbf292e6084dda10 Mon Sep 17 00:00:00 2001 From: Stephen Mardson McQuay Date: Fri, 1 Apr 2011 14:51:12 -0600 Subject: [PATCH] added a qstat like script --- bin/iqstat.py | 13 +++++++++++++ 1 file changed, 13 insertions(+) create mode 100644 bin/iqstat.py diff --git a/bin/iqstat.py b/bin/iqstat.py new file mode 100644 index 0000000..0c196c6 --- /dev/null +++ b/bin/iqstat.py @@ -0,0 +1,13 @@ +import interp.bootstrap +from multiprocessing.managers import BaseManager +class QueueManager(BaseManager): pass +QueueManager.register('get_inqueue' ) +QueueManager.register('get_outqueue') +m = QueueManager(address=('localhost', 6666), authkey='asdf') +m.connect() +m.get_outqueue() +oq = m.get_outqueue() +iq = m.get_inqueue() + +print "interp queue status:" +print " oq: %d, iq: %d" % (oq.qsize(), iq.qsize())