Merge branch 'update-changelog' into 'master'

Updated changelog

See merge request !4

.gitlab-ci.yml

@@ -0,0 +1,43 @@
+stages:
+  - package
+  - publish
+
+package:jessie:gem:
+  image: $CI_REGISTRY/docker-images/layers:$DISTRO-ruby
+  stage: package
+  variables:
+    DISTRO: jessie
+    GEMFILE: netlinkrb.gemspec
+  script:
+    - package
+  artifacts:
+    paths:
+    - pkg/
+ 
+package:jessie: &package
+  image: $CI_REGISTRY/docker-images/layers:$DISTRO-deb
+  stage: package
+  variables:
+    DISTRO: jessie
+  script:
+    - package
+  artifacts:
+    paths:
+      - pkg/
+
+package:stretch:
+  <<: *package
+  variables:
+    DISTRO: stretch
+
+package:wheezy:
+  <<: *package
+  variables:
+    DISTRO: wheezy
+
+publish:
+  image: $CI_REGISTRY/docker-images/layers:jessie-publish
+  stage: publish
+  script:
+    - publish
+

.hgignore

@@ -1,6 +1,7 @@
 ^debian/ruby-linux-netlink$
 ~$
 ^.config-liblinux-netlink-ruby
+^.pc/
 ^debian/files$
 ^debian/.*\.substvars$
 ^debian/.*\.debhelper.log$

debian/changelog

@@ -1,8 +1,82 @@
+ruby-linux-netlink (0.19-1) stable; urgency=medium
+
+  * The size of size_t is now calculated from the size of an unsigned long
+    int, instead of calling gcc.
+
+ -- Patrick J Cherry <patrick@bytemark.co.uk>  Wed, 10 May 2017 15:24:42 +0100
+
+ruby-linux-netlink (0.18-2) stable; urgency=medium
+
+  * This package is now architecture independent.
+  * The source format has been removed in favour of using dh --with quilt.
+
+ -- Patrick J Cherry <patrick@bytemark.co.uk>  Tue, 28 Feb 2017 16:43:43 +0000
+
+ruby-linux-netlink (0.18-1+jessie1) stable; urgency=medium
+
+  * Fixed new massive IP test thing to work with ruby1.8 and also non-root users
+  * Make sure link exists before proceeding with test
+  * Scaled back the massive allocation of IPs from 11 /24s to 4.
+  * Updated linux header constants
+  * Updated to 0.18
+
+ -- Patrick J Cherry <patrick@bytemark.co.uk>  Mon, 17 Oct 2016 13:09:35 +0100
+
+ruby-linux-netlink (0.17-1+jessie1) testing; urgency=medium
+
+  * New upstream release
+
+ -- Patrick J Cherry <patrick@bytemark.co.uk>  Wed, 01 Apr 2015 22:51:34 +0100
+
+ruby-linux-netlink (0.16-1+jessie1) testing; urgency=medium
+
+  * Repackaged for jessie
+
+ -- Patrick J Cherry <patrick@bytemark.co.uk>  Wed, 01 Apr 2015 17:39:44 +0100
+
+ruby-linux-netlink (0.16-1+wheezy1) stable; urgency=medium
+
+  * New upstream release.
+
+ -- Patrick J Cherry <patch@dynamo>  Tue, 26 Aug 2014 16:33:48 +0100
+
+ruby-linux-netlink (0.15-1+wheezy1) stable; urgency=low
+
+  * New upstream release.
+
+ -- Patrick J Cherry <patrick@bytemark.co.uk>  Tue, 21 Jan 2014 10:01:20 +0000
+
+ruby-linux-netlink (0.14-1+wheezy1) stable; urgency=low
+
+  * New upstream release.
+
+ -- Patrick J Cherry <patrick@bytemark.co.uk>  Thu, 14 Nov 2013 13:37:28 +0000
+
+ruby-linux-netlink (0.13-1+wheezy1) stable; urgency=low
+
+  * New upstream release.
+
+ -- Patrick J Cherry <patrick@bytemark.co.uk>  Wed, 13 Nov 2013 16:16:36 +0000
+
+ruby-linux-netlink (0.12-1+wheezy1) stable; urgency=low
+
+  * New upstream release.
+
+ -- Patrick J Cherry <patrick@bytemark.co.uk>  Thu, 12 Sep 2013 14:26:41 +0100
+
+ruby-linux-netlink (0.11-1+wheezy2) stable; urgency=low
+
+  * Switch to dpkg-source 3.0 (quilt) format.
+  * Added patch to remove rubygems requires.
+  * Renamed source package to fit in with the new guidelines.
+
+ -- Patrick J Cherry <patrick@bytemark.co.uk>  Fri, 05 Jul 2013 14:16:30 +0100
+
 linux-netlink-ruby (0.11-1+wheezy1) stable; urgency=low
 
   * New upstream version, repackaged for wheezy.
 
- -- Patrick J Cherry <patrick@bytemark.co.uk>  Fri, 05 Jul 2013 13:57:06 +0100
+ -- Patrick J Cherry <patrick@bytemark.co.uk>  Fri, 05 Jul 2013 14:16:05 +0100
 
 linux-netlink-ruby (0.10-6) stable; urgency=low
 

debian/control

@@ -1,14 +1,14 @@
-Source: linux-netlink-ruby
+Source: ruby-linux-netlink
 Maintainer: Matthew Bloch <matthew@bytemark.co.uk>
 Uploaders: Patrick J Cherry <patrick@bytemark.co.uk>
 Section: ruby
 Priority: optional
-Build-Depends:  debhelper (>= 7), gem2deb, rake, ruby-ffi
+Build-Depends:  debhelper (>= 7), gem2deb, rake, ruby-ffi, quilt
 Standards-Version: 3.8.0
 XS-Ruby-Versions: all 
 
 Package: ruby-linux-netlink
-Architecture: any
+Architecture: all
 Depends: ruby | ruby-interpreter, ruby-ffi, ${misc:Depends}
 Provides: liblinux-netlink-ruby1.8, liblinux-netlink-ruby1.9.1
 XB-Ruby-Versions: ${ruby:Versions}

debian/patches/remove-rubygems-requirements

@@ -0,0 +1,32 @@
+Removed "require rubygems" from everywhere.
+--- a/lib/linux/iptables.rb
++++ b/lib/linux/iptables.rb
+@@ -1,11 +1,6 @@
+ require 'socket'
+ require 'linux/constants'
+-
+-begin
+-  require 'ffi'
+-rescue LoadError
+-  require('rubygems') ? retry : raise
+-end
++require 'ffi'
+ 
+ 
+ # Good things about FFI::Struct:
+--- a/lib/linux/sendmsg.rb
++++ b/lib/linux/sendmsg.rb
+@@ -1,12 +1,7 @@
+ # Patchup to add Socket#sendmsg and Socket#recvmsg for ruby 1.8
+ 
+ if BasicSocket.instance_methods.grep(/^sendmsg$/).empty?
+-  begin
+-    require 'ffi'
+-  rescue LoadError
+-    require('rubygems') ? retry : raise
+-  end
+-
++  require 'ffi'
+     
+   class BasicSocket
+     module FFIExt

debian/patches/series

@@ -0,0 +1 @@
+remove-rubygems-requirements

debian/rules

@@ -13,7 +13,7 @@
 # export DH_RUBY_GEMSPEC=gem.gemspec
 
 %:
-	dh $@ --buildsystem=ruby --with ruby
+	dh $@ --buildsystem=ruby --with ruby --with quilt
 
 override_dh_auto_build-arch:
 	rake lib/linux/c_struct_sizeof_size_t.rb

lib/linux/c_struct.rb

@@ -32,12 +32,12 @@ class CStruct
   EMPTY_ARRAY  = [].freeze #:nodoc:
 
   TYPE_INFO = {} #:nodoc
-  
+
   # The size of the structure (in bytes)
   def self.bytesize
     @bytesize
   end
-  
+
   # Define a new type for use with 'field'. You supply the
   # symbolic name for the type, and a set of options.
   #    :pattern => "str"    # format string for Array#pack / String#unpack
@@ -51,7 +51,7 @@ class CStruct
   def self.define_type(name, opt)
     TYPE_INFO[name] = opt
   end
-  
+
   # Return a type info hash given a type id. Raises IndexError if not found.
   def self.find_type(type)
     case type
@@ -61,7 +61,7 @@ class CStruct
       TYPE_INFO.fetch(type)
     end
   end
-      
+
   define_type :uchar,   :pattern => "C"
   define_type :uint16,  :pattern => "S",  :align => true
   define_type :uint32,  :pattern => "L",  :align => true
@@ -78,12 +78,12 @@ class CStruct
   define_type :long,    :pattern => "l_", :align => true
   define_type :ns,      :pattern => "n",  :align => true
   define_type :nl,      :pattern => "N",  :align => true
-  
+
   begin
     require 'linux/c_struct_sizeof_size_t.rb'
   rescue LoadError
-    warn "Falling back to gcc to determine sizeof size_t." if $VERBOSE
-    SIZEOF_SIZE_T = Integer(`echo __SIZEOF_SIZE_T__ | gcc -E -P -`) rescue 1.size
+    warn "netlinkrb: Assuming size_t is a long unsigned int." if $DEBUG
+    SIZEOF_SIZE_T = [0].pack("L_").bytesize
   end
 
   define_type :size_t,
@@ -108,20 +108,20 @@ class CStruct
       h.each { |k,v| self[k] = v } if h
     end
   end
-  
+
   # This hook is called after unpacking from binary, and can be used
   # for fixing up the data
   def after_parse
   end
-  
+
   def to_hash
     @attrs
   end
-  
+
   def each(&blk)
     @attrs.each(&blk)
   end
-  
+
   # Set a field by name. Currently can use either symbol or string as key.
   def []=(k,v)
     send "#{k}=", v
@@ -131,7 +131,7 @@ class CStruct
   def [](k)
     @attrs[k]
   end
-  
+
   def self.inherited(subclass) #:nodoc:
     subclass.const_set(:FIELDS, [])
     subclass.const_set(:FORMAT, "")
@@ -175,7 +175,7 @@ class CStruct
       @bytesize += count
     end
   end
-  
+
   # Returns the packed binary representation of this structure
   def to_str
     self.class::FIELDS.map { |key| self[key] || self.class::DEFAULTS[key] }.pack(self.class::FORMAT)
@@ -184,7 +184,7 @@ class CStruct
   def inspect
     "#<#{self.class} #{@attrs.inspect}>"
   end
-  
+
   # Convert a binary representation of this structure into an object instance.
   # If a block is given, the object is yielded to that block. Finally the
   # after_parse hook is called.

lib/linux/constants.rb

@@ -1,406 +1,512 @@
 require 'socket'
 class Socket
   # From bits/socket.h
-  PF_NETLINK		= 16		unless defined? Socket::PF_NETLINK
-  AF_NETLINK		= PF_NETLINK	unless defined? Socket::AF_NETLINK
+  PF_NETLINK    = 16    unless defined? Socket::PF_NETLINK
+  AF_NETLINK    = PF_NETLINK  unless defined? Socket::AF_NETLINK
   # From in.h
-  IPPROTO_IPV6		= 41		unless defined? Socket::IPPROTO_IPV6
+  IPPROTO_IPV6    = 41    unless defined? Socket::IPPROTO_IPV6
 end
 
 module Linux
   # From linux/netlink.h
-  NETLINK_ROUTE		= 0
-  NETLINK_UNUSED	= 1
-  NETLINK_USERSOCK	= 2
-  NETLINK_FIREWALL	= 3
-  NETLINK_INET_DIAG	= 4
-  NETLINK_NFLOG		= 5
-  NETLINK_XFRM		= 6
-  NETLINK_SELINUX	= 7
-  NETLINK_ISCSI		= 8
-  NETLINK_AUDIT		= 9
-  NETLINK_FIB_LOOKUP	= 10
-  NETLINK_CONNECTOR	= 11
-  NETLINK_NETFILTER	= 12
-  NETLINK_IP6_FW	= 13
-  NETLINK_DNRTMSG	= 14
+  NETLINK_ROUTE    = 0
+  NETLINK_UNUSED  = 1
+  NETLINK_USERSOCK  = 2
+  NETLINK_FIREWALL  = 3
+  NETLINK_INET_DIAG  = 4
+  NETLINK_NFLOG    = 5
+  NETLINK_XFRM    = 6
+  NETLINK_SELINUX  = 7
+  NETLINK_ISCSI    = 8
+  NETLINK_AUDIT    = 9
+  NETLINK_FIB_LOOKUP  = 10
+  NETLINK_CONNECTOR  = 11
+  NETLINK_NETFILTER  = 12
+  NETLINK_IP6_FW  = 13
+  NETLINK_DNRTMSG  = 14
   NETLINK_KOBJECT_UEVENT = 15
-  NETLINK_GENERIC	= 16
-  NETLINK_SCSITRANSPORT	= 18
-  NETLINK_ECRYPTFS	= 19
+  NETLINK_GENERIC  = 16
+  NETLINK_SCSITRANSPORT  = 18
+  NETLINK_ECRYPTFS  = 19
   NETLINK_RDMA      = 20
-  NETLINK_CRYPTO    = 21  
- 
-  NLM_F_REQUEST		= 1
-  NLM_F_MULTI		= 2
-  NLM_F_ACK		= 4
-  NLM_F_ECHO		= 8
+  NETLINK_CRYPTO    = 21
+
+  NLM_F_REQUEST    = 1
+  NLM_F_MULTI    = 2
+  NLM_F_ACK    = 4
+  NLM_F_ECHO    = 8
   NLM_F_DUMP_INTR = 16
-  NLM_F_ROOT		= 0x100
-  NLM_F_MATCH		= 0x200
-  NLM_F_ATOMIC		= 0x400
-  NLM_F_DUMP		= (NLM_F_ROOT|NLM_F_MATCH)
-  
-  NLM_F_REPLACE		= 0x100
-  NLM_F_EXCL		= 0x200
-  NLM_F_CREATE		= 0x400
-  NLM_F_APPEND		= 0x800
+  NLM_F_DUMP_FILTERED = 32
+  NLM_F_ROOT    = 0x100
+  NLM_F_MATCH    = 0x200
+  NLM_F_ATOMIC    = 0x400
+  NLM_F_DUMP    = (NLM_F_ROOT|NLM_F_MATCH)
+
+  NLM_F_REPLACE    = 0x100
+  NLM_F_EXCL    = 0x200
+  NLM_F_CREATE    = 0x400
+  NLM_F_APPEND    = 0x800
+
+  NLMSG_ALIGNTO    = 4  # same on i686 and x86_64
+
+  NLMSG_NOOP    = 0x1
+  NLMSG_ERROR    = 0x2
+  NLMSG_DONE    = 0x3
+  NLMSG_OVERRUN    = 0x4
+
+  NLMSG_MIN_TYPE = 0x10
+
+  NETLINK_ADD_MEMBERSHIP  = 1
+  NETLINK_DROP_MEMBERSHIP  = 2
+  NETLINK_PKTINFO    = 3
+  NETLINK_BROADCAST_ERROR  = 4
+  NETLINK_NO_ENOBUFS    = 5
+  NETLINK_RX_RING  = 6
+  NETLINK_TX_RING = 7
+  NETLINK_LISTEN_ALL_NSID = 8
+  NETLINK_LIST_MEMBERSHIPS = 9
+  NETLINK_CAP_ACK = 10
+
+  NETLINK_UNCONNECTED    = 0
+  NETLINK_CONNECTED    = 1
+
+  NLA_F_NESTED      = (1 << 15)
+  NLA_F_NET_BYTEORDER    = (1 << 14)
+  NLA_TYPE_MASK      = ~(NLA_F_NESTED | NLA_F_NET_BYTEORDER)
+
+  NLA_ALIGNTO      = 4  # same on i686 and x86_64
 
-  NLMSG_ALIGNTO		= 4	# same on i686 and x86_64
-  
-  NLMSG_NOOP		= 0x1
-  NLMSG_ERROR		= 0x2
-  NLMSG_DONE		= 0x3
-  NLMSG_OVERRUN		= 0x4
-  
-  NETLINK_ADD_MEMBERSHIP	= 1
-  NETLINK_DROP_MEMBERSHIP	= 2
-  NETLINK_PKTINFO		= 3
-  NETLINK_BROADCAST_ERROR	= 4
-  NETLINK_NO_ENOBUFS		= 5
-  
-  NETLINK_UNCONNECTED		= 0
-  NETLINK_CONNECTED		= 1
-  
-  NLA_F_NESTED			= (1 << 15)
-  NLA_F_NET_BYTEORDER		= (1 << 14)
-  NLA_TYPE_MASK			= ~(NLA_F_NESTED | NLA_F_NET_BYTEORDER)
-  
-  NLA_ALIGNTO			= 4	# same on i686 and x86_64
-  
   # from linux/rtnetlink.h.
-  RTM_NEWLINK		= 16
-  RTM_DELLINK		= 17
-  RTM_GETLINK		= 18
-  RTM_SETLINK		= 19
-  
-  RTM_NEWADDR		= 20     
-  RTM_DELADDR		= 21
-  RTM_GETADDR		= 22
-  
-  RTM_NEWROUTE		= 24
-  RTM_DELROUTE		= 25
-  RTM_GETROUTE		= 26
-  
-  RTM_NEWNEIGH		= 28
-  RTM_DELNEIGH		= 29
-  RTM_GETNEIGH		= 30
-  
-  RTM_NEWRULE		= 32
-  RTM_DELRULE		= 33
-  RTM_GETRULE		= 34
-  
-  RTM_NEWQDISC		= 36
-  RTM_DELQDISC		= 37
-  RTM_GETQDISC		= 38
-  
-  RTM_NEWTCLASS		= 40
-  RTM_DELTCLASS		= 41
-  RTM_GETTCLASS		= 42
-  
-  RTM_NEWTFILTER	= 44
-  RTM_DELTFILTER	= 45
-  RTM_GETTFILTER	= 46
-  
-  RTM_NEWACTION		= 48
-  RTM_DELACTION		= 49
-  RTM_GETACTION		= 50
-  
-  RTM_NEWPREFIX		= 52
-  RTM_GETMULTICAST	= 58
-  RTM_GETANYCAST	= 62
+  RTM_BASE      = 16
+  RTM_NEWLINK    = 16
+  RTM_DELLINK    = 17
+  RTM_GETLINK    = 18
+  RTM_SETLINK    = 19
 
-  RTM_NEWNEIGHTBL	= 64
-  RTM_GETNEIGHTBL	= 66
-  RTM_SETNEIGHTBL	= 67
-  
-  RTM_NEWNDUSEROPT	= 68
+  RTM_NEWADDR    = 20
+  RTM_DELADDR    = 21
+  RTM_GETADDR    = 22
 
-  RTM_NEWADDRLABEL	= 72
-  RTM_DELADDRLABEL	= 73
-  RTM_GETADDRLABEL	= 74
-  
-  RTM_GETDCB		= 78
-  RTM_SETDCB		= 79
+  RTM_NEWROUTE    = 24
+  RTM_DELROUTE    = 25
+  RTM_GETROUTE    = 26
+
+  RTM_NEWNEIGH    = 28
+  RTM_DELNEIGH    = 29
+  RTM_GETNEIGH    = 30
+
+  RTM_NEWRULE    = 32
+  RTM_DELRULE    = 33
+  RTM_GETRULE    = 34
+
+  RTM_NEWQDISC    = 36
+  RTM_DELQDISC    = 37
+  RTM_GETQDISC    = 38
+
+  RTM_NEWTCLASS    = 40
+  RTM_DELTCLASS    = 41
+  RTM_GETTCLASS    = 42
+
+  RTM_NEWTFILTER  = 44
+  RTM_DELTFILTER  = 45
+  RTM_GETTFILTER  = 46
+
+  RTM_NEWACTION    = 48
+  RTM_DELACTION    = 49
+  RTM_GETACTION    = 50
+
+  RTM_NEWPREFIX    = 52
+  RTM_GETMULTICAST  = 58
+  RTM_GETANYCAST  = 62
+
+  RTM_NEWNEIGHTBL  = 64
+  RTM_GETNEIGHTBL  = 66
+  RTM_SETNEIGHTBL  = 67
+
+  RTM_NEWNDUSEROPT  = 68
+
+  RTM_NEWADDRLABEL  = 72
+  RTM_DELADDRLABEL  = 73
+  RTM_GETADDRLABEL  = 74
+
+  RTM_GETDCB    = 78
+  RTM_SETDCB    = 79
+
+
+  RTM_NEWNETCONF = 80
+  RTM_GETNETCONF = 82
+
+  RTM_NEWMDB = 84
+  RTM_DELMDB = 85
+  RTM_GETMDB = 86
+
+  RTM_NEWNSID = 88
+  RTM_DELNSID = 89
+  RTM_GETNSID = 90
+
+  RTM_NEWSTATS = 92
+  RTM_GETSTATS = 94
 
   # RT#type
-  RTN_UNSPEC		= 0
-  RTN_UNICAST		= 1
-  RTN_LOCAL		= 2
-  RTN_BROADCAST		= 3
-  RTN_ANYCAST		= 4
-  RTN_MULTICAST		= 5
-  RTN_BLACKHOLE		= 6
-  RTN_UNREACHABLE	= 7
-  RTN_PROHIBIT		= 8
-  RTN_THROW		= 9
-  RTN_NAT		= 10
-  RTN_XRESOLVE		= 11
-  
+  RTN_UNSPEC    = 0
+  RTN_UNICAST    = 1
+  RTN_LOCAL    = 2
+  RTN_BROADCAST    = 3
+  RTN_ANYCAST    = 4
+  RTN_MULTICAST    = 5
+  RTN_BLACKHOLE    = 6
+  RTN_UNREACHABLE  = 7
+  RTN_PROHIBIT    = 8
+  RTN_THROW    = 9
+  RTN_NAT    = 10
+  RTN_XRESOLVE    = 11
+
   # RT#protocol
-  RTPROT_UNSPEC		= 0
-  RTPROT_REDIRECT	= 1
-  RTPROT_KERNEL		= 2
-  RTPROT_BOOT		= 3
-  RTPROT_STATIC		= 4
-  RTPROT_GATED		= 8
-  RTPROT_RA		= 9
-  RTPROT_MRT		= 10
-  RTPROT_ZEBRA		= 11
-  RTPROT_BIRD		= 12
-  RTPROT_DNROUTED	= 13
-  RTPROT_XORP		= 14
-  RTPROT_NTK		= 15
-  RTPROT_DHCP		= 16
-  
+  RTPROT_UNSPEC    = 0
+  RTPROT_REDIRECT  = 1
+  RTPROT_KERNEL    = 2
+  RTPROT_BOOT    = 3
+  RTPROT_STATIC    = 4
+  RTPROT_GATED    = 8
+  RTPROT_RA    = 9
+  RTPROT_MRT    = 10
+  RTPROT_ZEBRA    = 11
+  RTPROT_BIRD    = 12
+  RTPROT_DNROUTED  = 13
+  RTPROT_XORP    = 14
+  RTPROT_NTK    = 15
+  RTPROT_DHCP    = 16
+  RTPROT_MROUTED = 17
+  RTPROT_BABEL = 42
+
   # RT#scope, IFAddr#scope
-  RT_SCOPE_UNIVERSE	= 0
-  RT_SCOPE_SITE		= 200
-  RT_SCOPE_LINK		= 253
-  RT_SCOPE_HOST		= 254
-  RT_SCOPE_NOWHERE	= 255
+  RT_SCOPE_UNIVERSE  = 0
+  RT_SCOPE_SITE    = 200
+  RT_SCOPE_LINK    = 253
+  RT_SCOPE_HOST    = 254
+  RT_SCOPE_NOWHERE  = 255
 
   # RT#flags
-  RTM_F_NOTIFY		= 0x100
-  RTM_F_CLONED		= 0x200
-  RTM_F_EQUALIZE	= 0x400
-  RTM_F_PREFIX		= 0x800
+  RTM_F_NOTIFY    = 0x100
+  RTM_F_CLONED    = 0x200
+  RTM_F_EQUALIZE  = 0x400
+  RTM_F_PREFIX    = 0x800
+  RTM_F_LOOKUP_TABLE = 0x1000
 
   # RT#table (reserved values)
-  RT_TABLE_UNSPEC	= 0
-  RT_TABLE_COMPAT	= 252
-  RT_TABLE_DEFAULT	= 253
-  RT_TABLE_MAIN		= 254
-  RT_TABLE_LOCAL	= 255
-  
-  # routing message attributes
-  RTA_UNSPEC		= 0
-  RTA_DST		= 1
-  RTA_SRC		= 2
-  RTA_IIF		= 3
-  RTA_OIF		= 4
-  RTA_GATEWAY		= 5
-  RTA_PRIORITY		= 6
-  RTA_PREFSRC		= 7
-  RTA_METRICS		= 8
-  RTA_MULTIPATH		= 9
-  RTA_FLOW		= 11
-  RTA_CACHEINFO		= 12
-  RTA_TABLE		= 15
-  RTA_MARK		= 16
-  
-  # Keys for RT#metrics
-  RTAX_UNSPEC		= 0
-  RTAX_LOCK		= 1
-  RTAX_MTU		= 2
-  RTAX_WINDOW		= 3
-  RTAX_RTT		= 4
-  RTAX_RTTVAR		= 5
-  RTAX_SSTHRESH		= 6
-  RTAX_CWND		= 7
-  RTAX_ADVMSS		= 8
-  RTAX_REORDERING	= 9
-  RTAX_HOPLIMIT		= 10
-  RTAX_INITCWND		= 11
-  RTAX_FEATURES		= 12
-  RTAX_RTO_MIN		= 13
-  RTAX_INITRWND		= 14
-    
-  # from linux/if_link.h
-  IFLA_UNSPEC		= 0
-  IFLA_ADDRESS		= 1
-  IFLA_BROADCAST	= 2
-  IFLA_IFNAME		= 3
-  IFLA_MTU		= 4
-  IFLA_LINK		= 5
-  IFLA_QDISC		= 6
-  IFLA_STATS		= 7
-  IFLA_COST		= 8
-  IFLA_PRIORITY		= 9
-  IFLA_MASTER		= 10
-  IFLA_WIRELESS		= 11
-  IFLA_PROTINFO		= 12
-  IFLA_TXQLEN		= 13
-  IFLA_MAP		= 14
-  IFLA_WEIGHT		= 15
-  IFLA_OPERSTATE	= 16
-  IFLA_LINKMODE		= 17
-  IFLA_LINKINFO		= 18	# Nested IFLA_INFO_*
-  IFLA_NET_NS_PID	= 19
-  IFLA_IFALIAS		= 20
-  IFLA_NUM_VF		= 21
-  IFLA_VFINFO_LIST	= 22
-  IFLA_STATS64		= 23
-  IFLA_VF_PORTS		= 24
-  IFLA_PORT_SELF	= 25
-  IFLA_AF_SPEC    = 26
-  IFLA_GROUP      = 27
-  IFLA_NET_NS_FD  = 28
-  IFLA_EXT_MASK   = 29 
-  IFLA_PROMISCUITY = 30
+  RT_TABLE_UNSPEC  = 0
+  RT_TABLE_COMPAT  = 252
+  RT_TABLE_DEFAULT  = 253
+  RT_TABLE_MAIN    = 254
+  RT_TABLE_LOCAL  = 255
+
+  # routing message attributes
+  RTA_UNSPEC    = 0
+  RTA_DST    = 1
+  RTA_SRC    = 2
+  RTA_IIF    = 3
+  RTA_OIF    = 4
+  RTA_GATEWAY    = 5
+  RTA_PRIORITY    = 6
+  RTA_PREFSRC    = 7
+  RTA_METRICS    = 8
+  RTA_MULTIPATH    = 9
+  RTA_FLOW    = 11
+  RTA_CACHEINFO    = 12
+  RTA_TABLE    = 15
+  RTA_MARK    = 16
+  RTA_MFC_STATS = 17
+  RTA_VIA = 18
+  RTA_NEWDST = 19
+  RTA_PREF = 20
+  RTA_ENCAP_TYPE = 21
+  RTA_ENCAP = 22
+  RTA_EXPIRES = 23
+  RTA_PAD = 24
+
+  # Keys for RT#nh_flags
+  RTNH_F_DEAD      = 1    # Nexthop is dead (used by multipath)
+  RTNH_F_PERVASIVE  = 2  # Do recursive gateway lookup
+  RTNH_F_ONLINK    = 4   # Gateway is forced on link
+  RTNH_F_OFFLOAD   = 8   # offloaded route
+  RTNH_F_LINKDOWN  = 16  # carrier-down on nexthop
+
+
+  # Keys for RT#metrics
+  RTAX_UNSPEC    = 0
+  RTAX_LOCK    = 1
+  RTAX_MTU    = 2
+  RTAX_WINDOW    = 3
+  RTAX_RTT    = 4
+  RTAX_RTTVAR    = 5
+  RTAX_SSTHRESH    = 6
+  RTAX_CWND    = 7
+  RTAX_ADVMSS    = 8
+  RTAX_REORDERING  = 9
+  RTAX_HOPLIMIT    = 10
+  RTAX_INITCWND    = 11
+  RTAX_FEATURES    = 12
+  RTAX_RTO_MIN    = 13
+  RTAX_INITRWND    = 14
+  RTAX_QUICKACK   = 15
+  RTAX_CC_ALGO    = 16
+
+  # from linux/if_link.h
+  IFLA_UNSPEC    = 0
+  IFLA_ADDRESS    = 1
+  IFLA_BROADCAST  = 2
+  IFLA_IFNAME    = 3
+  IFLA_MTU    = 4
+  IFLA_LINK    = 5
+  IFLA_QDISC    = 6
+  IFLA_STATS    = 7
+  IFLA_COST    = 8
+  IFLA_PRIORITY    = 9
+  IFLA_MASTER    = 10
+  IFLA_WIRELESS    = 11
+  IFLA_PROTINFO    = 12
+  IFLA_TXQLEN    = 13
+  IFLA_MAP    = 14
+  IFLA_WEIGHT    = 15
+  IFLA_OPERSTATE  = 16
+  IFLA_LINKMODE    = 17
+  IFLA_LINKINFO    = 18  # Nested IFLA_INFO_*
+  IFLA_NET_NS_PID  = 19
+  IFLA_IFALIAS    = 20
+  IFLA_NUM_VF    = 21
+  IFLA_VFINFO_LIST  = 22
+  IFLA_STATS64    = 23
+  IFLA_VF_PORTS    = 24
+  IFLA_PORT_SELF  = 25
+  IFLA_AF_SPEC          = 26
+  IFLA_GROUP            = 27
+  IFLA_NET_NS_FD        = 28
+  IFLA_EXT_MASK   = 29
+  IFLA_PROMISCUITY      = 30
+  IFLA_NUM_TX_QUEUES    = 31
+  IFLA_NUM_RX_QUEUES    = 32
+  IFLA_CARRIER          = 33
+  IFLA_PHYS_PORT_ID  = 34
+  IFLA_CARRIER_CHANGES = 35
+  IFLA_PHYS_SWITCH_ID = 36
+  IFLA_LINK_NETNSID = 37
+  IFLA_PHYS_PORT_NAME = 38
+  IFLA_PROTO_DOWN = 39
+  IFLA_GSO_MAX_SEGS = 40
+  IFLA_GSO_MAX_SIZE = 41
+  IFLA_PAD = 42
+
+  BRIDGE_MODE_UNSPEC = 0
+  BRIDGE_MODE_HAIRPIN = 1
+
+  IFLA_BRPORT_UNSPEC        = 0
+  IFLA_BRPORT_STATE         = 1 # Spanning tree state
+  IFLA_BRPORT_PRIORITY      = 2 # "             priority
+  IFLA_BRPORT_COST          = 3 # "             cost
+  IFLA_BRPORT_MODE          = 4 # mode (hairpin)
+  IFLA_BRPORT_GUARD         = 5 # bpdu guard
+  IFLA_BRPORT_PROTECT       = 6 # root port protection
+  IFLA_BRPORT_FAST_LEAVE    = 7 # multicast fast leave
+  IFLA_BRPORT_LEARNING      = 8 # mac learning
+  IFLA_BRPORT_UNICAST_FLOOD = 9 # flood unicast traffic
+  IFLA_BRPORT_PROXYARP      = 10 # proxy ARP
+  IFLA_BRPORT_LEARNING_SYNC = 11 # mac learning sync from device
+  IFLA_BRPORT_PROXYARP_WIFI = 12 # proxy ARP for Wi-Fi
+  IFLA_BRPORT_ROOT_ID       = 13 # designated root
+  IFLA_BRPORT_BRIDGE_ID     = 14 # designated bridge
+  IFLA_BRPORT_DESIGNATED_PORT = 15
+  IFLA_BRPORT_DESIGNATED_COST = 16
+  IFLA_BRPORT_ID = 17
+  IFLA_BRPORT_NO = 18
+  IFLA_BRPORT_TOPOLOGY_CHANGE_ACK = 19
+  IFLA_BRPORT_CONFIG_PENDING = 20
+  IFLA_BRPORT_MESSAGE_AGE_TIMER = 21
+  IFLA_BRPORT_FORWARD_DELAY_TIMER = 22
+  IFLA_BRPORT_HOLD_TIMER = 23
+  IFLA_BRPORT_FLUSH = 24
+  IFLA_BRPORT_MULTICAST_ROUTER = 25
+  IFLA_BRPORT_PAD = 26
+
+  IFLA_INFO_UNSPEC  = 0
+  IFLA_INFO_KIND  = 1  # "vlan", "gre" etc
+  IFLA_INFO_DATA  = 2  # packed rtattrs specific to type, e.g. vlan
+  IFLA_INFO_XSTATS  = 3
 
-  IFLA_INFO_UNSPEC	= 0
-  IFLA_INFO_KIND	= 1	# "vlan", "gre" etc
-  IFLA_INFO_DATA	= 2	# packed rtattrs specific to type, e.g. vlan
-  IFLA_INFO_XSTATS	= 3
 
   # INFO_DATA for INFO_KIND == "vlan"
-  IFLA_VLAN_UNSPEC	= 0
-  IFLA_VLAN_ID		= 1	# ushort
-  IFLA_VLAN_FLAGS	= 2	# struct ifla_vlan_flags
-  IFLA_VLAN_EGRESS_QOS	= 3	# followed by instance of IFLA_VLAN_QOS_*
-  IFLA_VLAN_INGRESS_QOS	= 4	# followed by instance of IFLA_VLAN_QOS_*
-  
-  IFLA_VLAN_QOS_UNSPEC	= 0
-  IFLA_VLAN_QOS_MAPPING	= 1
-  
-  IFLA_MACVLAN_UNSPEC	= 0
-  IFLA_MACVLAN_MODE	= 1
-  
-  MACVLAN_MODE_PRIVATE	= 1
-  MACVLAN_MODE_VEPA	= 2
-  MACVLAN_MODE_BRIDGE	= 4
-  MACVLAN_MODE_PASSTHRU	= 8
-  
+  IFLA_VLAN_UNSPEC  = 0
+  IFLA_VLAN_ID    = 1  # ushort
+  IFLA_VLAN_FLAGS  = 2  # struct ifla_vlan_flags
+  IFLA_VLAN_EGRESS_QOS  = 3  # followed by instance of IFLA_VLAN_QOS_*
+  IFLA_VLAN_INGRESS_QOS  = 4  # followed by instance of IFLA_VLAN_QOS_*
+  IFLA_VLAN_PROTOCOL    = 5
+
+  IFLA_VLAN_QOS_UNSPEC  = 0
+  IFLA_VLAN_QOS_MAPPING = 1
+
+  IFLA_MACVLAN_UNSPEC  = 0
+  IFLA_MACVLAN_MODE  = 1
+  IFLA_MACVLAN_FLAGS  = 2
+  IFLA_MACVLAN_MACADDR_MODE = 3
+  IFLA_MACVLAN_MACADDR = 4
+  IFLA_MACVLAN_MACADDR_DATA = 5
+  IFLA_MACVLAN_MACADDR_COUNT = 6
+
+  MACVLAN_MODE_PRIVATE  = 1 # don't talk to other macvlans
+  MACVLAN_MODE_VEPA  = 2 # talk to other ports through ext bridge
+  MACVLAN_MODE_BRIDGE  = 4 # talk to bridge ports directly
+  MACVLAN_MODE_PASSTHRU  = 8 # take over the underlying device
+  MACVLAN_MODE_SOURCE = 16 # use source MAC address list to assign
+
+  # TODO: VXLAN and VF stuff is missing here
+
   # linux/if_vlan.h
-  VLAN_FLAG_REORDER_HDR		= 0x1
-  VLAN_FLAG_GVRP		= 0x2
-  VLAN_FLAG_LOOSE_BINDING	= 0x4
-  
+  VLAN_FLAG_REORDER_HDR    = 0x1
+  VLAN_FLAG_GVRP    = 0x2
+  VLAN_FLAG_LOOSE_BINDING  = 0x4
+  VLAN_FLAG_MVRP          = 0x8
+
   # from linux/if_addr.h
-  IFA_UNSPEC		= 0
-  IFA_ADDRESS		= 1
-  IFA_LOCAL		= 2
-  IFA_LABEL		= 3
-  IFA_BROADCAST		= 4
-  IFA_ANYCAST		= 5
-  IFA_CACHEINFO		= 6
-  IFA_MULTICAST		= 7
+  IFA_UNSPEC      = 0
+  IFA_ADDRESS     = 1
+  IFA_LOCAL       = 2
+  IFA_LABEL       = 3
+  IFA_BROADCAST   = 4
+  IFA_ANYCAST     = 5
+  IFA_CACHEINFO   = 6
+  IFA_MULTICAST   = 7
+  IFA_FLAGS       = 8
 
-  IFA_F_SECONDARY	= 0x01
-  IFA_F_TEMPORARY	= IFA_F_SECONDARY
-  IFA_F_NODAD		= 0x02
-  IFA_F_OPTIMISTIC	= 0x04
-  IFA_F_DADFAILED	= 0x08
-  IFA_F_HOMEADDRESS	= 0x10
-  IFA_F_DEPRECATED	= 0x20
-  IFA_F_TENTATIVE	= 0x40
-  IFA_F_PERMANENT	= 0x80
+  IFA_F_SECONDARY      = 0x01
+  IFA_F_TEMPORARY      = IFA_F_SECONDARY
+  IFA_F_NODAD          = 0x02
+  IFA_F_OPTIMISTIC     = 0x04
+  IFA_F_DADFAILED      = 0x08
+  IFA_F_HOMEADDRESS    = 0x10
+  IFA_F_DEPRECATED     = 0x20
+  IFA_F_TENTATIVE      = 0x40
+  IFA_F_PERMANENT      = 0x80
+  IFA_F_MANAGETEMPADDR = 0x100
+  IFA_F_NOPREFIXROUTE  = 0x200
+  IFA_F_MCAUTOJOIN     = 0x400
+  IFA_F_STABLE_PRIVACY = 0x800
 
-  # from linux/if_arp.h
-  ARPHRD_NETROM		= 0
-  ARPHRD_ETHER		= 1
-  ARPHRD_EETHER		= 2
-  ARPHRD_AX25		= 3
-  ARPHRD_PRONET		= 4
-  ARPHRD_CHAOS		= 5
-  ARPHRD_IEEE802	= 6
-  ARPHRD_ARCNET		= 7
-  ARPHRD_APPLETLK	= 8
-  ARPHRD_DLCI		= 15
-  ARPHRD_ATM		= 19
-  ARPHRD_METRICOM	= 23
-  ARPHRD_IEEE1394	= 24
-  ARPHRD_EUI64		= 27
-  ARPHRD_INFINIBAND	= 32
-  ARPHRD_LOOPBACK	= 772
+  # from linux/if_arp.h - selected subset
+  ARPHRD_NETROM    = 0
+  ARPHRD_ETHER    = 1
+  ARPHRD_EETHER    = 2
+  ARPHRD_AX25    = 3
+  ARPHRD_PRONET    = 4
+  ARPHRD_CHAOS    = 5
+  ARPHRD_IEEE802  = 6
+  ARPHRD_ARCNET    = 7
+  ARPHRD_APPLETLK  = 8
+  ARPHRD_DLCI    = 15
+  ARPHRD_ATM    = 19
+  ARPHRD_METRICOM  = 23
+  ARPHRD_IEEE1394  = 24
+  ARPHRD_EUI64    = 27
+  ARPHRD_INFINIBAND  = 32
+  ARPHRD_LOOPBACK  = 772
   # ... others to be added as required
 
   # linux/if.h
-  IFNAMSIZ		= 16
-  IFALIASZ		= 256
-  IFF_UP		= 0x1
-  IFF_BROADCAST		= 0x2
-  IFF_DEBUG		= 0x4
-  IFF_LOOPBACK		= 0x8
-  IFF_POINTOPOINT	= 0x10
-  IFF_NOTRAILERS	= 0x20
-  IFF_RUNNING		= 0x40
-  IFF_NOARP		= 0x80
-  IFF_PROMISC		= 0x100
-  IFF_ALLMULTI		= 0x200
-  IFF_MASTER		= 0x400
-  IFF_SLAVE		= 0x800
-  IFF_MULTICAST		= 0x1000
-  IFF_PORTSEL		= 0x2000
-  IFF_AUTOMEDIA		= 0x4000
-  IFF_DYNAMIC		= 0x8000
-  IFF_LOWER_UP		= 0x10000
-  IFF_DORMANT		= 0x20000
-  IFF_ECHO		= 0x40000
-  IFF_VOLATILE		= (IFF_LOOPBACK|IFF_POINTOPOINT|IFF_BROADCAST|IFF_ECHO|\
-			IFF_MASTER|IFF_SLAVE|IFF_RUNNING|IFF_LOWER_UP|IFF_DORMANT)
+  IFNAMSIZ    = 16
+  IFALIASZ    = 256
+  IFF_UP    = 0x1
+  IFF_BROADCAST    = 0x2
+  IFF_DEBUG    = 0x4
+  IFF_LOOPBACK    = 0x8
+  IFF_POINTOPOINT  = 0x10
+  IFF_NOTRAILERS  = 0x20
+  IFF_RUNNING    = 0x40
+  IFF_NOARP    = 0x80
+  IFF_PROMISC    = 0x100
+  IFF_ALLMULTI    = 0x200
+  IFF_MASTER    = 0x400
+  IFF_SLAVE    = 0x800
+  IFF_MULTICAST    = 0x1000
+  IFF_PORTSEL    = 0x2000
+  IFF_AUTOMEDIA    = 0x4000
+  IFF_DYNAMIC    = 0x8000
+  IFF_LOWER_UP    = 0x10000
+  IFF_DORMANT    = 0x20000
+  IFF_ECHO    = 0x40000
+  IFF_VOLATILE    = (IFF_LOOPBACK|IFF_POINTOPOINT|IFF_BROADCAST|IFF_ECHO|\
+      IFF_MASTER|IFF_SLAVE|IFF_RUNNING|IFF_LOWER_UP|IFF_DORMANT)
 
   # linux/netfilter.h
-  NF_DROP		= 0
-  NF_ACCEPT		= 1
-  NF_STOLEN		= 2
-  NF_QUEUE		= 3
-  NF_REPEAT		= 4
-  NF_STOP		= 5
+  NF_DROP    = 0
+  NF_ACCEPT    = 1
+  NF_STOLEN    = 2
+  NF_QUEUE    = 3
+  NF_REPEAT    = 4
+  NF_STOP    = 5
 
-  NF_INET_PRE_ROUTING	= 0
-  NF_INET_LOCAL_IN	= 1
-  NF_INET_FORWARD	= 2
-  NF_INET_LOCAL_OUT	= 3
-  NF_INET_POST_ROUTING	= 4
-  NF_INET_NUMHOOKS	= 5
-    
-  NFPROTO_UNSPEC	= 0
-  NFPROTO_IPV4		= 2
-  NFPROTO_ARP		= 3
-  NFPROTO_BRIDGE	= 7
-  NFPROTO_IPV6		= 10
-  NFPROTO_DECNET	= 12
+  NF_INET_PRE_ROUTING  = 0
+  NF_INET_LOCAL_IN  = 1
+  NF_INET_FORWARD  = 2
+  NF_INET_LOCAL_OUT  = 3
+  NF_INET_POST_ROUTING  = 4
+  NF_INET_NUMHOOKS  = 5
+
+  NFPROTO_UNSPEC  = 0
+  NFPROTO_INET    = 1
+  NFPROTO_IPV4    = 2
+  NFPROTO_ARP    = 3
+  NFPROTO_NETDEV = 5
+  NFPROTO_BRIDGE  = 7
+  NFPROTO_IPV6    = 10
+  NFPROTO_DECNET  = 12
 
   # linux/netfilter_ipv4/ip_queue.h
-  IPQ_COPY_NONE		= 0
-  IPQ_COPY_META		= 1
-  IPQ_COPY_PACKET	= 2
-  
-  IPQM_MODE		= 17
-  IPQM_VERDICT		= 18
-  IPQM_PACKET		= 19
-  IPQM_MAX		= 20
+  IPQ_COPY_NONE    = 0
+  IPQ_COPY_META    = 1
+  IPQ_COPY_PACKET  = 2
+
+  IPQM_MODE    = 17
+  IPQM_VERDICT    = 18
+  IPQM_PACKET    = 19
+  IPQM_MAX    = 20
 
   # linux/netfilter_ipv4/ipt_ULOG.h
-  ULOG_MAC_LEN		= 80
-  ULOG_PREFIX_LEN	= 32
-  
+  ULOG_MAC_LEN    = 80
+  ULOG_PREFIX_LEN  = 32
+
   # linux/netfilter/x_tables.h
-  XT_TABLE_MAXNAMELEN	= 32
-  
-  XT_CONTINUE		= 0xffffffff
-  XT_RETURN		= (-NF_REPEAT - 1)
+  XT_TABLE_MAXNAMELEN  = 32
+
+  XT_CONTINUE    = 0xffffffff
+  XT_RETURN    = (-NF_REPEAT - 1)
+
+  XT_INV_PROTO    = 0x40
 
-  XT_INV_PROTO		= 0x40
-  
   # linux/netfilter_ipv4/ip_tables.h
-  IPT_TABLE_MAXNAMELEN	= XT_TABLE_MAXNAMELEN
-  
-  IPT_F_FRAG		= 0x01
-  IPT_F_GOTO		= 0x02
-  IPT_F_MASK		= 0x03
-  
-  IPT_INV_VIA_IN	= 0x01
-  IPT_INV_VIA_OUT	= 0x02
-  IPT_INV_TOS		= 0x04
-  IPT_INV_SRCIP		= 0x08
-  IPT_INV_DSTIP		= 0x10
-  IPT_INV_FRAG		= 0x20
-  IPT_INV_PROTO		= XT_INV_PROTO
-  IPT_INV_MASK		= 0x7f
-  
-  IPT_BASE_CTL			= 64
+  IPT_TABLE_MAXNAMELEN  = XT_TABLE_MAXNAMELEN
 
-  IPT_SO_SET_REPLACE		= IPT_BASE_CTL
-  IPT_SO_SET_ADD_COUNTERS	= IPT_BASE_CTL + 1
-  
-  IPT_SO_GET_INFO		= IPT_BASE_CTL
-  IPT_SO_GET_ENTRIES		= IPT_BASE_CTL + 1
-  IPT_SO_GET_REVISION_MATCH	= IPT_BASE_CTL + 2
-  IPT_SO_GET_REVISION_TARGET	= IPT_BASE_CTL + 3
-  
-  IPT_CONTINUE			= XT_CONTINUE
-  IPT_RETURN			= XT_RETURN
+  IPT_F_FRAG    = 0x01
+  IPT_F_GOTO    = 0x02
+  IPT_F_MASK    = 0x03
+
+  IPT_INV_VIA_IN  = 0x01
+  IPT_INV_VIA_OUT  = 0x02
+  IPT_INV_TOS    = 0x04
+  IPT_INV_SRCIP    = 0x08
+  IPT_INV_DSTIP    = 0x10
+  IPT_INV_FRAG    = 0x20
+  IPT_INV_PROTO    = XT_INV_PROTO
+  IPT_INV_MASK    = 0x7f
+
+  IPT_BASE_CTL      = 64
+
+  IPT_SO_SET_REPLACE    = IPT_BASE_CTL
+  IPT_SO_SET_ADD_COUNTERS  = IPT_BASE_CTL + 1
+
+  IPT_SO_GET_INFO    = IPT_BASE_CTL
+  IPT_SO_GET_ENTRIES    = IPT_BASE_CTL + 1
+  IPT_SO_GET_REVISION_MATCH  = IPT_BASE_CTL + 2
+  IPT_SO_GET_REVISION_TARGET  = IPT_BASE_CTL + 3
+
+  IPT_CONTINUE      = XT_CONTINUE
+  IPT_RETURN      = XT_RETURN
 end

lib/linux/netlink/message.rb

@@ -187,7 +187,7 @@ module Netlink
             warn "Duplicate attribute #{name} (#{code}): #{attrs[name].inspect} -> #{val.inspect}" if attrs[name]
             attrs[name] = val
           else
-            warn "Unknown attribute #{code}, in class #{self}, value #{val.inspect}"
+            warn "Unknown attribute #{code}, in class #{self}, value #{val.inspect}" if $DEBUG
             attrs[code] = val
           end
         end

lib/linux/netlink/nlsocket.rb

@@ -25,7 +25,7 @@ module Netlink
     # Check the sockaddr on a received message. Raises an error if the AF
     # is not AF_NETLINK or the PID is not 0 (this is important for security)
     def self.check_sockaddr(str)
-      af, pad, pid, groups = str.unpack(SOCKADDR_PACK)
+      af, _, pid, _ = str.unpack(SOCKADDR_PACK)
       raise "Bad AF #{af}!" if af != Socket::AF_NETLINK
       raise "Bad PID #{pid}!" if pid != 0
     end
@@ -58,14 +58,16 @@ module Netlink
     #   :timeout => N (seconds, default to DEFAULT_TIMEOUT. Pass nil for no timeout)
     #   :junk_handler => lambda { ... } for unexpected packets
     def initialize(opt)
-      @socket ||= opt[:socket] || ::Socket.new(
+      @socket = opt[:socket] || ::Socket.new(
         Socket::AF_NETLINK,
         Socket::SOCK_DGRAM,
         opt[:protocol] || (raise "Missing :protocol")
       )
       @socket.bind(NLSocket.sockaddr(opt)) unless opt[:socket]
       @seq = opt[:seq] || Time.now.to_i
-      @pid = opt[:pid] || $$
+
+      @pid = @socket.getsockname.unpack(SOCKADDR_PACK)[2]
+
       @timeout = opt.has_key?(:timeout) ? opt[:timeout] : DEFAULT_TIMEOUT
       if opt.has_key?(:junk_handler)
         @junk_handler = opt[:junk_handler]
@@ -75,7 +77,7 @@ module Netlink
         }
       end
     end
-    
+
     # Close the Netlink socket
     def close
       @socket.close
@@ -85,7 +87,7 @@ module Netlink
     def next_seq
       @seq = (@seq + 1) & 0xffffffff
     end
-    
+
     # Add a header and send a single message over the socket.
     #   type:: the message type code
     #   msg:: the message to send (without header)
@@ -135,8 +137,8 @@ module Netlink
     # (Compare: rtnl_talk in lib/libnetlink.c, with answer=NULL)
     def cmd(type, msg, flags=NLM_F_REQUEST, resp_type=NLMSG_ERROR, timeout=@timeout, sockaddr=SOCKADDR_DEFAULT)
       send_request(type, msg, flags|NLM_F_ACK, sockaddr)
-      receive_responses(true, timeout) do |type,msg|
-        return msg if type == resp_type
+      receive_responses(true, timeout) do |rtype,rmsg|
+        return rmsg if rtype == resp_type
         false
       end
     end
@@ -144,7 +146,7 @@ module Netlink
     # Discard all waiting messages
     def drain
       while select([@socket], nil, nil, 0)
-        mesg, sender, rflags, controls = @socket.recvmsg
+        mesg, _, _, _ = @socket.recvmsg
         raise EOFError unless mesg
       end
     end
@@ -203,13 +205,13 @@ module Netlink
         end
       end
     end
-    
+
     # Receive one datagram from kernel. Validates the sender, and returns
     # the raw binary message. Raises an exception on timeout or if the
     # kernel closes the socket.
     def recvmsg(timeout=@timeout)
       if select([@socket], nil, nil, timeout)
-        mesg, sender, rflags, controls = @socket.recvmsg
+        mesg, sender, _, _ = @socket.recvmsg
         raise EOFError unless mesg
         sender = sender.to_sockaddr if sender.respond_to? :to_sockaddr
         NLSocket.check_sockaddr(sender)

lib/linux/netlink/route/addr_handler.rb

@@ -24,6 +24,10 @@ module Netlink
         :pack   => lambda { |val,obj| val.to_a.pack("L*") },
         :unpack => lambda { |str,obj| IFACacheInfo.new(*(str.unpack("L*"))) }
     rtattr :multicast, IFA_MULTICAST, :l3addr
+
+    # TODO: is there any difference between flags and ifa_flags? The latter only
+    # shows up on newer kernels
+    rtattr :ifa_flags, IFA_FLAGS, :uint
   end
 
   module Route

lib/linux/netlink/route/link_handler.rb

@@ -65,6 +65,9 @@ module Netlink
     rtattr :net_ns_fd, IFLA_NET_NS_FD
     rtattr :ext_mask, IFLA_EXT_MASK   
     rtattr :promiscuity, IFLA_PROMISCUITY
+    rtattr :num_tx_queues, IFLA_NUM_TX_QUEUES
+    rtattr :num_rx_queues, IFLA_NUM_RX_QUEUES
+    rtattr :carrier, IFLA_CARRIER
  
     # Return the best stats available (64bit or 32bit)
     def stats
@@ -119,6 +122,7 @@ module Netlink
       :unpack => lambda { |str,obj| VlanFlags.parse(str) }
     rtattr :egress_qos, IFLA_VLAN_EGRESS_QOS
     rtattr :ingress_qos, IFLA_VLAN_INGRESS_QOS
+    rtattr :protocol, IFLA_VLAN_PROTOCOL, :ushort
   end
 
   module Route

lib/linux/netlink/route/vlan_handler.rb

@@ -8,12 +8,12 @@ module Netlink
       def clear_cache
         # No cache
       end
-      
+
       def list(filter={}, &blk)
         @rtsocket.link.list(filter.merge(:kind=>"vlan"))
       end
       alias :each :list
-            
+
       # Higher-level API to manipulate VLAN interface.
       #    nl.vlans.add(
       #      :link=>"lo",
@@ -24,15 +24,15 @@ module Netlink
       def add(opt)
         @rtsocket.link.add(vlan_options(opt))
       end
-      
+
       def change(opt)
         @rtsocket.link.change(vlan_options(opt))
       end
-      
+
       def replace(opt)
         @rtsocket.link.replace(vlan_options(opt))
       end
-      
+
       # Delete vlan given :link and :vlan_id. If you want to delete
       # by :index then call link.delete instead.
       def delete(opt)
@@ -59,6 +59,7 @@ module Netlink
         end
         li.data.egress_qos = opt.delete(:egress_qos) if opt.has_key?(:egress_qos)
         li.data.ingress_qos = opt.delete(:ingress_qos) if opt.has_key?(:ingress_qos)
+        li.data.protocol = opt.delete(:protocol) if opt.has_key?(:protocol)
         opt
       end
     end

netlinkrb.gemspec

@@ -5,9 +5,9 @@ $:.unshift lib unless $:.include? lib
 
 Gem::Specification.new do |s|
   s.name = "netlinkrb"
-  s.version = "0.11"
+  s.version = "0.18"
   s.platform = Gem::Platform::RUBY
-  s.authors = ["Brian Candler", "Patrick Cherry", "Alex Young"]
+  s.authors = ["Brian Candler", "Matthew Bloch", "Patrick Cherry", "Alex Young", "Nicholas Thomas"]
   s.email = ["matthew@bytemark.co.uk"]
   s.summary = "Interface to Linux' Netlink API"
   s.description = "Ruby native interface to the Netlink API which avoids shelling out to command-line tools as much as possible."

test/t_route.rb

@@ -1,10 +1,6 @@
-require File.join(File.dirname(__FILE__), 'test_helper')
+require File.expand_path( File.join(File.dirname(__FILE__), 'test_helper') )
 require 'linux/netlink/route'
 
-# Note: multiple sockets bound to the same PID seem to cause timeout problems.
-# (Should we use different algorithm for generating the PID? PID + seq?)
-$ip ||= Linux::Netlink::Route::Socket.new
-
 #
 # Ruby 1.8.7 appears to lack the KeyError constant.
 #
@@ -15,21 +11,62 @@ end
 class TestAddr < Test::Unit::TestCase
   context "With netlink route socket" do
     setup do
-      @ip = $ip
+      @ip =  Linux::Netlink::Route::Socket.new
+      @ifname = nil
     end
 
     teardown do
       begin
-        delete_test_interface
+        delete_test_interface(@ifname)
       rescue KeyError, IndexError
         # Do nothing
       end
+
+      @ip.close
     end
 
     test "Read link type" do
       assert_equal Linux::ARPHRD_LOOPBACK, @ip.link["lo"].type
     end
 
+    test "Both sockets work if two are open at the same time" do
+      begin
+        @ip2 = Linux::Netlink::Route::Socket.new
+
+        assert_kind_of Enumerable, @ip.route.list
+        assert_kind_of Enumerable, @ip2.route.list
+      ensure
+        @ip2.close
+      end
+    end
+
+    test "massively parallel IP address addition" do
+      @ifname = create_test_interface
+      return if @ifname.nil?
+      
+      link = @ip.link.list.find{|x| x.ifname == @ifname} 
+      return if link.nil?
+
+      ips = (10..13).map {|y| (1..254).map {|z| "10.100.#{y}.#{z}" } }.flatten.compact
+
+      threads = ips.map {|ip|
+        Thread.new {
+          Linux::Netlink::Route::Socket.new.addr.add(
+            :index => @ifname,
+            :local => ip,
+            :prefixlen => 8
+          )
+        }
+      }
+
+      threads.map{|t| t.join }
+
+      created = @ip.addr.list(:index => @ifname, :family => Socket::AF_INET).
+        map {|ifaddr| ifaddr.address.to_s }
+
+      ips.each {|ip| assert created.include?( ip ), "#{ip} was not created" }
+    end
+
     def create_test_interface(ifname = "test_#{$$}")
       begin
         @ip.link.add(
@@ -38,28 +75,29 @@ class TestAddr < Test::Unit::TestCase
             :kind => "dummy"
           )
         )
+      rescue Errno::EOPNOTSUPP
+        # Ugh, fall back to eth0
+        ifname = "eth0"
       rescue Errno::EPERM => err
-        if self.respond_to?(:skip)
-          skip err.to_s
-        else
-          puts "Skipping #{self.method_name} -- #{err.to_s}"
-          return nil
-        end
+        do_skip err.to_s
       end
 
       return ifname
     end
 
     def set_interface_up(ifname)
-        link = @ip.link.list.find{|l| l.ifname == ifname}
+      link = @ip.link.list.find{|l| l.ifname == ifname}
 
-        #
-        # Bring the link up
-        #
-        @ip.link.change(
-         :index => link.index,
-         :flags => link.flags | Linux::IFF_UP | Linux::IFF_RUNNING
-       )
+      return if link.nil?
+      return unless link.linkinfo and "dummy" == link.linkinfo.kind
+
+      #
+      # Bring the link up
+      #
+      @ip.link.change(
+        :index => link.index,
+        :flags => link.flags | Linux::IFF_UP | Linux::IFF_RUNNING
+      )
 
       link = @ip.link.list.find{|l| l.ifname == ifname}
 
@@ -71,6 +109,7 @@ class TestAddr < Test::Unit::TestCase
       link = @ip.link.list.find{|l| l.ifname == ifname}
 
       return if link.nil?
+      return unless link.linkinfo and "dummy" == link.linkinfo.kind
       return unless link.flags == (link.flags | Linux::IFF_UP | Linux::IFF_RUNNING)
 
       #
@@ -87,19 +126,39 @@ class TestAddr < Test::Unit::TestCase
       assert_equal(0, link.flags & Linux::IFF_RUNNING, "Link still has the IFF_RUNNING flag set") 
     end
 
-    def delete_test_interface(ifname = "test_#{$$}")
+    def delete_test_interface(ifname) 
+      unless @ip.link[ifname] and @ip.link[ifname].linkinfo and "dummy" == @ip.link[ifname].linkinfo.kind
+        return nil
+      end
+
       begin
         set_interface_down(ifname)
       ensure
         @ip.link.delete(:index => ifname)
       end
     end
-      
-    test "Add and remove dummy interface" do
-      ifname = create_test_interface
-      return if ifname.nil?
 
-      delete_test_interface(ifname)
+    def do_skip(msg)
+      if self.respond_to?(:skip)
+        skip msg
+      else
+        puts "Skipping #{self.method_name} -- #{msg}"
+      end
+      return nil
+    end
+
+    test "Add and remove dummy interface" do
+      @ifname = create_test_interface
+      return if @ifname.nil?
+      
+      link = @ip.link.list.find{|x| x.ifname == @ifname} 
+      return if link.nil?
+
+      unless link.linkinfo and "dummy" == link.linkinfo.kind
+        return do_skip("Could not create dummy interface")
+      end
+
+      delete_test_interface(@ifname)
     end
     
     def addrlist(opt = {:index=>"lo"})
@@ -107,23 +166,26 @@ class TestAddr < Test::Unit::TestCase
     end
 
     def add_and_remove_addr(testaddr, pfx)
-      ifname = create_test_interface
-      return if ifname.nil?
+      @ifname = create_test_interface
+      return if @ifname.nil?
 
-      addrs1 = addrlist({:index => ifname})
+      link = @ip.link.list.find{|x| x.ifname == @ifname} 
+      return if link.nil?
+      
+      addrs1 = addrlist({:index => @ifname})
       assert !addrs1.include?(testaddr)
 
-      @ip.addr.add(:index=>ifname, :local=>testaddr, :prefixlen=>pfx)
+      @ip.addr.add(:index=>@ifname, :local=>testaddr, :prefixlen=>pfx)
       assert_raises(Errno::EEXIST) {
-        @ip.addr.add(:index=>ifname, :local=>testaddr, :prefixlen=>pfx)
+        @ip.addr.add(:index=>@ifname, :local=>testaddr, :prefixlen=>pfx)
       }
 
-      addrs2 = addrlist({:index => ifname})
+      addrs2 = addrlist({:index => @ifname})
       assert addrs2.include?(testaddr), "#{addrs2.inspect} doesn't include #{testaddr}"
       
-      @ip.addr.delete(:index=>ifname, :local=>testaddr, :prefixlen=>pfx)
+      @ip.addr.delete(:index=>@ifname, :local=>testaddr, :prefixlen=>pfx)
       
-      addrs3 = addrlist({:index => ifname})
+      addrs3 = addrlist({:index => @ifname})
       assert_equal addrs1, addrs3
     end
 
@@ -158,22 +220,24 @@ class TestAddr < Test::Unit::TestCase
     end
   
     test "Add and remove vlan" do
-      ifname = create_test_interface
-      return if ifname.nil?
+      @ifname = create_test_interface
+      return if @ifname.nil?
 
-      vlans1 = vlanlist(ifname)
+      link = @ip.link.list.find{|x| x.ifname == @ifname}
+      return if link.nil?
+
+      vlans1 = vlanlist(@ifname)
       assert !vlans1.include?(1234)
 
-      @ip.vlan.add(:link=>ifname, :vlan_id=>1234)
+      @ip.vlan.add(:link=>@ifname, :vlan_id=>1234)
 
-      vlans2 = vlanlist(ifname)
+      vlans2 = vlanlist(@ifname)
       assert vlans2.include?(1234)
 
-      @ip.vlan.delete(:link=>ifname, :vlan_id=>1234)
+      @ip.vlan.delete(:link=>@ifname, :vlan_id=>1234)
 
-      vlans3 = vlanlist(ifname)
+      vlans3 = vlanlist(@ifname)
       assert_equal vlans1, vlans3
-      @ip.link.delete(:index => ifname)
     end
 
     def routes
@@ -191,13 +255,17 @@ class TestAddr < Test::Unit::TestCase
     end
     
     def add_and_remove_route(info)
-      ifname = create_test_interface
-      return if ifname.nil?
+      @ifname = create_test_interface
+      return if @ifname.nil?
 
-      set_interface_up(ifname) 
+      set_interface_up(@ifname) 
 
-      info[:oif] = ifname
-      ifidx = @ip.link.list.find{|x| x.ifname == info[:oif]}.index
+      info[:oif] = @ifname
+
+      link = @ip.link.list.find{|x| x.ifname == info[:oif]}
+      return if link.nil?
+
+      ifidx = link.index
 
       assert_equal 0, routes.select { |x| x == [info[:dst], info[:dst_len], ifidx] }.size