Compare commits
8 Commits
0.12-1+whe
...
0.15
Author | SHA1 | Date | |
---|---|---|---|
![]() |
6cbda4bb58 | ||
![]() |
e0aae9c67c | ||
![]() |
e96601981b | ||
![]() |
8bbb45af33 | ||
![]() |
d86d0c8408 | ||
![]() |
0281a5e4eb | ||
![]() |
84c0414550 | ||
![]() |
610a70fe12 |
@@ -58,6 +58,8 @@ module Linux
|
||||
NETLINK_PKTINFO = 3
|
||||
NETLINK_BROADCAST_ERROR = 4
|
||||
NETLINK_NO_ENOBUFS = 5
|
||||
NETLINK_RX_RING = 6
|
||||
NETLINK_TX_RING = 7
|
||||
|
||||
NETLINK_UNCONNECTED = 0
|
||||
NETLINK_CONNECTED = 1
|
||||
@@ -123,6 +125,15 @@ module Linux
|
||||
RTM_GETDCB = 78
|
||||
RTM_SETDCB = 79
|
||||
|
||||
|
||||
RTM_NEWNETCONF = 80
|
||||
RTM_GETNETCONF = 82
|
||||
|
||||
RTM_NEWMDB = 84
|
||||
RTM_DELMDB = 85
|
||||
RTM_GETMDB = 86
|
||||
|
||||
|
||||
# RT#type
|
||||
RTN_UNSPEC = 0
|
||||
RTN_UNICAST = 1
|
||||
@@ -152,6 +163,7 @@ module Linux
|
||||
RTPROT_XORP = 14
|
||||
RTPROT_NTK = 15
|
||||
RTPROT_DHCP = 16
|
||||
RTPROT_MROUTED = 17
|
||||
|
||||
# RT#scope, IFAddr#scope
|
||||
RT_SCOPE_UNIVERSE = 0
|
||||
@@ -188,6 +200,12 @@ module Linux
|
||||
RTA_CACHEINFO = 12
|
||||
RTA_TABLE = 15
|
||||
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
|
||||
RTAX_UNSPEC = 0
|
||||
@@ -205,6 +223,7 @@ module Linux
|
||||
RTAX_FEATURES = 12
|
||||
RTAX_RTO_MIN = 13
|
||||
RTAX_INITRWND = 14
|
||||
RTAX_QUICKACK = 15
|
||||
|
||||
# from linux/if_link.h
|
||||
IFLA_UNSPEC = 0
|
||||
@@ -236,11 +255,26 @@ module Linux
|
||||
IFLA_AF_SPEC = 26
|
||||
IFLA_GROUP = 27
|
||||
IFLA_NET_NS_FD = 28
|
||||
IFLA_EXT_MASK = 29
|
||||
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
|
||||
|
||||
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_KIND = 1 # "vlan", "gre" etc
|
||||
@@ -253,22 +287,27 @@ module Linux
|
||||
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_VLAN_QOS_MAPPING = 1
|
||||
|
||||
IFLA_MACVLAN_UNSPEC = 0
|
||||
IFLA_MACVLAN_MODE = 1
|
||||
IFLA_MACVLAN_FLAGS = 2
|
||||
|
||||
MACVLAN_MODE_PRIVATE = 1
|
||||
MACVLAN_MODE_VEPA = 2
|
||||
MACVLAN_MODE_BRIDGE = 4
|
||||
MACVLAN_MODE_PASSTHRU = 8
|
||||
|
||||
# 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_MVRP = 0x8
|
||||
|
||||
# from linux/if_addr.h
|
||||
IFA_UNSPEC = 0
|
||||
@@ -290,7 +329,7 @@ module Linux
|
||||
IFA_F_TENTATIVE = 0x40
|
||||
IFA_F_PERMANENT = 0x80
|
||||
|
||||
# from linux/if_arp.h
|
||||
# from linux/if_arp.h - selected subset
|
||||
ARPHRD_NETROM = 0
|
||||
ARPHRD_ETHER = 1
|
||||
ARPHRD_EETHER = 2
|
||||
|
@@ -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
|
||||
@@ -135,8 +135,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 +144,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
|
||||
@@ -209,7 +209,7 @@ module Netlink
|
||||
# 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)
|
||||
|
@@ -122,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
|
||||
|
@@ -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
|
||||
|
Reference in New Issue
Block a user