Accepting the patch from #190.

git-svn-id: https://reductivelabs.com/svn/puppet/trunk@1368 980ebf18-57e1-0310-9a29-db15c13687c0

1 files changed, 26 insertions, 7 deletions

diff --git a/lib/puppet/client/master.rb b/lib/puppet/client/master.rb
index 0a3419ea4..1c4c57c9c 100644
--- a/lib/puppet/client/master.rb
+++ b/lib/puppet/client/master.rb
@@ -352,15 +352,19 @@ class Puppet::Client::MasterClient < Puppet::Client
     end
 
     def locked?
+        return(FileTest.exists? Puppet[:puppetdlockfile])
+    end
+
+    def lockpid
         if FileTest.exists? Puppet[:puppetdlockfile]
             text = File.read(Puppet[:puppetdlockfile]).chomp
             if text =~ /\d+/
-                return text
+                return text.to_i
             else
-                return true
+                return 0
             end
         else
-            return false
+            return 0
         end
     end
 
@@ -392,11 +396,26 @@ class Puppet::Client::MasterClient < Puppet::Client
 
     # The code that actually runs the configuration.  
     def run(tags = nil, ignoreschedules = false)
-        if pid = locked?
-            t = ""
-            if pid != true
-                Puppet.notice "Locked by process %s" % pid
+        # Check if the lock is stale, so we can clear it
+        if locked?
+            pid = lockpid
+
+            if pid != 0
+                begin
+                    Process.kill(0, pid)
+                rescue Errno::ESRCH
+                    # No process with the given PID exists; stale lockfile
+                    File.unlink(Puppet[:puppetdlockfile])
+                    Puppet.notice("Stale lockfile %s left by process %i; removing" %
+                        [Puppet[:puppetdlockfile], pid])
+                    lockpid = false
+                else
+                    Puppet.notice "Locked by process %s" % pid
+                end
             end
+        end
+
+        if locked?
             Puppet.notice "Lock file %s exists; skipping configuration run" %
                 Puppet[:puppetdlockfile]
         else