diff options
Diffstat (limited to 'lib/puppet/provider/service/daemontools.rb')
| -rw-r--r-- | lib/puppet/provider/service/daemontools.rb | 314 |
1 files changed, 157 insertions, 157 deletions
diff --git a/lib/puppet/provider/service/daemontools.rb b/lib/puppet/provider/service/daemontools.rb index 7a584a1f9..65abf7728 100644 --- a/lib/puppet/provider/service/daemontools.rb +++ b/lib/puppet/provider/service/daemontools.rb @@ -2,193 +2,193 @@ # # author Brice Figureau <brice-puppet@daysofwonder.com> Puppet::Type.type(:service).provide :daemontools, :parent => :base do - desc "Daemontools service management. + desc "Daemontools service management. - This provider manages daemons running supervised by D.J.Bernstein daemontools. - It tries to detect the service directory, with by order of preference: + This provider manages daemons running supervised by D.J.Bernstein daemontools. + It tries to detect the service directory, with by order of preference: - * /service - * /etc/service - * /var/lib/svscan + * /service + * /etc/service + * /var/lib/svscan - The daemon directory should be placed in a directory that can be - by default in: + The daemon directory should be placed in a directory that can be + by default in: - * /var/lib/service - * /etc + * /var/lib/service + * /etc - or this can be overriden in the service resource parameters:: + or this can be overriden in the service resource parameters:: - service { - \"myservice\": - provider => \"daemontools\", path => \"/path/to/daemons\"; - } + service { + \"myservice\": + provider => \"daemontools\", path => \"/path/to/daemons\"; + } - This provider supports out of the box: + This provider supports out of the box: - * start/stop (mapped to enable/disable) - * enable/disable - * restart - * status + * start/stop (mapped to enable/disable) + * enable/disable + * restart + * status - If a service has ensure => \"running\", it will link /path/to/daemon to - /path/to/service, which will automatically enable the service. + If a service has ensure => \"running\", it will link /path/to/daemon to + /path/to/service, which will automatically enable the service. - If a service has ensure => \"stopped\", it will only down the service, not - remove the /path/to/service link. + If a service has ensure => \"stopped\", it will only down the service, not + remove the /path/to/service link. - " + " - commands :svc => "/usr/bin/svc", :svstat => "/usr/bin/svstat" + commands :svc => "/usr/bin/svc", :svstat => "/usr/bin/svstat" - class << self - attr_writer :defpath + class << self + attr_writer :defpath - # Determine the daemon path. - def defpath(dummy_argument=:work_arround_for_ruby_GC_bug) - unless @defpath - ["/var/lib/service", "/etc"].each do |path| - if FileTest.exist?(path) - @defpath = path - break - end - end - raise "Could not find the daemon directory (tested [/var/lib/service,/etc])" unless @defpath - end - @defpath + # Determine the daemon path. + def defpath(dummy_argument=:work_arround_for_ruby_GC_bug) + unless @defpath + ["/var/lib/service", "/etc"].each do |path| + if FileTest.exist?(path) + @defpath = path + break + end end + raise "Could not find the daemon directory (tested [/var/lib/service,/etc])" unless @defpath + end + @defpath end + end - attr_writer :servicedir + attr_writer :servicedir - # returns all providers for all existing services in @defpath - # ie enabled or not - def self.instances - path = self.defpath - unless FileTest.directory?(path) - Puppet.notice "Service path #{path} does not exist" - next - end - - # reject entries that aren't either a directory - # or don't contain a run file - Dir.entries(path).reject { |e| - fullpath = File.join(path, e) - e =~ /^\./ or ! FileTest.directory?(fullpath) or ! FileTest.exist?(File.join(fullpath,"run")) - }.collect do |name| - new(:name => name, :path => path) - end + # returns all providers for all existing services in @defpath + # ie enabled or not + def self.instances + path = self.defpath + unless FileTest.directory?(path) + Puppet.notice "Service path #{path} does not exist" + next end - # returns the daemon dir on this node - def self.daemondir - self.defpath + # reject entries that aren't either a directory + # or don't contain a run file + Dir.entries(path).reject { |e| + fullpath = File.join(path, e) + e =~ /^\./ or ! FileTest.directory?(fullpath) or ! FileTest.exist?(File.join(fullpath,"run")) + }.collect do |name| + new(:name => name, :path => path) end - - # find the service dir on this node - def servicedir - unless @servicedir - ["/service", "/etc/service","/var/lib/svscan"].each do |path| - if FileTest.exist?(path) - @servicedir = path - break - end - end - raise "Could not find service directory" unless @servicedir + end + + # returns the daemon dir on this node + def self.daemondir + self.defpath + end + + # find the service dir on this node + def servicedir + unless @servicedir + ["/service", "/etc/service","/var/lib/svscan"].each do |path| + if FileTest.exist?(path) + @servicedir = path + break end - @servicedir + end + raise "Could not find service directory" unless @servicedir end - - # returns the full path of this service when enabled - # (ie in the service directory) - def service - File.join(self.servicedir, resource[:name]) + @servicedir + end + + # returns the full path of this service when enabled + # (ie in the service directory) + def service + File.join(self.servicedir, resource[:name]) + end + + # returns the full path to the current daemon directory + # note that this path can be overriden in the resource + # definition + def daemon + File.join(resource[:path], resource[:name]) + end + + def status + begin + output = svstat self.service + if output =~ /:\s+up \(/ + return :running + end + rescue Puppet::ExecutionFailure => detail + raise Puppet::Error.new( "Could not get status for service #{resource.ref}: #{detail}" ) end - - # returns the full path to the current daemon directory - # note that this path can be overriden in the resource - # definition - def daemon - File.join(resource[:path], resource[:name]) + :stopped + end + + def setupservice + if resource[:manifest] + Puppet.notice "Configuring #{resource[:name]}" + command = [ resource[:manifest], resource[:name] ] + #texecute("setupservice", command) + rv = system("#{command}") + end + rescue Puppet::ExecutionFailure => detail + raise Puppet::Error.new( "Cannot config #{self.service} to enable it: #{detail}" ) + end + + def enabled? + case self.status + when :running + # obviously if the daemon is running then it is enabled + return :true + else + # the service is enabled if it is linked + return FileTest.symlink?(self.service) ? :true : :false end - - def status - begin - output = svstat self.service - if output =~ /:\s+up \(/ - return :running - end - rescue Puppet::ExecutionFailure => detail - raise Puppet::Error.new( "Could not get status for service #{resource.ref}: #{detail}" ) + end + + def enable + if ! FileTest.directory?(self.daemon) + Puppet.notice "No daemon dir, calling setupservice for #{resource[:name]}" + self.setupservice + end + if self.daemon + if ! FileTest.symlink?(self.service) + Puppet.notice "Enabling #{self.service}: linking #{self.daemon} -> #{self.service}" + File.symlink(self.daemon, self.service) end - :stopped - end - - def setupservice - if resource[:manifest] - Puppet.notice "Configuring #{resource[:name]}" - command = [ resource[:manifest], resource[:name] ] - #texecute("setupservice", command) - rv = system("#{command}") - end - rescue Puppet::ExecutionFailure => detail - raise Puppet::Error.new( "Cannot config #{self.service} to enable it: #{detail}" ) - end - - def enabled? - case self.status - when :running - # obviously if the daemon is running then it is enabled - return :true - else - # the service is enabled if it is linked - return FileTest.symlink?(self.service) ? :true : :false + end + rescue Puppet::ExecutionFailure => detail + raise Puppet::Error.new( "No daemon directory found for #{self.service}") + end + + def disable + begin + if ! FileTest.directory?(self.daemon) + Puppet.notice "No daemon dir, calling setupservice for #{resource[:name]}" + self.setupservice + end + if self.daemon + if FileTest.symlink?(self.service) + Puppet.notice "Disabling #{self.service}: removing link #{self.daemon} -> #{self.service}" + File.unlink(self.service) end - end - - def enable - if ! FileTest.directory?(self.daemon) - Puppet.notice "No daemon dir, calling setupservice for #{resource[:name]}" - self.setupservice - end - if self.daemon - if ! FileTest.symlink?(self.service) - Puppet.notice "Enabling #{self.service}: linking #{self.daemon} -> #{self.service}" - File.symlink(self.daemon, self.service) - end - end + end rescue Puppet::ExecutionFailure => detail - raise Puppet::Error.new( "No daemon directory found for #{self.service}") - end - - def disable - begin - if ! FileTest.directory?(self.daemon) - Puppet.notice "No daemon dir, calling setupservice for #{resource[:name]}" - self.setupservice - end - if self.daemon - if FileTest.symlink?(self.service) - Puppet.notice "Disabling #{self.service}: removing link #{self.daemon} -> #{self.service}" - File.unlink(self.service) - end - end - rescue Puppet::ExecutionFailure => detail - raise Puppet::Error.new( "No daemon directory found for #{self.service}") - end - self.stop + raise Puppet::Error.new( "No daemon directory found for #{self.service}") end + self.stop + end - def restart - svc "-t", self.service - end + def restart + svc "-t", self.service + end - def start - enable unless enabled? == :true - svc "-u", self.service - end + def start + enable unless enabled? == :true + svc "-u", self.service + end - def stop - svc "-d", self.service - end + def stop + svc "-d", self.service + end end |