lib/model/endpoint.rb in puppetdb_rundeck-0.3.0 vs lib/model/endpoint.rb in puppetdb_rundeck-0.3.1
- old
+ new
@@ -20,10 +20,10 @@
mutex = Mutex.new
per_type_cache = "/tmp/puppetdb-resource.#{type}"
THREAD_COUNT.times.map {
- Thread.new(nodes, @rundeck_data) do |nodes|
+ Thread.new(nodes) do |nodes|
while node = mutex.synchronize { nodes.pop }
host = node['name']
facts = @db_helper.get_facts(host)
if !facts.nil?
mutex.synchronize { helper.add_facts(facts, host, @rundeck_data) }