2020-10-10 14:16:11 +02:00
|
|
|
# typed: true
|
2019-04-19 15:38:03 +09:00
|
|
|
# frozen_string_literal: true
|
|
|
|
|
2015-08-03 13:09:07 +01:00
|
|
|
require "fcntl"
|
2013-07-27 23:53:53 -05:00
|
|
|
|
2020-08-09 03:16:22 +02:00
|
|
|
# A lock file.
|
|
|
|
#
|
|
|
|
# @api private
|
2017-05-22 03:23:50 +02:00
|
|
|
class LockFile
|
2018-08-09 16:46:39 +02:00
|
|
|
attr_reader :path
|
|
|
|
|
2013-02-09 18:19:50 -06:00
|
|
|
def initialize(name)
|
2017-05-22 04:15:11 +02:00
|
|
|
@name = name.to_s
|
2018-09-06 18:38:43 +01:00
|
|
|
@path = HOMEBREW_LOCKS/"#{@name}.lock"
|
2013-04-05 22:06:52 -05:00
|
|
|
@lockfile = nil
|
2013-02-09 18:19:50 -06:00
|
|
|
end
|
|
|
|
|
|
|
|
def lock
|
2016-09-24 17:59:14 +02:00
|
|
|
@path.parent.mkpath
|
|
|
|
create_lockfile
|
2016-09-23 22:02:23 +02:00
|
|
|
return if @lockfile.flock(File::LOCK_EX | File::LOCK_NB)
|
2018-09-17 02:45:00 +02:00
|
|
|
|
2016-09-23 22:02:23 +02:00
|
|
|
raise OperationInProgressError, @name
|
2013-02-09 18:19:50 -06:00
|
|
|
end
|
|
|
|
|
|
|
|
def unlock
|
2016-09-23 22:02:23 +02:00
|
|
|
return if @lockfile.nil? || @lockfile.closed?
|
2018-09-17 02:45:00 +02:00
|
|
|
|
2016-09-23 22:02:23 +02:00
|
|
|
@lockfile.flock(File::LOCK_UN)
|
|
|
|
@lockfile.close
|
2013-02-09 18:19:50 -06:00
|
|
|
end
|
|
|
|
|
|
|
|
def with_lock
|
|
|
|
lock
|
|
|
|
yield
|
|
|
|
ensure
|
|
|
|
unlock
|
|
|
|
end
|
|
|
|
|
|
|
|
private
|
|
|
|
|
2016-09-24 17:59:14 +02:00
|
|
|
def create_lockfile
|
|
|
|
return unless @lockfile.nil? || @lockfile.closed?
|
2018-09-17 02:45:00 +02:00
|
|
|
|
2016-09-24 17:59:14 +02:00
|
|
|
@lockfile = @path.open(File::RDWR | File::CREAT)
|
|
|
|
@lockfile.fcntl(Fcntl::F_SETFD, Fcntl::FD_CLOEXEC)
|
2013-02-09 18:19:50 -06:00
|
|
|
end
|
|
|
|
end
|
2017-05-22 03:23:50 +02:00
|
|
|
|
2020-08-09 03:16:22 +02:00
|
|
|
# A lock file for a formula.
|
|
|
|
#
|
|
|
|
# @api private
|
2017-05-22 03:23:50 +02:00
|
|
|
class FormulaLock < LockFile
|
|
|
|
def initialize(name)
|
|
|
|
super("#{name}.formula")
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2020-08-09 03:16:22 +02:00
|
|
|
# A lock file for a cask.
|
|
|
|
#
|
|
|
|
# @api private
|
2017-05-22 03:23:50 +02:00
|
|
|
class CaskLock < LockFile
|
|
|
|
def initialize(name)
|
|
|
|
super("#{name}.cask")
|
|
|
|
end
|
|
|
|
end
|