| 
									
										
										
										
											2013-07-27 23:53:53 -05:00
										 |  |  | require 'fcntl' | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2013-02-09 18:19:50 -06:00
										 |  |  | class FormulaLock | 
					
						
							|  |  |  |   LOCKDIR = HOMEBREW_CACHE_FORMULA | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |   def initialize(name) | 
					
						
							|  |  |  |     @name = name | 
					
						
							|  |  |  |     @path = LOCKDIR.join("#{@name}.brewing") | 
					
						
							| 
									
										
										
										
											2013-04-05 22:06:52 -05:00
										 |  |  |     @lockfile = nil | 
					
						
							| 
									
										
										
										
											2013-02-09 18:19:50 -06:00
										 |  |  |   end | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |   def lock | 
					
						
							|  |  |  |     LOCKDIR.mkpath | 
					
						
							|  |  |  |     @lockfile = get_or_create_lockfile | 
					
						
							|  |  |  |     unless @lockfile.flock(File::LOCK_EX | File::LOCK_NB) | 
					
						
							|  |  |  |       raise OperationInProgressError, @name | 
					
						
							|  |  |  |     end | 
					
						
							|  |  |  |   end | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |   def unlock | 
					
						
							|  |  |  |     unless @lockfile.nil? || @lockfile.closed? | 
					
						
							|  |  |  |       @lockfile.flock(File::LOCK_UN) | 
					
						
							|  |  |  |       @lockfile.close | 
					
						
							|  |  |  |     end | 
					
						
							|  |  |  |   end | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |   def with_lock | 
					
						
							|  |  |  |     lock | 
					
						
							|  |  |  |     yield | 
					
						
							|  |  |  |   ensure | 
					
						
							|  |  |  |     unlock | 
					
						
							|  |  |  |   end | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |   private | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |   def get_or_create_lockfile | 
					
						
							|  |  |  |     if @lockfile.nil? || @lockfile.closed? | 
					
						
							| 
									
										
										
										
											2013-07-27 23:53:53 -05:00
										 |  |  |       @lockfile = @path.open(File::RDWR | File::CREAT) | 
					
						
							|  |  |  |       @lockfile.fcntl(Fcntl::F_SETFD, Fcntl::FD_CLOEXEC) | 
					
						
							|  |  |  |       @lockfile | 
					
						
							| 
									
										
										
										
											2013-02-09 18:19:50 -06:00
										 |  |  |     else | 
					
						
							|  |  |  |       @lockfile | 
					
						
							|  |  |  |     end | 
					
						
							|  |  |  |   end | 
					
						
							|  |  |  | end |