| 
									
										
										
										
											2015-08-03 13:09:07 +01:00
										 |  |  | require "fcntl" | 
					
						
							| 
									
										
										
										
											2013-07-27 23:53:53 -05:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2013-02-09 18:19:50 -06:00
										 |  |  | class FormulaLock | 
					
						
							|  |  |  |   def initialize(name) | 
					
						
							|  |  |  |     @name = name | 
					
						
							| 
									
										
										
										
											2016-09-15 18:28:42 +01:00
										 |  |  |     @path = HOMEBREW_LOCK_DIR/"#{@name}.brewing" | 
					
						
							| 
									
										
										
										
											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) | 
					
						
							|  |  |  |     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? | 
					
						
							|  |  |  |     @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? | 
					
						
							|  |  |  |     @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 |