diff options
| -rw-r--r-- | src/lib/Bcfg2/Reporting/Collector.py | 3 |
1 files changed, 3 insertions, 0 deletions
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") |