From f813f86f8ac2bc7b55f4eb6a0d936f1ce4f68ba7 Mon Sep 17 00:00:00 2001
From: Michael Fenn <fennm@deshawresearch.com>
Date: Wed, 9 Oct 2013 15:59:42 -0400
Subject: Reporting: Simple sanity check to avoid creating too many threads

---
 src/lib/Bcfg2/Reporting/Collector.py | 3 +++
 1 file changed, 3 insertions(+)

(limited to 'src/lib/Bcfg2/Reporting')

diff --git a/src/lib/Bcfg2/Reporting/Collector.py b/src/lib/Bcfg2/Reporting/Collector.py
index 68e1d6a6d..f348a60dc 100644
--- a/src/lib/Bcfg2/Reporting/Collector.py
+++ b/src/lib/Bcfg2/Reporting/Collector.py
@@ -130,6 +130,9 @@ class ReportingCollector(object):
                     continue
 
                 t = ReportingStoreThread(interaction, self.storage)
+                while len(threading.enumerate()) > 100:
+                    self.logger.info("more than 100 threads running, sleeping")
+                    time.sleep(1)
                 t.start()
             except (SystemExit, KeyboardInterrupt):
                 self.logger.info("Shutting down")
-- 
cgit v1.2.3-1-g7c22