From 231fe8d8c1d5bbd7cc414af5694b7043f803e255 Mon Sep 17 00:00:00 2001 From: "Steve L. Nyemba" Date: Fri, 23 Dec 2016 08:10:56 -0600 Subject: [PATCH] TODO: We need a form of in-memory store --- src/monitor.py | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/src/monitor.py b/src/monitor.py index 93c276f..80ed6a9 100755 --- a/src/monitor.py +++ b/src/monitor.py @@ -11,6 +11,8 @@ import subprocess from sets import Set import re import datetime +import Queue + class Analysis: def __init__(self): @@ -182,3 +184,11 @@ class DetailProcess(Analysis): #return [{"memory_usage":row[0],"cpu_usage":row[1],"memory_available":row[2]/1000,"label":row[3]} for row in ma] return ma + +class QListener(Thread) + def __init__(self,handlers): + self.handlers = handlers + self.queue = Queue.LifoQueue() + def post(self) : + for handler in self.handlers: + self.queue.put(handler.) \ No newline at end of file