try again, with puppetforge modules, correctly included now

[dsa-puppet.git] / 3rdparty / modules / vswitch / lib / puppet / provider / vs_port / ovs_redhat.rb

diff --git a/3rdparty/modules/vswitch/lib/puppet/provider/vs_port/ovs_redhat.rb b/3rdparty/modules/vswitch/lib/puppet/provider/vs_port/ovs_redhat.rb
new file mode 100644 (file)
index 0000000..41f6445
--- /dev/null
+++ b/3rdparty/modules/vswitch/lib/puppet/provider/vs_port/ovs_redhat.rb
@@ -0,0 +1,162 @@
+require File.expand_path(File.join(File.dirname(__FILE__), '..', '..', '..', 'puppetx', 'redhat', 'ifcfg.rb'))
+
+BASE = '/etc/sysconfig/network-scripts/ifcfg-'
+
+# When not seedling from interface file
+DEFAULT = {
+  'ONBOOT'        => 'yes',
+  'BOOTPROTO'     => 'dhcp',
+  'PEERDNS'       => 'no',
+  'NM_CONTROLLED' => 'no',
+  'NOZEROCONF'    => 'yes' }
+
+Puppet::Type.type(:vs_port).provide(:ovs_redhat, :parent => :ovs) do
+  desc 'Openvswitch port manipulation for RedHat OSes family'
+
+  confine    :osfamily => :redhat
+  defaultfor :osfamily => :redhat
+
+  commands :ip     => 'ip'
+  commands :ifdown => 'ifdown'
+  commands :ifup   => 'ifup'
+  commands :vsctl  => 'ovs-vsctl'
+
+  def create
+    unless vsctl('list-ports',
+      @resource[:bridge]).include? @resource[:interface]
+      super
+    end
+
+    if interface_physical?
+      template = DEFAULT
+      extras   = nil
+
+      if link?
+        extras = dynamic_default if dynamic?
+        if File.exist?(BASE + @resource[:interface])
+          template = cleared(from_str(File.read(BASE + @resource[:interface])))
+        end
+      end
+
+      port = IFCFG::Port.new(@resource[:interface], @resource[:bridge])
+      if vlan?
+        port.set('VLAN' => 'yes')
+      end
+
+      if bonding?
+        port.set('BONDING_MASTER' => 'yes')
+        config = from_str(File.read(BASE + @resource[:interface]))
+        port.set('BONDING_OPTS' => config['BONDING_OPTS']) if config.has_key?('BONDING_OPTS')
+      end
+
+      port.save(BASE + @resource[:interface])
+
+      bridge = IFCFG::Bridge.new(@resource[:bridge], template)
+      bridge.set(extras) if extras
+      bridge.save(BASE + @resource[:bridge])
+
+      ifdown(@resource[:bridge])
+      ifdown(@resource[:interface])
+      ifup(@resource[:interface])
+      ifup(@resource[:bridge])
+    end
+  end
+
+  def exists?
+    if interface_physical?
+      super &&
+      IFCFG::OVS.exists?(@resource[:interface]) &&
+      IFCFG::OVS.exists?(@resource[:bridge])
+    else
+      super
+    end
+  end
+
+  def destroy
+    if interface_physical?
+      ifdown(@resource[:bridge])
+      ifdown(@resource[:interface])
+      IFCFG::OVS.remove(@resource[:interface])
+      IFCFG::OVS.remove(@resource[:bridge])
+    end
+    super
+  end
+
+  private
+
+  def bonding?
+    # To do: replace with iproute2 commands
+    if File.exists?("/proc/net/bonding/#{@resource[:interface]}")
+      return true
+    else
+      return false
+    end
+  rescue Errno::ENOENT
+    return false
+  end
+
+  def dynamic?
+    device = ''
+    device = ip('addr', 'show', @resource[:interface])
+    return device =~ /dynamic/ ? true : false
+  end
+
+  def link?
+    if File.read("/sys/class/net/#{@resource[:interface]}/operstate") =~ /up/
+      return true
+    else
+      return false
+    end
+  rescue Errno::ENOENT
+    return false
+  end
+
+  def dynamic_default
+    list = { 'OVSDHCPINTERFACES' => @resource[:interface] }
+    # Persistent MAC address taken from interface
+    bridge_mac_address = File.read("/sys/class/net/#{@resource[:interface]}/address").chomp
+    if bridge_mac_address != ''
+      list.merge!({ 'OVS_EXTRA' =>
+        "\"set bridge #{@resource[:bridge]} other-config:hwaddr=#{bridge_mac_address}\"" })
+    end
+    list
+  end
+
+  def interface_physical?
+    # OVS ports don't have entries in /sys/class/net
+    # Alias interfaces (ethX:Y) must use ethX entries
+    interface = @resource[:interface].sub(/:\d/, '')
+    ! Dir["/sys/class/net/#{interface}"].empty?
+  end
+
+  def from_str(data)
+    items = {}
+    data.each_line do |line|
+      if m = line.match(/^([A-Za-z_]*)=(.*)$/)
+        items.merge!(m[1] => m[2])
+      end
+    end
+    items
+  end
+
+  def cleared(data)
+    data.each do |key, value|
+      case key
+      when /vlan/i
+        data.delete(key)
+      when /bonding/i
+        data.delete(key)
+      end
+    end
+  end
+
+  def vlan?
+    if File.read('/proc/net/vlan/config') =~ /#{@resource[:interface]}/
+      return true
+    else
+      return false
+    end
+  rescue Errno::ENOENT
+    return false
+  end
+end