Class: Chef::Provider::Route
- Inherits:
-
Chef::Provider
- Object
- Chef::Provider
- Chef::Provider::Route
- Defined in:
- lib/chef/provider/route.rb
Constant Summary collapse
- MASK =
{ "0.0.0.0" => "0", "128.0.0.0" => "1", "192.0.0.0" => "2", "224.0.0.0" => "3", "240.0.0.0" => "4", "248.0.0.0" => "5", "252.0.0.0" => "6", "254.0.0.0" => "7", "255.0.0.0" => "8", "255.128.0.0" => "9", "255.192.0.0" => "10", "255.224.0.0" => "11", "255.240.0.0" => "12", "255.248.0.0" => "13", "255.252.0.0" => "14", "255.254.0.0" => "15", "255.255.0.0" => "16", "255.255.128.0" => "17", "255.255.192.0" => "18", "255.255.224.0" => "19", "255.255.240.0" => "20", "255.255.248.0" => "21", "255.255.252.0" => "22", "255.255.254.0" => "23", "255.255.255.0" => "24", "255.255.255.128" => "25", "255.255.255.192" => "26", "255.255.255.224" => "27", "255.255.255.240" => "28", "255.255.255.248" => "29", "255.255.255.252" => "30", "255.255.255.254" => "31", "255.255.255.255" => "32" }.freeze
Instance Attribute Summary collapse
-
#is_running ⇒ Object
Returns the value of attribute is_running.
Attributes inherited from Chef::Provider
#action, #after_resource, #current_resource, #logger, #new_resource, #run_context
Instance Method Summary collapse
- #config_file_contents(action, options = {}) ⇒ Object
- #generate_command(action) ⇒ Object
- #generate_config ⇒ Object
- #hex2ip(hex_data) ⇒ Object
- #load_current_resource ⇒ Object
Methods inherited from Chef::Provider
action, action_description, action_descriptions, #action_nothing, #check_resource_semantics!, #cleanup_after_converge, #compile_and_converge_action, #converge_by, #converge_if_changed, #cookbook_name, #define_resource_requirements, #description, #events, include_resource_dsl?, include_resource_dsl_module, #initialize, #introduced, #load_after_resource, #node, #process_resource_requirements, provides, provides?, #recipe_name, #requirements, #resource_collection, #resource_updated?, #run_action, #set_updated_status, supports?, use, use_inline_resources, #validate_required_properties!, #whyrun_mode?, #whyrun_supported?
Methods included from Mixin::Provides
#provided_as, #provides, #provides?
Methods included from Mixin::DescendantsTracker
#descendants, descendants, direct_descendants, #direct_descendants, find_descendants_by_name, #find_descendants_by_name, #inherited, store_inherited
Methods included from Mixin::LazyModuleInclude
#descendants, #include, #included
Methods included from Mixin::PowershellOut
#powershell_out, #powershell_out!
Methods included from Mixin::WindowsArchitectureHelper
#assert_valid_windows_architecture!, #disable_wow64_file_redirection, #forced_32bit_override_required?, #is_i386_process_on_x86_64_windows?, #node_supports_windows_architecture?, #node_windows_architecture, #restore_wow64_file_redirection, #valid_windows_architecture?, #with_os_architecture, #wow64_architecture_override_required?, #wow64_directory
Methods included from DSL::Secret
#default_secret_config, #default_secret_service, #secret, #with_secret_config, #with_secret_service
Methods included from DSL::RenderHelpers
#render_json, #render_toml, #render_yaml
Methods included from DSL::ReaderHelpers
#parse_file, #parse_json, #parse_toml, #parse_yaml
Methods included from DSL::Powershell
Methods included from DSL::RegistryHelper
#registry_data_exists?, #registry_get_subkeys, #registry_get_values, #registry_has_subkeys?, #registry_key_exists?, #registry_value_exists?
Methods included from DSL::ChefVault
#chef_vault, #chef_vault_item, #chef_vault_item_for_environment
Methods included from DSL::DataQuery
#data_bag, #data_bag_item, #search, #tagged?
Methods included from EncryptedDataBagItem::CheckEncrypted
Methods included from DSL::PlatformIntrospection
#older_than_win_2012_or_8?, #platform?, #platform_family?, #value_for_platform, #value_for_platform_family
Methods included from DSL::Recipe
#exec, #have_resource_class_for?, #resource_class_for
Methods included from DSL::Definitions
add_definition, #evaluate_resource_definition, #has_resource_definition?
Methods included from DSL::Resources
add_resource_dsl, remove_resource_dsl
Methods included from DSL::Cheffish
Methods included from DSL::RebootPending
Methods included from DSL::IncludeRecipe
Methods included from Mixin::NotifyingBlock
#notifying_block, #subcontext_block
Methods included from DSL::DeclareResource
#build_resource, #declare_resource, #delete_resource, #delete_resource!, #edit_resource, #edit_resource!, #find_resource, #find_resource!, #resources, #with_run_context
Methods included from DSL::Compliance
#include_input, #include_profile, #include_waiver
Constructor Details
This class inherits a constructor from Chef::Provider
Instance Attribute Details
#is_running ⇒ Object
Returns the value of attribute is_running.
30 31 32 |
# File 'lib/chef/provider/route.rb', line 30 def is_running @is_running end |
Instance Method Details
#config_file_contents(action, options = {}) ⇒ Object
231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 |
# File 'lib/chef/provider/route.rb', line 231 def config_file_contents(action, = {}) content = "" case action when :add content << "# #{[:comment]}\n" if [:comment] content << ([:target]).to_s content << "/#{MASK[[:netmask].to_s]}" if [:netmask] content << " via #{[:gateway]}" if [:gateway] content << " dev #{[:device]}" if [:device] content << " metric #{[:metric]}" if [:metric] content << "\n" end content end |
#generate_command(action) ⇒ Object
213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 |
# File 'lib/chef/provider/route.rb', line 213 def generate_command(action) target = new_resource.target target = "#{target}/#{MASK[new_resource.netmask.to_s]}" if new_resource.netmask case action when :add command = [ "ip", "route", "replace", target ] command += [ "via", new_resource.gateway ] if new_resource.gateway command += [ "dev", new_resource.device ] if new_resource.device command += [ "metric", new_resource.metric ] if new_resource.metric when :delete command = [ "ip", "route", "delete", target ] command += [ "via", new_resource.gateway ] if new_resource.gateway end command end |
#generate_config ⇒ Object
162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 |
# File 'lib/chef/provider/route.rb', line 162 def generate_config if platform_family?("rhel", "amazon", "fedora") conf = {} # FIXME FIXME FIXME FIXME: whatever this walking-the-run-context API is, it needs to be removed. # walk the collection rc = run_context.parent_run_context || run_context rc.resource_collection.each do |resource| next unless resource.is_a? Chef::Resource::Route # default to eth0 dev = resource.device || "eth0" conf[dev] = "" if conf[dev].nil? case @action when :add conf[dev] << config_file_contents(:add, comment: resource.comment, device: resource.device, target: resource.target, metric: resource.metric, netmask: resource.netmask, gateway: resource.gateway) if resource.action == [:add] 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 conf.each_key do |k| if new_resource.target == "default" network_file_name = "/etc/sysconfig/network" converge_by("write route default route to #{network_file_name}") do logger.trace("#{new_resource} writing default route #{new_resource.gateway} to #{network_file_name}") if ::File.exist?(network_file_name) network_file = ::Chef::Util::FileEdit.new(network_file_name) network_file.search_file_replace_line(/^GATEWAY=/, "GATEWAY=#{new_resource.gateway}") network_file.insert_line_if_no_match(/^GATEWAY=/, "GATEWAY=#{new_resource.gateway}") network_file.write_file else network_file = ::File.new(network_file_name, "w") network_file.puts("GATEWAY=#{new_resource.gateway}") network_file.close end end else 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]) logger.trace("#{new_resource} writing route.#{k}\n#{conf[k]}") network_file.close end end end end end |
#hex2ip(hex_data) ⇒ Object
66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 |
# File 'lib/chef/provider/route.rb', line 66 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 logger.trace("Invalid IP address data: hex=#{hex_ip}, ip=#{ip}") nil end end |
#load_current_resource ⇒ Object
86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 |
# File 'lib/chef/provider/route.rb', line 86 def load_current_resource self.is_running = false # cidr or quad dot mask new_ip = if new_resource.target == "default" IPAddr.new(new_resource.gateway) elsif new_resource.netmask IPAddr.new("#{new_resource.target}/#{new_resource.netmask}") else IPAddr.new(new_resource.target) end # For linux, we use /proc/net/route file to read proc table info return unless linux? route_file = ::File.open("/proc/net/route", "r") # Read all routes while (line = route_file.gets) # Get all the fields for a route _, destination, gateway, _, _, _, _, mask = 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 logger.trace("#{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}") logger.trace("#{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 |