summaryrefslogtreecommitdiff
path: root/lib/gitlab/exclusive_lease.rb
diff options
context:
space:
mode:
authorJacob Vosmaer <contact@jacobvosmaer.nl>2016-03-10 12:37:14 +0100
committerJacob Vosmaer <contact@jacobvosmaer.nl>2016-03-10 12:37:14 +0100
commite7df3f51c9cc246279da36c9488b4c591f30b866 (patch)
tree123e38968f0ac6bf17899a62ef9411d17f130d0b /lib/gitlab/exclusive_lease.rb
parent0223b58f019fc3ce906c97caf8c6e361fa4302be (diff)
downloadgitlab-ce-e7df3f51c9cc246279da36c9488b4c591f30b866.tar.gz
Move method to User
Diffstat (limited to 'lib/gitlab/exclusive_lease.rb')
-rw-r--r--lib/gitlab/exclusive_lease.rb13
1 files changed, 12 insertions, 1 deletions
diff --git a/lib/gitlab/exclusive_lease.rb b/lib/gitlab/exclusive_lease.rb
index f801e8b60b3..0ed4c357926 100644
--- a/lib/gitlab/exclusive_lease.rb
+++ b/lib/gitlab/exclusive_lease.rb
@@ -8,14 +8,25 @@ module Gitlab
# servers. It is a 'cheap' alternative to using SQL queries and updates:
# you do not need to change the SQL schema to start using
# ExclusiveLease.
+ #
+ # It is important to choose the timeout wisely. If the timeout is very
+ # high (1 hour) then the throughput of your operation gets very low (at
+ # most once an hour). If the timeout is lower than how long your
+ # operation may take then you cannot count on exclusivity. For example,
+ # if the timeout is 10 seconds and you do an operation which may take 20
+ # seconds then two overlapping operations may hold a lease at the
+ # same time.
+ #
class ExclusiveLease
- def initialize(key, timeout)
+ def initialize(key, timeout:)
@key, @timeout = key, timeout
end
# Try to obtain the lease. Return true on succes,
# false if the lease is already taken.
def try_obtain
+ # This is expected to be atomic because we are talking to a
+ # single-threaded Redis server.
!!redis.set(redis_key, redis_value, nx: true, ex: @timeout)
end