Contents

# This is used by rbbt-rest when issuing a new job

$rest_cache_semaphore = ENV["RBBT_REST_CACHE_SEMAPHORE"] || "/REST_SEMAPHORE"
parallel_rest_jobs = Rbbt::Config.get('parallel_rest_jobs', :parallel_rest_jobs, :rest_jobs, :default => 2)

parallel_rest_jobs = parallel_rest_jobs.to_i if String === parallel_rest_jobs

begin
  RbbtSemaphore.delete_semaphore($rest_cache_semaphore)
ensure
  RbbtSemaphore.create_semaphore($rest_cache_semaphore, parallel_rest_jobs)
end
Log.debug("Created semaphore: #{$rest_cache_semaphore} with #{parallel_rest_jobs} size")

Version data entries

186 entries across 186 versions & 1 rubygems

Version	Path
rbbt-util-5.44.1	etc/app.d/semaphores.rb
rbbt-util-5.43.0	etc/app.d/semaphores.rb
rbbt-util-5.42.0	etc/app.d/semaphores.rb
rbbt-util-5.41.1	etc/app.d/semaphores.rb
rbbt-util-5.41.0	etc/app.d/semaphores.rb
rbbt-util-5.40.5	etc/app.d/semaphores.rb
rbbt-util-5.40.4	etc/app.d/semaphores.rb
rbbt-util-5.40.3	etc/app.d/semaphores.rb
rbbt-util-5.40.0	etc/app.d/semaphores.rb
rbbt-util-5.39.0	etc/app.d/semaphores.rb
rbbt-util-5.38.1	etc/app.d/semaphores.rb
rbbt-util-5.38.0	etc/app.d/semaphores.rb
rbbt-util-5.37.16	etc/app.d/semaphores.rb
rbbt-util-5.37.15	etc/app.d/semaphores.rb
rbbt-util-5.37.14	etc/app.d/semaphores.rb
rbbt-util-5.37.13	etc/app.d/semaphores.rb
rbbt-util-5.37.12	etc/app.d/semaphores.rb
rbbt-util-5.37.11	etc/app.d/semaphores.rb
rbbt-util-5.37.10	etc/app.d/semaphores.rb
rbbt-util-5.37.9	etc/app.d/semaphores.rb