Compare commits

..

7 Commits

Author SHA1 Message Date
Patrick J Cherry
d4eeb977ce New upstream release 2013-09-12 14:28:35 +01:00
Patrick J Cherry
c0263e83d0 merge 2013-07-16 16:52:27 +01:00
Patrick J Cherry
2251b116ce merge 2013-07-16 16:45:29 +01:00
Patrick J Cherry
e27f54116e Foo 2013-07-16 16:28:40 +01:00
Patrick J Cherry
7195d7b24e arse 2013-07-16 16:36:19 +01:00
Patrick J Cherry
eeb55fa103 Added tag 0.11-1+squeeze1 for changeset 6993fdccebef 2013-07-05 14:02:25 +01:00
Patrick J Cherry
9c7e3a1a96 Updated hgignore for squeeze packages 2013-07-05 13:59:40 +01:00
18 changed files with 125 additions and 282 deletions

View File

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

54
debian/changelog vendored
View File

@@ -1,58 +1,14 @@
ruby-linux-netlink (0.17-1+stretch1) testing; urgency=medium linux-netlink-ruby (0.12-1+squeeze1) oldstable; urgency=low
* Repackaged for stretch.
-- Patrick J Cherry <patrick@bytemark.co.uk> Tue, 10 Nov 2015 13:39:37 +0000
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. * New upstream release.
-- Patrick J Cherry <patch@dynamo> Tue, 26 Aug 2014 16:33:48 +0100 -- Patrick J Cherry <patrick@bytemark.co.uk> Thu, 12 Sep 2013 14:28:10 +0100
ruby-linux-netlink (0.15-1+wheezy1) stable; urgency=low linux-netlink-ruby (0.11-1+squeeze1) oldstable; urgency=low
* New upstream release. * New upstream version.
-- Patrick J Cherry <patrick@bytemark.co.uk> Tue, 21 Jan 2014 10:01:20 +0000 -- Patrick J Cherry <patrick@bytemark.co.uk> Fri, 05 Jul 2013 13:52:09 +0100
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 14:16:05 +0100
linux-netlink-ruby (0.10-6) stable; urgency=low linux-netlink-ruby (0.10-6) stable; urgency=low

37
debian/control vendored
View File

@@ -1,18 +1,39 @@
Source: ruby-linux-netlink Source: linux-netlink-ruby
Maintainer: Matthew Bloch <matthew@bytemark.co.uk> Maintainer: Matthew Bloch <matthew@bytemark.co.uk>
Uploaders: Patrick J Cherry <patrick@bytemark.co.uk> Uploaders: Patrick J Cherry <patrick@bytemark.co.uk>
Section: ruby Section: ruby
Priority: optional Priority: optional
Build-Depends: debhelper (>= 7), gem2deb, rake, ruby-ffi Build-Depends: debhelper (>= 7), cdbs, ruby1.8, ruby1.9.1, ruby-pkg-tools, rake
Standards-Version: 3.8.0 Standards-Version: 3.8.0
XS-Ruby-Versions: all
Package: ruby-linux-netlink Package: liblinux-netlink-ruby
Architecture: any Architecture: all
Depends: ruby | ruby-interpreter, ruby-ffi, ${misc:Depends} Depends: liblinux-netlink-ruby1.8 | liblinux-netlink-ruby1.9.1, ${misc:Depends}
Provides: liblinux-netlink-ruby1.8, liblinux-netlink-ruby1.9.1
XB-Ruby-Versions: ${ruby:Versions}
Description: Netlink socket library for Ruby Description: Netlink socket library for Ruby
This library provides an API for using a Linux Netlink socket, for doing This library provides an API for using a Linux Netlink socket, for doing
things like manipulating IP interfaces and routes programmatically, and things like manipulating IP interfaces and routes programmatically, and
capturing packets from ULOG. capturing packets from ULOG.
.
This is the metapackage for all versions of Ruby.
Package: liblinux-netlink-ruby1.8
Architecture: any
Depends: ruby1.8 (>= 1.8.7), libffi-ruby1.8, ${misc:Depends}
Description: Netlink socket library for Ruby 1.8
This library provides an API for using a Linux Netlink socket, for doing
things like manipulating IP interfaces and routes programmatically, and
capturing packets from ULOG.
.
This is the version for Ruby 1.8.7.
Package: liblinux-netlink-ruby1.9.1
Architecture: any
Depends: ruby1.9.1, libffi-ruby1.9.1, ${misc:Depends}
Description: Netlink socket library for Ruby 1.9.1
This library provides an API for using a Linux Netlink socket, for doing
things like manipulating IP interfaces and routes programmatically, and
capturing packets from ULOG.
.
This is the version for Ruby 1.9.1.

View File

@@ -0,0 +1 @@
examples/*

View File

@@ -1,32 +0,0 @@
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

View File

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

View File

@@ -1,2 +0,0 @@
---
- test/t_route.rb

20
debian/rules vendored
View File

@@ -1,23 +1,11 @@
#!/usr/bin/make -f #!/usr/bin/make -f
# #
# export DH_VERBOSE=1
#
# Uncomment to ignore all test failures (but the tests will run anyway)
# export DH_RUBY_IGNORE_TESTS=all
#
# Uncomment to ignore some test failures (but the tests will run anyway).
# Valid values:
# export DH_RUBY_IGNORE_TESTS=ruby1.8 ruby1.9.1 require-rubygems
#
# If you need to specify the .gemspec (eg there is more than one)
# export DH_RUBY_GEMSPEC=gem.gemspec
%: include /usr/share/cdbs/1/rules/debhelper.mk
dh $@ --buildsystem=ruby --with ruby include /usr/share/ruby-pkg-tools/1/class/ruby-setup-rb.mk
override_dh_auto_build-arch: makebuilddir::
rake lib/linux/c_struct_sizeof_size_t.rb rake lib/linux/c_struct_sizeof_size_t.rb
override_dh_auto_clean: clean::
rake clean rake clean

View File

@@ -1 +0,0 @@
3.0 (quilt)

View File

@@ -58,8 +58,6 @@ module Linux
NETLINK_PKTINFO = 3 NETLINK_PKTINFO = 3
NETLINK_BROADCAST_ERROR = 4 NETLINK_BROADCAST_ERROR = 4
NETLINK_NO_ENOBUFS = 5 NETLINK_NO_ENOBUFS = 5
NETLINK_RX_RING = 6
NETLINK_TX_RING = 7
NETLINK_UNCONNECTED = 0 NETLINK_UNCONNECTED = 0
NETLINK_CONNECTED = 1 NETLINK_CONNECTED = 1
@@ -125,15 +123,6 @@ module Linux
RTM_GETDCB = 78 RTM_GETDCB = 78
RTM_SETDCB = 79 RTM_SETDCB = 79
RTM_NEWNETCONF = 80
RTM_GETNETCONF = 82
RTM_NEWMDB = 84
RTM_DELMDB = 85
RTM_GETMDB = 86
# RT#type # RT#type
RTN_UNSPEC = 0 RTN_UNSPEC = 0
RTN_UNICAST = 1 RTN_UNICAST = 1
@@ -163,7 +152,6 @@ module Linux
RTPROT_XORP = 14 RTPROT_XORP = 14
RTPROT_NTK = 15 RTPROT_NTK = 15
RTPROT_DHCP = 16 RTPROT_DHCP = 16
RTPROT_MROUTED = 17
# RT#scope, IFAddr#scope # RT#scope, IFAddr#scope
RT_SCOPE_UNIVERSE = 0 RT_SCOPE_UNIVERSE = 0
@@ -200,12 +188,6 @@ module Linux
RTA_CACHEINFO = 12 RTA_CACHEINFO = 12
RTA_TABLE = 15 RTA_TABLE = 15
RTA_MARK = 16 RTA_MARK = 16
RTA_MFC_STATS = 17
# 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
# Keys for RT#metrics # Keys for RT#metrics
RTAX_UNSPEC = 0 RTAX_UNSPEC = 0
@@ -223,7 +205,6 @@ module Linux
RTAX_FEATURES = 12 RTAX_FEATURES = 12
RTAX_RTO_MIN = 13 RTAX_RTO_MIN = 13
RTAX_INITRWND = 14 RTAX_INITRWND = 14
RTAX_QUICKACK = 15
# from linux/if_link.h # from linux/if_link.h
IFLA_UNSPEC = 0 IFLA_UNSPEC = 0
@@ -260,21 +241,6 @@ module Linux
IFLA_NUM_TX_QUEUES = 31 IFLA_NUM_TX_QUEUES = 31
IFLA_NUM_RX_QUEUES = 32 IFLA_NUM_RX_QUEUES = 32
IFLA_CARRIER = 33 IFLA_CARRIER = 33
IFLA_PHYS_PORT_ID = 34
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_INFO_UNSPEC = 0 IFLA_INFO_UNSPEC = 0
IFLA_INFO_KIND = 1 # "vlan", "gre" etc IFLA_INFO_KIND = 1 # "vlan", "gre" etc
@@ -287,27 +253,22 @@ module Linux
IFLA_VLAN_FLAGS = 2 # struct ifla_vlan_flags IFLA_VLAN_FLAGS = 2 # struct ifla_vlan_flags
IFLA_VLAN_EGRESS_QOS = 3 # followed by instance of IFLA_VLAN_QOS_* 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_INGRESS_QOS = 4 # followed by instance of IFLA_VLAN_QOS_*
IFLA_VLAN_PROTOCOL = 5
IFLA_VLAN_QOS_UNSPEC = 0 IFLA_VLAN_QOS_UNSPEC = 0
IFLA_VLAN_QOS_MAPPING = 1 IFLA_VLAN_QOS_MAPPING = 1
IFLA_MACVLAN_UNSPEC = 0 IFLA_MACVLAN_UNSPEC = 0
IFLA_MACVLAN_MODE = 1 IFLA_MACVLAN_MODE = 1
IFLA_MACVLAN_FLAGS = 2
MACVLAN_MODE_PRIVATE = 1 MACVLAN_MODE_PRIVATE = 1
MACVLAN_MODE_VEPA = 2 MACVLAN_MODE_VEPA = 2
MACVLAN_MODE_BRIDGE = 4 MACVLAN_MODE_BRIDGE = 4
MACVLAN_MODE_PASSTHRU = 8 MACVLAN_MODE_PASSTHRU = 8
# TODO: VXLAN and VF stuff is missing here
# linux/if_vlan.h # linux/if_vlan.h
VLAN_FLAG_REORDER_HDR = 0x1 VLAN_FLAG_REORDER_HDR = 0x1
VLAN_FLAG_GVRP = 0x2 VLAN_FLAG_GVRP = 0x2
VLAN_FLAG_LOOSE_BINDING = 0x4 VLAN_FLAG_LOOSE_BINDING = 0x4
VLAN_FLAG_MVRP = 0x8
# from linux/if_addr.h # from linux/if_addr.h
IFA_UNSPEC = 0 IFA_UNSPEC = 0
@@ -318,7 +279,6 @@ module Linux
IFA_ANYCAST = 5 IFA_ANYCAST = 5
IFA_CACHEINFO = 6 IFA_CACHEINFO = 6
IFA_MULTICAST = 7 IFA_MULTICAST = 7
IFA_FLAGS = 8
IFA_F_SECONDARY = 0x01 IFA_F_SECONDARY = 0x01
IFA_F_TEMPORARY = IFA_F_SECONDARY IFA_F_TEMPORARY = IFA_F_SECONDARY
@@ -329,10 +289,8 @@ module Linux
IFA_F_DEPRECATED = 0x20 IFA_F_DEPRECATED = 0x20
IFA_F_TENTATIVE = 0x40 IFA_F_TENTATIVE = 0x40
IFA_F_PERMANENT = 0x80 IFA_F_PERMANENT = 0x80
IFA_F_MANAGETEMPADDR = 0x100
IFA_F_NOPREFIXROUTE = 0x200
# from linux/if_arp.h - selected subset # from linux/if_arp.h
ARPHRD_NETROM = 0 ARPHRD_NETROM = 0
ARPHRD_ETHER = 1 ARPHRD_ETHER = 1
ARPHRD_EETHER = 2 ARPHRD_EETHER = 2

View File

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

View File

@@ -25,7 +25,7 @@ module Netlink
# Check the sockaddr on a received message. Raises an error if the AF # 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) # is not AF_NETLINK or the PID is not 0 (this is important for security)
def self.check_sockaddr(str) def self.check_sockaddr(str)
af, _, pid, _ = str.unpack(SOCKADDR_PACK) af, pad, pid, groups = str.unpack(SOCKADDR_PACK)
raise "Bad AF #{af}!" if af != Socket::AF_NETLINK raise "Bad AF #{af}!" if af != Socket::AF_NETLINK
raise "Bad PID #{pid}!" if pid != 0 raise "Bad PID #{pid}!" if pid != 0
end end
@@ -58,16 +58,14 @@ module Netlink
# :timeout => N (seconds, default to DEFAULT_TIMEOUT. Pass nil for no timeout) # :timeout => N (seconds, default to DEFAULT_TIMEOUT. Pass nil for no timeout)
# :junk_handler => lambda { ... } for unexpected packets # :junk_handler => lambda { ... } for unexpected packets
def initialize(opt) def initialize(opt)
@socket = opt[:socket] || ::Socket.new( @socket ||= opt[:socket] || ::Socket.new(
Socket::AF_NETLINK, Socket::AF_NETLINK,
Socket::SOCK_DGRAM, Socket::SOCK_DGRAM,
opt[:protocol] || (raise "Missing :protocol") opt[:protocol] || (raise "Missing :protocol")
) )
@socket.bind(NLSocket.sockaddr(opt)) unless opt[:socket] @socket.bind(NLSocket.sockaddr(opt)) unless opt[:socket]
@seq = opt[:seq] || Time.now.to_i @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 @timeout = opt.has_key?(:timeout) ? opt[:timeout] : DEFAULT_TIMEOUT
if opt.has_key?(:junk_handler) if opt.has_key?(:junk_handler)
@junk_handler = opt[:junk_handler] @junk_handler = opt[:junk_handler]
@@ -137,8 +135,8 @@ module Netlink
# (Compare: rtnl_talk in lib/libnetlink.c, with answer=NULL) # (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) 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) send_request(type, msg, flags|NLM_F_ACK, sockaddr)
receive_responses(true, timeout) do |rtype,rmsg| receive_responses(true, timeout) do |type,msg|
return rmsg if rtype == resp_type return msg if type == resp_type
false false
end end
end end
@@ -146,7 +144,7 @@ module Netlink
# Discard all waiting messages # Discard all waiting messages
def drain def drain
while select([@socket], nil, nil, 0) while select([@socket], nil, nil, 0)
mesg, _, _, _ = @socket.recvmsg mesg, sender, rflags, controls = @socket.recvmsg
raise EOFError unless mesg raise EOFError unless mesg
end end
end end
@@ -211,7 +209,7 @@ module Netlink
# kernel closes the socket. # kernel closes the socket.
def recvmsg(timeout=@timeout) def recvmsg(timeout=@timeout)
if select([@socket], nil, nil, timeout) if select([@socket], nil, nil, timeout)
mesg, sender, _, _ = @socket.recvmsg mesg, sender, rflags, controls = @socket.recvmsg
raise EOFError unless mesg raise EOFError unless mesg
sender = sender.to_sockaddr if sender.respond_to? :to_sockaddr sender = sender.to_sockaddr if sender.respond_to? :to_sockaddr
NLSocket.check_sockaddr(sender) NLSocket.check_sockaddr(sender)

View File

@@ -24,10 +24,6 @@ module Netlink
:pack => lambda { |val,obj| val.to_a.pack("L*") }, :pack => lambda { |val,obj| val.to_a.pack("L*") },
:unpack => lambda { |str,obj| IFACacheInfo.new(*(str.unpack("L*"))) } :unpack => lambda { |str,obj| IFACacheInfo.new(*(str.unpack("L*"))) }
rtattr :multicast, IFA_MULTICAST, :l3addr 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 end
module Route module Route

View File

@@ -122,7 +122,6 @@ module Netlink
:unpack => lambda { |str,obj| VlanFlags.parse(str) } :unpack => lambda { |str,obj| VlanFlags.parse(str) }
rtattr :egress_qos, IFLA_VLAN_EGRESS_QOS rtattr :egress_qos, IFLA_VLAN_EGRESS_QOS
rtattr :ingress_qos, IFLA_VLAN_INGRESS_QOS rtattr :ingress_qos, IFLA_VLAN_INGRESS_QOS
rtattr :protocol, IFLA_VLAN_PROTOCOL, :ushort
end end
module Route module Route

View File

@@ -59,7 +59,6 @@ module Netlink
end end
li.data.egress_qos = opt.delete(:egress_qos) if opt.has_key?(:egress_qos) 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.ingress_qos = opt.delete(:ingress_qos) if opt.has_key?(:ingress_qos)
li.data.protocol = opt.delete(:protocol) if opt.has_key?(:protocol)
opt opt
end end
end end

View File

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

View File

@@ -1,6 +1,10 @@
require File.expand_path( File.join(File.dirname(__FILE__), 'test_helper') ) require File.join(File.dirname(__FILE__), 'test_helper')
require 'linux/netlink/route' 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. # Ruby 1.8.7 appears to lack the KeyError constant.
# #
@@ -11,7 +15,7 @@ end
class TestAddr < Test::Unit::TestCase class TestAddr < Test::Unit::TestCase
context "With netlink route socket" do context "With netlink route socket" do
setup do setup do
@ip = Linux::Netlink::Route::Socket.new @ip = $ip
@ifname = nil @ifname = nil
end end
@@ -21,52 +25,12 @@ class TestAddr < Test::Unit::TestCase
rescue KeyError, IndexError rescue KeyError, IndexError
# Do nothing # Do nothing
end end
@ip.close
end end
test "Read link type" do test "Read link type" do
assert_equal Linux::ARPHRD_LOOPBACK, @ip.link["lo"].type assert_equal Linux::ARPHRD_LOOPBACK, @ip.link["lo"].type
end 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_#{$$}") def create_test_interface(ifname = "test_#{$$}")
begin begin
@ip.link.add( @ip.link.add(