Fixing #113. I added support in the transaction for self-refreshing, which just creates a special trigger for resources that have self-refreshing enabled. Logging is a bit different for them, so it is clear why they are refreshing. I still need to verify the remount methods work in the providers.

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

4 files changed, 51 insertions, 4 deletions

diff --git a/lib/puppet/provider/mount.rb b/lib/puppet/provider/mount.rb
index fc3e5acef..bd8693e7d 100644
--- a/lib/puppet/provider/mount.rb
+++ b/lib/puppet/provider/mount.rb
@@ -11,6 +11,16 @@ module Puppet::Provider::Mount
         mountcmd @model[:name]
     end
 
+    def remount
+        info "Remounting"
+        if @model[:remounts] == :true
+            mountcmd "-o", "remount", @model[:name]
+        else
+            unmount()
+            mount()
+        end
+    end
+
     # This only works when the mount point is synced to the fstab.
     def unmount
         umount @model[:name]
diff --git a/lib/puppet/transaction.rb b/lib/puppet/transaction.rb
index e184bf128..f3662ccfe 100644
--- a/lib/puppet/transaction.rb
+++ b/lib/puppet/transaction.rb
@@ -83,6 +83,13 @@ class Transaction
             if resource.respond_to?(:flush)
                 resource.flush
             end
+            
+            # And set a trigger for refreshing this resource if it's a self-refresher
+            if resource.self_refresh?
+                # Create an edge with this resource as both the source and target.  The triggering
+                # method treats these specially for logging.
+                set_trigger(Puppet::Relationship.new(resource, resource, :callback => :refresh, :event => :ALL_EVENTS))
+            end
         end
 
         resourceevents
@@ -567,7 +574,9 @@ class Transaction
         return unless method = edge.callback
         return unless edge.target.respond_to?(method)
         if edge.target.respond_to?(:ref)
-            edge.source.info "Scheduling %s of %s" % [edge.callback, edge.target.ref]
+            unless edge.source == edge.target
+                edge.source.info "Scheduling %s of %s" % [edge.callback, edge.target.ref]
+            end
         end
         @targets[edge.target] << edge
     end
@@ -634,9 +643,14 @@ class Transaction
         end
 
         callbacks.each do |callback, subs|
-            message = "Triggering '%s' from %s dependencies" %
-                [callback, subs.length]
+            if subs.length == 1 and subs[0].source == resource
+                message = "Refreshing self"
+            else
+                message = "Triggering '%s' from %s dependencies" %
+                    [callback, subs.length]
+            end
             resource.notice message
+            
             # At this point, just log failures, don't try to react
             # to them in any way.
             begin
diff --git a/lib/puppet/type.rb b/lib/puppet/type.rb
index fb73e0459..26d2df24a 100644
--- a/lib/puppet/type.rb
+++ b/lib/puppet/type.rb
@@ -337,6 +337,10 @@ class Type < Puppet::Element
     def ref
         "%s[%s]" % [self.class.name.to_s.capitalize, self.title]
     end
+    
+    def self_refresh?
+        self.class.self_refresh
+    end
 
     # Retrieve the title of an object.  If no title was set separately,
     # then use the object's name.
diff --git a/lib/puppet/type/mount.rb b/lib/puppet/type/mount.rb
index d9e894b05..4961e689a 100755
--- a/lib/puppet/type/mount.rb
+++ b/lib/puppet/type/mount.rb
@@ -1,7 +1,8 @@
 require 'puppet/type/parsedtype'
 
 module Puppet
-    newtype(:mount) do
+    # We want the mount to refresh when it changes.
+    newtype(:mount, :self_refresh => true) do
         # Use the normal parent class, because we actually want to
         # call code when sync() is called.
         newstate(:ensure) do
@@ -152,10 +153,28 @@ module Puppet
                 super
             end
         end
+        
+        newparam(:remounts) do
+            desc "Whether the mount can be remounted  ``mount -o remount``.  If this is false,
+                then the filesystem will be unmounted and remounted manually, which is prone to failure."
+            
+            newvalues(:true, :false)
+            defaultto do
+                case Facter.value(:operatingsystem)
+                when "Darwin": false
+                else
+                    true
+                end
+            end
+        end
 
         @doc = "Manages mounted mounts, including putting mount
             information into the mount table. The actual behavior depends 
             on the value of the 'ensure' parameter."
+        
+        def refresh
+            provider.remount
+        end
 
         def value(name)
             name = symbolize(name)