Ensure not to have a semaphore larger than 1
This commit is contained in:
@ -49,8 +49,12 @@ class DockerContainerPool
|
|||||||
|
|
||||||
def self.release_semaphore
|
def self.release_semaphore
|
||||||
Rails.logger.info("Semaphore - Release: Trying " + @semaphore.inspect.to_s + " for " + caller_locations(1, 1)[0].label)
|
Rails.logger.info("Semaphore - Release: Trying " + @semaphore.inspect.to_s + " for " + caller_locations(1, 1)[0].label)
|
||||||
@semaphore.release
|
if @semaphore.available_permits < 1
|
||||||
Rails.logger.info("Semaphore - Release: Done " + @semaphore.inspect.to_s + " for " + caller_locations(1, 1)[0].label)
|
@semaphore.release
|
||||||
|
Rails.logger.info("Semaphore - Release: Done " + @semaphore.inspect.to_s + " for " + caller_locations(1, 1)[0].label)
|
||||||
|
else
|
||||||
|
Rails.logger.info("Semaphore - Release: Failed " + @semaphore.inspect.to_s + " for " + caller_locations(1, 1)[0].label)
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def self.remove_from_all_containers(container, execution_environment, bypass_semaphore: false)
|
def self.remove_from_all_containers(container, execution_environment, bypass_semaphore: false)
|
||||||
|
Reference in New Issue
Block a user