diff options
Diffstat (limited to 'lib/puppet/metatype/evaluation.rb')
| -rw-r--r-- | lib/puppet/metatype/evaluation.rb | 163 |
1 files changed, 0 insertions, 163 deletions
diff --git a/lib/puppet/metatype/evaluation.rb b/lib/puppet/metatype/evaluation.rb deleted file mode 100644 index 18bbb812f..000000000 --- a/lib/puppet/metatype/evaluation.rb +++ /dev/null @@ -1,163 +0,0 @@ -class Puppet::Type - # This method is responsible for collecting property changes we always - # descend into the children before we evaluate our current properties. - # This returns any changes resulting from testing, thus 'collect' rather - # than 'each'. - def evaluate - if self.provider.is_a?(Puppet::Provider) - unless provider.class.suitable? - raise Puppet::Error, "Provider %s is not functional on this platform" % provider.class.name - end - end - #Puppet.err "Evaluating %s" % self.path.join(":") - unless defined? @evalcount - self.err "No evalcount defined on '%s' of type '%s'" % - [self.title,self.class] - @evalcount = 0 - end - @evalcount += 1 - - if p = self.provider and p.respond_to?(:prefetch) - p.prefetch - end - - # this only operates on properties, not properties + children - # it's important that we call retrieve() on the type instance, - # not directly on the property, because it allows the type to override - # the method, like pfile does - currentvalues = self.retrieve - - changes = propertychanges(currentvalues).flatten - - # now record how many changes we've resulted in - if changes.length > 0 - self.debug "%s change(s)" % - [changes.length] - end - - # If we're in noop mode, we don't want to store the checked time, - # because it will result in the resource not getting scheduled if - # someone were to apply the catalog in non-noop mode. - # We're going to go ahead and record that we checked if there were - # no changes, since it's unlikely it will affect the scheduling. - noop = noop? - if ! noop or (noop && changes.length == 0) - self.cache(:checked, Time.now) - end - return changes.flatten - end - - # Flush the provider, if it supports it. This is called by the - # transaction. - def flush - if self.provider and self.provider.respond_to?(:flush) - self.provider.flush - end - end - - # if all contained objects are in sync, then we're in sync - # FIXME I don't think this is used on the type instances any more, - # it's really only used for testing - def insync?(is) - insync = true - - if property = @parameters[:ensure] - unless is.include? property - raise Puppet::DevError, - "The is value is not in the is array for '%s'" % - [property.name] - end - ensureis = is[property] - if property.insync?(ensureis) and property.should == :absent - return true - end - end - - properties.each { |property| - unless is.include? property - raise Puppet::DevError, - "The is value is not in the is array for '%s'" % - [property.name] - end - - propis = is[property] - unless property.insync?(propis) - property.debug("Not in sync: %s vs %s" % - [propis.inspect, property.should.inspect]) - insync = false - #else - # property.debug("In sync") - end - } - - #self.debug("%s sync status is %s" % [self,insync]) - return insync - end - - # retrieve the current value of all contained properties - def retrieve - return currentpropvalues - end - - # get a hash of the current properties. - def currentpropvalues(override_value = nil) - # it's important to use the method here, as it follows the order - # in which they're defined in the object - return properties().inject({}) { | prophash, property| - prophash[property] = override_value.nil? ? - property.retrieve : - override_value - prophash - } - end - - # Are we running in noop mode? - def noop? - if defined?(@noop) - @noop - else - Puppet[:noop] - end - end - - def noop - noop? - end - - # Retrieve the changes associated with all of the properties. - def propertychanges(currentvalues) - # If we are changing the existence of the object, then none of - # the other properties matter. - changes = [] - ensureparam = @parameters[:ensure] - - # This allows resource types to have 'ensure' be a parameter, which allows them to - # just pass the parameter on to other generated resources. - ensureparam = nil unless ensureparam.is_a?(Puppet::Property) - if ensureparam && !currentvalues.include?(ensureparam) - raise Puppet::DevError, "Parameter ensure defined but missing from current values" - end - - if ensureparam and ! ensureparam.insync?(currentvalues[ensureparam]) - changes << Puppet::Transaction::Change.new(ensureparam, currentvalues[ensureparam]) - # Else, if the 'ensure' property is correctly absent, then do - # nothing - elsif ensureparam and currentvalues[ensureparam] == :absent - return [] - else - changes = properties().find_all { |property| - currentvalues[property] ||= :absent - ! property.insync?(currentvalues[property]) - }.collect { |property| - Puppet::Transaction::Change.new(property, currentvalues[property]) - } - end - - if Puppet[:debug] and changes.length > 0 - self.debug("Changing " + changes.collect { |ch| ch.property.name }.join(",")) - end - - changes - end -end - |