From dfd62263c3f683f3afa6a0f8fdb2f288776a3d25 Mon Sep 17 00:00:00 2001 From: Alexander Sulfrian Date: Tue, 11 Nov 2014 22:33:09 +0100 Subject: Reporting/Collector: fix semaphore initialization --- src/lib/Bcfg2/Reporting/Collector.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'src/lib/Bcfg2') diff --git a/src/lib/Bcfg2/Reporting/Collector.py b/src/lib/Bcfg2/Reporting/Collector.py index 88e8f68eb..e29bd5a99 100644 --- a/src/lib/Bcfg2/Reporting/Collector.py +++ b/src/lib/Bcfg2/Reporting/Collector.py @@ -78,6 +78,7 @@ class ReportingCollector(object): self.children = [] self.cleanup_threshold = 25 + self.semaphore = None if Bcfg2.Options.setup.children > 0: self.semaphore = threading.Semaphore( value=Bcfg2.Options.setup.children) @@ -156,7 +157,7 @@ class ReportingCollector(object): interaction = self.transport.fetch() if not interaction: continue - if Bcfg2.Options.setup.children > 0: + if self.semaphore: self.semaphore.acquire() store_thread = ReportingStoreThread(interaction, self.storage, semaphore=self.semaphore) -- cgit v1.2.3-1-g7c22