| 
									
										
										
										
											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 |