lib/sidekiq/limit_fetch/global/semaphore.rb in sidekiq-limit_fetch-3.4.0 vs lib/sidekiq/limit_fetch/global/semaphore.rb in sidekiq-limit_fetch-4.0.0
- old
+ new
@@ -107,9 +107,17 @@
def blocking?
redis {|it| it.get "#{PREFIX}:block:#@name" }
end
+ def clear_limits
+ redis do |it|
+ %w(block busy limit pause probed process_limit).each do |key|
+ it.del "#{PREFIX}:#{key}:#@name"
+ end
+ end
+ end
+
def increase_local_busy
@lock.synchronize { @local_busy += 1 }
end
def decrease_local_busy