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())