Sha256: a7b9ba9276ad3c55097d1e5fb503e65eb6555fc6827f62c17339eb6a83138198
Contents?: true
Size: 1.16 KB
Versions: 26
Compression:
Stored size: 1.16 KB
Contents
module Dynflow
class Action
module Singleton
def self.included(base)
base.middleware.use ::Dynflow::Middleware::Common::Singleton
end
def validate_singleton_lock!
singleton_lock! unless holds_singleton_lock?
end
def singleton_lock!
world.coordinator.acquire(singleton_lock)
rescue Dynflow::Coordinator::LockError
fail "Action #{self.class.name} is already active"
end
def singleton_unlock!
world.coordinator.release(singleton_lock) if holds_singleton_lock?
end
def holds_singleton_lock?
# Get locks for this action, there should be none or one
lock_filter = singleton_lock_class.unique_filter(self.class.name)
present_locks = world.coordinator.find_locks lock_filter
!present_locks.empty? && present_locks.first.owner_id == execution_plan_id
end
def singleton_lock_class
::Dynflow::Coordinator::SingletonActionLock
end
def singleton_lock
singleton_lock_class.new(self.class.name, execution_plan_id)
end
def error!(*args)
singleton_unlock!
super
end
end
end
end
Version data entries
26 entries across 26 versions & 1 rubygems