From c3f70edc456bb47c2058a424f99e4673b8586214 Mon Sep 17 00:00:00 2001
From: Tim Laszlo <tim.laszlo@gmail.com>
Date: Thu, 14 Jun 2012 11:07:22 -0500
Subject: DBStats: watch for missing work queue (cherry picked from commit
 d0555789f2af89817b4bf50a4d88e98ad6c20730)

---
 src/lib/Server/Plugin.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/lib/Server/Plugin.py b/src/lib/Server/Plugin.py
index 3e3616f46..28299d8c7 100644
--- a/src/lib/Server/Plugin.py
+++ b/src/lib/Server/Plugin.py
@@ -289,7 +289,7 @@ class ThreadedStatistics(Statistics,
     def run(self):
         if not self.load():
             return
-        while not self.terminate.isSet():
+        while not self.terminate.isSet() and self.work_queue != None:
             try:
                 (xdata, client) = self.work_queue.get(block=True, timeout=2)
             except Empty:
@@ -299,7 +299,7 @@ class ThreadedStatistics(Statistics,
                 self.logger.error("ThreadedStatistics: %s" % e)
                 continue
             self.handle_statistic(xdata, client)
-        if not self.work_queue.empty():
+        if self.work_queue != None and not self.work_queue.empty():
             self.save()
 
     def process_statistics(self, metadata, data):
-- 
cgit v1.2.3-1-g7c22