diff options
| author | Alexander Sulfrian <alexander@sulfrian.net> | 2014-11-11 22:33:09 +0100 |
|---|---|---|
| committer | Alexander Sulfrian <alexander@sulfrian.net> | 2014-11-11 22:33:09 +0100 |
| commit | dfd62263c3f683f3afa6a0f8fdb2f288776a3d25 (patch) | |
| tree | 4208cd45427074999c081459aa7be72540f30885 /src/lib/Bcfg2 | |
| parent | 77cf4a56b3b7ff8cd466705b968abb539efa703f (diff) | |
| download | bcfg2-dfd62263c3f683f3afa6a0f8fdb2f288776a3d25.tar.gz bcfg2-dfd62263c3f683f3afa6a0f8fdb2f288776a3d25.tar.bz2 bcfg2-dfd62263c3f683f3afa6a0f8fdb2f288776a3d25.zip | |
Reporting/Collector: fix semaphore initialization
Diffstat (limited to 'src/lib/Bcfg2')
| -rw-r--r-- | src/lib/Bcfg2/Reporting/Collector.py | 3 |
1 files changed, 2 insertions, 1 deletions
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) |