class Chef::Provider::Route

Constants

MASK

Attributes

is_running[RW]

Public Instance Methods

action_add() click to toggle source
# File lib/chef/provider/route.rb, line 129
def action_add
  # check to see if load_current_resource found the route
  if is_running
    Chef::Log.debug("#{@new_resource} route already active - nothing to do")
  else
    command = generate_command(:add)
    converge_by ("run #{ command } to add route") do
      run_command( :command => command )
      Chef::Log.info("#{@new_resource} added")
    end
  end

  #for now we always write the file (ugly but its what it is)
  generate_config
end
action_delete() click to toggle source
# File lib/chef/provider/route.rb, line 145
def action_delete
  if is_running
    command = generate_command(:delete)
    converge_by ("run #{ command } to delete route ") do
      run_command( :command => command )
      Chef::Log.info("#{@new_resource} removed")
    end
  else
    Chef::Log.debug("#{@new_resource} route does not exist - nothing to do")
  end

  #for now we always write the file (ugly but its what it is)
  generate_config
end
config_file_contents(action, options={}) click to toggle source
# File lib/chef/provider/route.rb, line 215
def config_file_contents(action, options={})
  content = ''
  case action
  when :add
    content << "#{options[:target]}"
    content << "/#{options[:netmask]}" if options[:netmask]
    content << " via #{options[:gateway]}" if options[:gateway]
    content << "\n"
  end

  return content
end
generate_command(action) click to toggle source
# File lib/chef/provider/route.rb, line 197
def generate_command(action)
  common_route_items = ''
  common_route_items << "/#{MASK[@new_resource.netmask.to_s]}" if @new_resource.netmask
  common_route_items << " via #{@new_resource.gateway} " if @new_resource.gateway

  case action
  when :add
    command = "ip route replace #{@new_resource.target}"
    command << common_route_items
    command << " dev #{@new_resource.device} " if @new_resource.device
  when :delete
    command = "ip route delete #{@new_resource.target}"
    command << common_route_items
  end

  return command
end
generate_config() click to toggle source
# File lib/chef/provider/route.rb, line 160
def generate_config
  conf = Hash.new
  case node[:platform]
  when "centos", "redhat", "fedora"
    # walk the collection
    run_context.resource_collection.each do |resource|
      if resource.is_a? Chef::Resource::Route
        # default to eth0
        if resource.device
          dev = resource.device
        else
          dev = "eth0"
        end

        conf[dev] = String.new if conf[dev].nil?
        case @action
        when :add
          conf[dev] << config_file_contents(:add, :target => resource.target, :netmask => resource.netmask, :gateway => resource.gateway)
        when :delete
          # need to do this for the case when the last route on an int
          # is removed
          conf[dev] << config_file_contents(:delete)
        end
      end
    end
    conf.each do |k, v|
      network_file_name = "/etc/sysconfig/network-scripts/route-#{k}"
      converge_by ("write route route.#{k}\n#{conf[k]} to #{ network_file_name }") do
        network_file = ::File.new(network_file_name, "w")
        network_file.puts(conf[k])
        Chef::Log.debug("#{@new_resource} writing route.#{k}\n#{conf[k]}")
        network_file.close
      end
    end
  end
end
hex2ip(hex_data) click to toggle source
# File lib/chef/provider/route.rb, line 63
def hex2ip(hex_data)
  # Cleanup hex data
  hex_ip = hex_data.to_s.downcase.gsub(/[^0-9a-f]/, '')

  # Check hex data format (IP is a 32bit integer, so should be 8 chars long)
  return nil if hex_ip.length != hex_data.length || hex_ip.length != 8

  # Extract octets from hex data
  octets = hex_ip.scan(/../).reverse.collect { |octet| [octet].pack('H2').unpack("C").first }

  # Validate IP
  ip = octets.join('.')
  begin
    IPAddr.new(ip, Socket::AF_INET).to_s
  rescue ArgumentError
    Chef::Log.debug("Invalid IP address data: hex=#{hex_ip}, ip=#{ip}")
    return nil
  end
end
load_current_resource() click to toggle source
# File lib/chef/provider/route.rb, line 87
def load_current_resource
  self.is_running = false

  # cidr or quad dot mask
  if @new_resource.netmask
    new_ip = IPAddr.new("#{@new_resource.target}/#{@new_resource.netmask}")
  else
    new_ip = IPAddr.new(@new_resource.target)
  end

  # For linux, we use /proc/net/route file to read proc table info
  if node[:os] == "linux"
    route_file = ::File.open("/proc/net/route", "r")

    # Read all routes
    while (line = route_file.gets)
      # Get all the fields for a route
      iface,destination,gateway,flags,refcnt,use,metric,mask,mtu,window,irtt = line.split

      # Convert hex-encoded values to quad-dotted notation (e.g. 0064A8C0 => 192.168.100.0)
      destination = hex2ip(destination)
      gateway = hex2ip(gateway)
      mask = hex2ip(mask)

      # Skip formatting lines (header, etc)
      next unless destination && gateway && mask
      Chef::Log.debug("#{@new_resource} system has route: dest=#{destination} mask=#{mask} gw=#{gateway}")

      # check if what were trying to configure is already there
      # use an ipaddr object with ip/mask this way we can have
      # a new resource be in cidr format (i don't feel like
      # expanding bitmask by hand.
      #
      running_ip = IPAddr.new("#{destination}/#{mask}")
      Chef::Log.debug("#{@new_resource} new ip: #{new_ip.inspect} running ip: #{running_ip.inspect}")
      self.is_running = true if running_ip == new_ip && gateway == @new_resource.gateway
    end

    route_file.close
  end
end
whyrun_supported?() click to toggle source
# File lib/chef/provider/route.rb, line 83
def whyrun_supported?
  true
end