|
@@ -12,6 +12,13 @@ import (
|
|
|
"github.com/vishvananda/netlink/nl"
|
|
|
)
|
|
|
|
|
|
+const SizeofLinkStats = 0x5c
|
|
|
+
|
|
|
+const (
|
|
|
+ TUNTAP_MODE_TUN TuntapMode = syscall.IFF_TUN
|
|
|
+ TUNTAP_MODE_TAP TuntapMode = syscall.IFF_TAP
|
|
|
+)
|
|
|
+
|
|
|
var native = nl.NativeEndian()
|
|
|
var lookupByDump = false
|
|
|
|
|
@@ -33,12 +40,27 @@ func ensureIndex(link *LinkAttrs) {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+func (h *Handle) ensureIndex(link *LinkAttrs) {
|
|
|
+ if link != nil && link.Index == 0 {
|
|
|
+ newlink, _ := h.LinkByName(link.Name)
|
|
|
+ if newlink != nil {
|
|
|
+ link.Index = newlink.Attrs().Index
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
// LinkSetUp enables the link device.
|
|
|
// Equivalent to: `ip link set $link up`
|
|
|
func LinkSetUp(link Link) error {
|
|
|
+ return pkgHandle.LinkSetUp(link)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetUp enables the link device.
|
|
|
+// Equivalent to: `ip link set $link up`
|
|
|
+func (h *Handle) LinkSetUp(link Link) error {
|
|
|
base := link.Attrs()
|
|
|
- ensureIndex(base)
|
|
|
- req := nl.NewNetlinkRequest(syscall.RTM_NEWLINK, syscall.NLM_F_ACK)
|
|
|
+ h.ensureIndex(base)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_NEWLINK, syscall.NLM_F_ACK)
|
|
|
|
|
|
msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
msg.Change = syscall.IFF_UP
|
|
@@ -53,9 +75,15 @@ func LinkSetUp(link Link) error {
|
|
|
// LinkSetDown disables link device.
|
|
|
// Equivalent to: `ip link set $link down`
|
|
|
func LinkSetDown(link Link) error {
|
|
|
+ return pkgHandle.LinkSetDown(link)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetDown disables link device.
|
|
|
+// Equivalent to: `ip link set $link down`
|
|
|
+func (h *Handle) LinkSetDown(link Link) error {
|
|
|
base := link.Attrs()
|
|
|
- ensureIndex(base)
|
|
|
- req := nl.NewNetlinkRequest(syscall.RTM_NEWLINK, syscall.NLM_F_ACK)
|
|
|
+ h.ensureIndex(base)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_NEWLINK, syscall.NLM_F_ACK)
|
|
|
|
|
|
msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
msg.Change = syscall.IFF_UP
|
|
@@ -70,9 +98,15 @@ func LinkSetDown(link Link) error {
|
|
|
// LinkSetMTU sets the mtu of the link device.
|
|
|
// Equivalent to: `ip link set $link mtu $mtu`
|
|
|
func LinkSetMTU(link Link, mtu int) error {
|
|
|
+ return pkgHandle.LinkSetMTU(link, mtu)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetMTU sets the mtu of the link device.
|
|
|
+// Equivalent to: `ip link set $link mtu $mtu`
|
|
|
+func (h *Handle) LinkSetMTU(link Link, mtu int) error {
|
|
|
base := link.Attrs()
|
|
|
- ensureIndex(base)
|
|
|
- req := nl.NewNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
+ h.ensureIndex(base)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
|
|
|
msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
msg.Index = int32(base.Index)
|
|
@@ -91,9 +125,15 @@ func LinkSetMTU(link Link, mtu int) error {
|
|
|
// LinkSetName sets the name of the link device.
|
|
|
// Equivalent to: `ip link set $link name $name`
|
|
|
func LinkSetName(link Link, name string) error {
|
|
|
+ return pkgHandle.LinkSetName(link, name)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetName sets the name of the link device.
|
|
|
+// Equivalent to: `ip link set $link name $name`
|
|
|
+func (h *Handle) LinkSetName(link Link, name string) error {
|
|
|
base := link.Attrs()
|
|
|
- ensureIndex(base)
|
|
|
- req := nl.NewNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
+ h.ensureIndex(base)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
|
|
|
msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
msg.Index = int32(base.Index)
|
|
@@ -106,12 +146,42 @@ func LinkSetName(link Link, name string) error {
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
+// LinkSetAlias sets the alias of the link device.
|
|
|
+// Equivalent to: `ip link set dev $link alias $name`
|
|
|
+func LinkSetAlias(link Link, name string) error {
|
|
|
+ return pkgHandle.LinkSetAlias(link, name)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetAlias sets the alias of the link device.
|
|
|
+// Equivalent to: `ip link set dev $link alias $name`
|
|
|
+func (h *Handle) LinkSetAlias(link Link, name string) error {
|
|
|
+ base := link.Attrs()
|
|
|
+ h.ensureIndex(base)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
+
|
|
|
+ msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
+ msg.Index = int32(base.Index)
|
|
|
+ req.AddData(msg)
|
|
|
+
|
|
|
+ data := nl.NewRtAttr(syscall.IFLA_IFALIAS, []byte(name))
|
|
|
+ req.AddData(data)
|
|
|
+
|
|
|
+ _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
// LinkSetHardwareAddr sets the hardware address of the link device.
|
|
|
// Equivalent to: `ip link set $link address $hwaddr`
|
|
|
func LinkSetHardwareAddr(link Link, hwaddr net.HardwareAddr) error {
|
|
|
+ return pkgHandle.LinkSetHardwareAddr(link, hwaddr)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetHardwareAddr sets the hardware address of the link device.
|
|
|
+// Equivalent to: `ip link set $link address $hwaddr`
|
|
|
+func (h *Handle) LinkSetHardwareAddr(link Link, hwaddr net.HardwareAddr) error {
|
|
|
base := link.Attrs()
|
|
|
- ensureIndex(base)
|
|
|
- req := nl.NewNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
+ h.ensureIndex(base)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
|
|
|
msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
msg.Index = int32(base.Index)
|
|
@@ -124,24 +194,111 @@ func LinkSetHardwareAddr(link Link, hwaddr net.HardwareAddr) error {
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
+// LinkSetVfHardwareAddr sets the hardware address of a vf for the link.
|
|
|
+// Equivalent to: `ip link set $link vf $vf mac $hwaddr`
|
|
|
+func LinkSetVfHardwareAddr(link Link, vf int, hwaddr net.HardwareAddr) error {
|
|
|
+ return pkgHandle.LinkSetVfHardwareAddr(link, vf, hwaddr)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetVfHardwareAddr sets the hardware address of a vf for the link.
|
|
|
+// Equivalent to: `ip link set $link vf $vf mac $hwaddr`
|
|
|
+func (h *Handle) LinkSetVfHardwareAddr(link Link, vf int, hwaddr net.HardwareAddr) error {
|
|
|
+ base := link.Attrs()
|
|
|
+ h.ensureIndex(base)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
+
|
|
|
+ msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
+ msg.Index = int32(base.Index)
|
|
|
+ req.AddData(msg)
|
|
|
+
|
|
|
+ data := nl.NewRtAttr(nl.IFLA_VFINFO_LIST, nil)
|
|
|
+ info := nl.NewRtAttrChild(data, nl.IFLA_VF_INFO, nil)
|
|
|
+ vfmsg := nl.VfMac{
|
|
|
+ Vf: uint32(vf),
|
|
|
+ }
|
|
|
+ copy(vfmsg.Mac[:], []byte(hwaddr))
|
|
|
+ nl.NewRtAttrChild(info, nl.IFLA_VF_MAC, vfmsg.Serialize())
|
|
|
+ req.AddData(data)
|
|
|
+
|
|
|
+ _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetVfVlan sets the vlan of a vf for the link.
|
|
|
+// Equivalent to: `ip link set $link vf $vf vlan $vlan`
|
|
|
+func LinkSetVfVlan(link Link, vf, vlan int) error {
|
|
|
+ return pkgHandle.LinkSetVfVlan(link, vf, vlan)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetVfVlan sets the vlan of a vf for the link.
|
|
|
+// Equivalent to: `ip link set $link vf $vf vlan $vlan`
|
|
|
+func (h *Handle) LinkSetVfVlan(link Link, vf, vlan int) error {
|
|
|
+ base := link.Attrs()
|
|
|
+ h.ensureIndex(base)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
+
|
|
|
+ msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
+ msg.Index = int32(base.Index)
|
|
|
+ req.AddData(msg)
|
|
|
+
|
|
|
+ data := nl.NewRtAttr(nl.IFLA_VFINFO_LIST, nil)
|
|
|
+ info := nl.NewRtAttrChild(data, nl.IFLA_VF_INFO, nil)
|
|
|
+ vfmsg := nl.VfVlan{
|
|
|
+ Vf: uint32(vf),
|
|
|
+ Vlan: uint32(vlan),
|
|
|
+ }
|
|
|
+ nl.NewRtAttrChild(info, nl.IFLA_VF_VLAN, vfmsg.Serialize())
|
|
|
+ req.AddData(data)
|
|
|
+
|
|
|
+ _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
// LinkSetMaster sets the master of the link device.
|
|
|
// Equivalent to: `ip link set $link master $master`
|
|
|
func LinkSetMaster(link Link, master *Bridge) error {
|
|
|
+ return pkgHandle.LinkSetMaster(link, master)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetMaster sets the master of the link device.
|
|
|
+// Equivalent to: `ip link set $link master $master`
|
|
|
+func (h *Handle) LinkSetMaster(link Link, master *Bridge) error {
|
|
|
index := 0
|
|
|
if master != nil {
|
|
|
masterBase := master.Attrs()
|
|
|
- ensureIndex(masterBase)
|
|
|
+ h.ensureIndex(masterBase)
|
|
|
index = masterBase.Index
|
|
|
}
|
|
|
- return LinkSetMasterByIndex(link, index)
|
|
|
+ if index <= 0 {
|
|
|
+ return fmt.Errorf("Device does not exist")
|
|
|
+ }
|
|
|
+ return h.LinkSetMasterByIndex(link, index)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetNoMaster removes the master of the link device.
|
|
|
+// Equivalent to: `ip link set $link nomaster`
|
|
|
+func LinkSetNoMaster(link Link) error {
|
|
|
+ return pkgHandle.LinkSetNoMaster(link)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetNoMaster removes the master of the link device.
|
|
|
+// Equivalent to: `ip link set $link nomaster`
|
|
|
+func (h *Handle) LinkSetNoMaster(link Link) error {
|
|
|
+ return h.LinkSetMasterByIndex(link, 0)
|
|
|
}
|
|
|
|
|
|
// LinkSetMasterByIndex sets the master of the link device.
|
|
|
// Equivalent to: `ip link set $link master $master`
|
|
|
func LinkSetMasterByIndex(link Link, masterIndex int) error {
|
|
|
+ return pkgHandle.LinkSetMasterByIndex(link, masterIndex)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetMasterByIndex sets the master of the link device.
|
|
|
+// Equivalent to: `ip link set $link master $master`
|
|
|
+func (h *Handle) LinkSetMasterByIndex(link Link, masterIndex int) error {
|
|
|
base := link.Attrs()
|
|
|
- ensureIndex(base)
|
|
|
- req := nl.NewNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
+ h.ensureIndex(base)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
|
|
|
msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
msg.Index = int32(base.Index)
|
|
@@ -161,9 +318,16 @@ func LinkSetMasterByIndex(link Link, masterIndex int) error {
|
|
|
// pid must be a pid of a running process.
|
|
|
// Equivalent to: `ip link set $link netns $pid`
|
|
|
func LinkSetNsPid(link Link, nspid int) error {
|
|
|
+ return pkgHandle.LinkSetNsPid(link, nspid)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetNsPid puts the device into a new network namespace. The
|
|
|
+// pid must be a pid of a running process.
|
|
|
+// Equivalent to: `ip link set $link netns $pid`
|
|
|
+func (h *Handle) LinkSetNsPid(link Link, nspid int) error {
|
|
|
base := link.Attrs()
|
|
|
- ensureIndex(base)
|
|
|
- req := nl.NewNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
+ h.ensureIndex(base)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
|
|
|
msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
msg.Index = int32(base.Index)
|
|
@@ -183,9 +347,16 @@ func LinkSetNsPid(link Link, nspid int) error {
|
|
|
// fd must be an open file descriptor to a network namespace.
|
|
|
// Similar to: `ip link set $link netns $ns`
|
|
|
func LinkSetNsFd(link Link, fd int) error {
|
|
|
+ return pkgHandle.LinkSetNsFd(link, fd)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkSetNsFd puts the device into a new network namespace. The
|
|
|
+// fd must be an open file descriptor to a network namespace.
|
|
|
+// Similar to: `ip link set $link netns $ns`
|
|
|
+func (h *Handle) LinkSetNsFd(link Link, fd int) error {
|
|
|
base := link.Attrs()
|
|
|
- ensureIndex(base)
|
|
|
- req := nl.NewNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
+ h.ensureIndex(base)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
|
|
|
msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
msg.Index = int32(base.Index)
|
|
@@ -250,10 +421,12 @@ func addVxlanAttrs(vxlan *Vxlan, linkInfo *nl.RtAttr) {
|
|
|
nl.NewRtAttrChild(data, nl.IFLA_VXLAN_L2MISS, boolAttr(vxlan.L2miss))
|
|
|
nl.NewRtAttrChild(data, nl.IFLA_VXLAN_L3MISS, boolAttr(vxlan.L3miss))
|
|
|
|
|
|
+ if vxlan.UDPCSum {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_VXLAN_UDP_CSUM, boolAttr(vxlan.UDPCSum))
|
|
|
+ }
|
|
|
if vxlan.GBP {
|
|
|
nl.NewRtAttrChild(data, nl.IFLA_VXLAN_GBP, boolAttr(vxlan.GBP))
|
|
|
}
|
|
|
-
|
|
|
if vxlan.NoAge {
|
|
|
nl.NewRtAttrChild(data, nl.IFLA_VXLAN_AGEING, nl.Uint32Attr(0))
|
|
|
} else if vxlan.Age > 0 {
|
|
@@ -263,7 +436,7 @@ func addVxlanAttrs(vxlan *Vxlan, linkInfo *nl.RtAttr) {
|
|
|
nl.NewRtAttrChild(data, nl.IFLA_VXLAN_LIMIT, nl.Uint32Attr(uint32(vxlan.Limit)))
|
|
|
}
|
|
|
if vxlan.Port > 0 {
|
|
|
- nl.NewRtAttrChild(data, nl.IFLA_VXLAN_PORT, nl.Uint16Attr(uint16(vxlan.Port)))
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_VXLAN_PORT, htons(uint16(vxlan.Port)))
|
|
|
}
|
|
|
if vxlan.PortLow > 0 || vxlan.PortHigh > 0 {
|
|
|
pr := vxlanPortRange{uint16(vxlan.PortLow), uint16(vxlan.PortHigh)}
|
|
@@ -275,10 +448,98 @@ func addVxlanAttrs(vxlan *Vxlan, linkInfo *nl.RtAttr) {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+func addBondAttrs(bond *Bond, linkInfo *nl.RtAttr) {
|
|
|
+ data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
|
|
|
+ if bond.Mode >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_MODE, nl.Uint8Attr(uint8(bond.Mode)))
|
|
|
+ }
|
|
|
+ if bond.ActiveSlave >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_ACTIVE_SLAVE, nl.Uint32Attr(uint32(bond.ActiveSlave)))
|
|
|
+ }
|
|
|
+ if bond.Miimon >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_MIIMON, nl.Uint32Attr(uint32(bond.Miimon)))
|
|
|
+ }
|
|
|
+ if bond.UpDelay >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_UPDELAY, nl.Uint32Attr(uint32(bond.UpDelay)))
|
|
|
+ }
|
|
|
+ if bond.DownDelay >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_DOWNDELAY, nl.Uint32Attr(uint32(bond.DownDelay)))
|
|
|
+ }
|
|
|
+ if bond.UseCarrier >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_USE_CARRIER, nl.Uint8Attr(uint8(bond.UseCarrier)))
|
|
|
+ }
|
|
|
+ if bond.ArpInterval >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_ARP_INTERVAL, nl.Uint32Attr(uint32(bond.ArpInterval)))
|
|
|
+ }
|
|
|
+ if bond.ArpIpTargets != nil {
|
|
|
+ msg := nl.NewRtAttrChild(data, nl.IFLA_BOND_ARP_IP_TARGET, nil)
|
|
|
+ for i := range bond.ArpIpTargets {
|
|
|
+ ip := bond.ArpIpTargets[i].To4()
|
|
|
+ if ip != nil {
|
|
|
+ nl.NewRtAttrChild(msg, i, []byte(ip))
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ ip = bond.ArpIpTargets[i].To16()
|
|
|
+ if ip != nil {
|
|
|
+ nl.NewRtAttrChild(msg, i, []byte(ip))
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if bond.ArpValidate >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_ARP_VALIDATE, nl.Uint32Attr(uint32(bond.ArpValidate)))
|
|
|
+ }
|
|
|
+ if bond.ArpAllTargets >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_ARP_ALL_TARGETS, nl.Uint32Attr(uint32(bond.ArpAllTargets)))
|
|
|
+ }
|
|
|
+ if bond.Primary >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_PRIMARY, nl.Uint32Attr(uint32(bond.Primary)))
|
|
|
+ }
|
|
|
+ if bond.PrimaryReselect >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_PRIMARY_RESELECT, nl.Uint8Attr(uint8(bond.PrimaryReselect)))
|
|
|
+ }
|
|
|
+ if bond.FailOverMac >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_FAIL_OVER_MAC, nl.Uint8Attr(uint8(bond.FailOverMac)))
|
|
|
+ }
|
|
|
+ if bond.XmitHashPolicy >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_XMIT_HASH_POLICY, nl.Uint8Attr(uint8(bond.XmitHashPolicy)))
|
|
|
+ }
|
|
|
+ if bond.ResendIgmp >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_RESEND_IGMP, nl.Uint32Attr(uint32(bond.ResendIgmp)))
|
|
|
+ }
|
|
|
+ if bond.NumPeerNotif >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_NUM_PEER_NOTIF, nl.Uint8Attr(uint8(bond.NumPeerNotif)))
|
|
|
+ }
|
|
|
+ if bond.AllSlavesActive >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_ALL_SLAVES_ACTIVE, nl.Uint8Attr(uint8(bond.AllSlavesActive)))
|
|
|
+ }
|
|
|
+ if bond.MinLinks >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_MIN_LINKS, nl.Uint32Attr(uint32(bond.MinLinks)))
|
|
|
+ }
|
|
|
+ if bond.LpInterval >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_LP_INTERVAL, nl.Uint32Attr(uint32(bond.LpInterval)))
|
|
|
+ }
|
|
|
+ if bond.PackersPerSlave >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_PACKETS_PER_SLAVE, nl.Uint32Attr(uint32(bond.PackersPerSlave)))
|
|
|
+ }
|
|
|
+ if bond.LacpRate >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_AD_LACP_RATE, nl.Uint8Attr(uint8(bond.LacpRate)))
|
|
|
+ }
|
|
|
+ if bond.AdSelect >= 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_BOND_AD_SELECT, nl.Uint8Attr(uint8(bond.AdSelect)))
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
// LinkAdd adds a new link device. The type and features of the device
|
|
|
-// are taken fromt the parameters in the link object.
|
|
|
+// are taken from the parameters in the link object.
|
|
|
// Equivalent to: `ip link add $link`
|
|
|
func LinkAdd(link Link) error {
|
|
|
+ return pkgHandle.LinkAdd(link)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkAdd adds a new link device. The type and features of the device
|
|
|
+// are taken fromt the parameters in the link object.
|
|
|
+// Equivalent to: `ip link add $link`
|
|
|
+func (h *Handle) LinkAdd(link Link) error {
|
|
|
// TODO: set mtu and hardware address
|
|
|
// TODO: support extra data for macvlan
|
|
|
base := link.Attrs()
|
|
@@ -315,19 +576,40 @@ func LinkAdd(link Link) error {
|
|
|
if errno != 0 {
|
|
|
return fmt.Errorf("Tuntap IOCTL TUNSETPERSIST failed, errno %v", errno)
|
|
|
}
|
|
|
- ensureIndex(base)
|
|
|
+ h.ensureIndex(base)
|
|
|
|
|
|
// can't set master during create, so set it afterwards
|
|
|
if base.MasterIndex != 0 {
|
|
|
// TODO: verify MasterIndex is actually a bridge?
|
|
|
- return LinkSetMasterByIndex(link, base.MasterIndex)
|
|
|
+ return h.LinkSetMasterByIndex(link, base.MasterIndex)
|
|
|
}
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
- req := nl.NewNetlinkRequest(syscall.RTM_NEWLINK, syscall.NLM_F_CREATE|syscall.NLM_F_EXCL|syscall.NLM_F_ACK)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_NEWLINK, syscall.NLM_F_CREATE|syscall.NLM_F_EXCL|syscall.NLM_F_ACK)
|
|
|
|
|
|
msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
+ // TODO: make it shorter
|
|
|
+ if base.Flags&net.FlagUp != 0 {
|
|
|
+ msg.Change = syscall.IFF_UP
|
|
|
+ msg.Flags = syscall.IFF_UP
|
|
|
+ }
|
|
|
+ if base.Flags&net.FlagBroadcast != 0 {
|
|
|
+ msg.Change |= syscall.IFF_BROADCAST
|
|
|
+ msg.Flags |= syscall.IFF_BROADCAST
|
|
|
+ }
|
|
|
+ if base.Flags&net.FlagLoopback != 0 {
|
|
|
+ msg.Change |= syscall.IFF_LOOPBACK
|
|
|
+ msg.Flags |= syscall.IFF_LOOPBACK
|
|
|
+ }
|
|
|
+ if base.Flags&net.FlagPointToPoint != 0 {
|
|
|
+ msg.Change |= syscall.IFF_POINTOPOINT
|
|
|
+ msg.Flags |= syscall.IFF_POINTOPOINT
|
|
|
+ }
|
|
|
+ if base.Flags&net.FlagMulticast != 0 {
|
|
|
+ msg.Change |= syscall.IFF_MULTICAST
|
|
|
+ msg.Flags |= syscall.IFF_MULTICAST
|
|
|
+ }
|
|
|
req.AddData(msg)
|
|
|
|
|
|
if base.ParentIndex != 0 {
|
|
@@ -388,6 +670,8 @@ func LinkAdd(link Link) error {
|
|
|
|
|
|
} else if vxlan, ok := link.(*Vxlan); ok {
|
|
|
addVxlanAttrs(vxlan, linkInfo)
|
|
|
+ } else if bond, ok := link.(*Bond); ok {
|
|
|
+ addBondAttrs(bond, linkInfo)
|
|
|
} else if ipv, ok := link.(*IPVlan); ok {
|
|
|
data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
|
|
|
nl.NewRtAttrChild(data, nl.IFLA_IPVLAN_MODE, nl.Uint16Attr(uint16(ipv.Mode)))
|
|
@@ -396,6 +680,13 @@ func LinkAdd(link Link) error {
|
|
|
data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
|
|
|
nl.NewRtAttrChild(data, nl.IFLA_MACVLAN_MODE, nl.Uint32Attr(macvlanModes[macv.Mode]))
|
|
|
}
|
|
|
+ } else if macv, ok := link.(*Macvtap); ok {
|
|
|
+ if macv.Mode != MACVLAN_MODE_DEFAULT {
|
|
|
+ data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_MACVLAN_MODE, nl.Uint32Attr(macvlanModes[macv.Mode]))
|
|
|
+ }
|
|
|
+ } else if gretap, ok := link.(*Gretap); ok {
|
|
|
+ addGretapAttrs(gretap, linkInfo)
|
|
|
}
|
|
|
|
|
|
req.AddData(linkInfo)
|
|
@@ -405,12 +696,12 @@ func LinkAdd(link Link) error {
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
- ensureIndex(base)
|
|
|
+ h.ensureIndex(base)
|
|
|
|
|
|
// can't set master during create, so set it afterwards
|
|
|
if base.MasterIndex != 0 {
|
|
|
// TODO: verify MasterIndex is actually a bridge?
|
|
|
- return LinkSetMasterByIndex(link, base.MasterIndex)
|
|
|
+ return h.LinkSetMasterByIndex(link, base.MasterIndex)
|
|
|
}
|
|
|
return nil
|
|
|
}
|
|
@@ -419,11 +710,18 @@ func LinkAdd(link Link) error {
|
|
|
// the link object for it to be deleted. The other values are ignored.
|
|
|
// Equivalent to: `ip link del $link`
|
|
|
func LinkDel(link Link) error {
|
|
|
+ return pkgHandle.LinkDel(link)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkDel deletes link device. Either Index or Name must be set in
|
|
|
+// the link object for it to be deleted. The other values are ignored.
|
|
|
+// Equivalent to: `ip link del $link`
|
|
|
+func (h *Handle) LinkDel(link Link) error {
|
|
|
base := link.Attrs()
|
|
|
|
|
|
- ensureIndex(base)
|
|
|
+ h.ensureIndex(base)
|
|
|
|
|
|
- req := nl.NewNetlinkRequest(syscall.RTM_DELLINK, syscall.NLM_F_ACK)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_DELLINK, syscall.NLM_F_ACK)
|
|
|
|
|
|
msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
msg.Index = int32(base.Index)
|
|
@@ -433,8 +731,8 @@ func LinkDel(link Link) error {
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
-func linkByNameDump(name string) (Link, error) {
|
|
|
- links, err := LinkList()
|
|
|
+func (h *Handle) linkByNameDump(name string) (Link, error) {
|
|
|
+ links, err := h.LinkList()
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
@@ -447,13 +745,32 @@ func linkByNameDump(name string) (Link, error) {
|
|
|
return nil, fmt.Errorf("Link %s not found", name)
|
|
|
}
|
|
|
|
|
|
+func (h *Handle) linkByAliasDump(alias string) (Link, error) {
|
|
|
+ links, err := h.LinkList()
|
|
|
+ if err != nil {
|
|
|
+ return nil, err
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, link := range links {
|
|
|
+ if link.Attrs().Alias == alias {
|
|
|
+ return link, nil
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return nil, fmt.Errorf("Link alias %s not found", alias)
|
|
|
+}
|
|
|
+
|
|
|
// LinkByName finds a link by name and returns a pointer to the object.
|
|
|
func LinkByName(name string) (Link, error) {
|
|
|
- if lookupByDump {
|
|
|
- return linkByNameDump(name)
|
|
|
+ return pkgHandle.LinkByName(name)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkByName finds a link by name and returns a pointer to the object.
|
|
|
+func (h *Handle) LinkByName(name string) (Link, error) {
|
|
|
+ if h.lookupByDump {
|
|
|
+ return h.linkByNameDump(name)
|
|
|
}
|
|
|
|
|
|
- req := nl.NewNetlinkRequest(syscall.RTM_GETLINK, syscall.NLM_F_ACK)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_GETLINK, syscall.NLM_F_ACK)
|
|
|
|
|
|
msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
req.AddData(msg)
|
|
@@ -465,8 +782,40 @@ func LinkByName(name string) (Link, error) {
|
|
|
if err == syscall.EINVAL {
|
|
|
// older kernels don't support looking up via IFLA_IFNAME
|
|
|
// so fall back to dumping all links
|
|
|
- lookupByDump = true
|
|
|
- return linkByNameDump(name)
|
|
|
+ h.lookupByDump = true
|
|
|
+ return h.linkByNameDump(name)
|
|
|
+ }
|
|
|
+
|
|
|
+ return link, err
|
|
|
+}
|
|
|
+
|
|
|
+// LinkByAlias finds a link by its alias and returns a pointer to the object.
|
|
|
+// If there are multiple links with the alias it returns the first one
|
|
|
+func LinkByAlias(alias string) (Link, error) {
|
|
|
+ return pkgHandle.LinkByAlias(alias)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkByAlias finds a link by its alias and returns a pointer to the object.
|
|
|
+// If there are multiple links with the alias it returns the first one
|
|
|
+func (h *Handle) LinkByAlias(alias string) (Link, error) {
|
|
|
+ if h.lookupByDump {
|
|
|
+ return h.linkByAliasDump(alias)
|
|
|
+ }
|
|
|
+
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_GETLINK, syscall.NLM_F_ACK)
|
|
|
+
|
|
|
+ msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
+ req.AddData(msg)
|
|
|
+
|
|
|
+ nameData := nl.NewRtAttr(syscall.IFLA_IFALIAS, nl.ZeroTerminated(alias))
|
|
|
+ req.AddData(nameData)
|
|
|
+
|
|
|
+ link, err := execGetLink(req)
|
|
|
+ if err == syscall.EINVAL {
|
|
|
+ // older kernels don't support looking up via IFLA_IFALIAS
|
|
|
+ // so fall back to dumping all links
|
|
|
+ h.lookupByDump = true
|
|
|
+ return h.linkByAliasDump(alias)
|
|
|
}
|
|
|
|
|
|
return link, err
|
|
@@ -474,7 +823,12 @@ func LinkByName(name string) (Link, error) {
|
|
|
|
|
|
// LinkByIndex finds a link by index and returns a pointer to the object.
|
|
|
func LinkByIndex(index int) (Link, error) {
|
|
|
- req := nl.NewNetlinkRequest(syscall.RTM_GETLINK, syscall.NLM_F_ACK)
|
|
|
+ return pkgHandle.LinkByIndex(index)
|
|
|
+}
|
|
|
+
|
|
|
+// LinkByIndex finds a link by index and returns a pointer to the object.
|
|
|
+func (h *Handle) LinkByIndex(index int) (Link, error) {
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_GETLINK, syscall.NLM_F_ACK)
|
|
|
|
|
|
msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
msg.Index = int32(index)
|
|
@@ -543,12 +897,16 @@ func linkDeserialize(m []byte) (Link, error) {
|
|
|
link = &Veth{}
|
|
|
case "vxlan":
|
|
|
link = &Vxlan{}
|
|
|
+ case "bond":
|
|
|
+ link = &Bond{}
|
|
|
case "ipvlan":
|
|
|
link = &IPVlan{}
|
|
|
case "macvlan":
|
|
|
link = &Macvlan{}
|
|
|
case "macvtap":
|
|
|
link = &Macvtap{}
|
|
|
+ case "gretap":
|
|
|
+ link = &Gretap{}
|
|
|
default:
|
|
|
link = &GenericLink{LinkType: linkType}
|
|
|
}
|
|
@@ -562,12 +920,16 @@ func linkDeserialize(m []byte) (Link, error) {
|
|
|
parseVlanData(link, data)
|
|
|
case "vxlan":
|
|
|
parseVxlanData(link, data)
|
|
|
+ case "bond":
|
|
|
+ parseBondData(link, data)
|
|
|
case "ipvlan":
|
|
|
parseIPVlanData(link, data)
|
|
|
case "macvlan":
|
|
|
parseMacvlanData(link, data)
|
|
|
case "macvtap":
|
|
|
parseMacvtapData(link, data)
|
|
|
+ case "gretap":
|
|
|
+ parseGretapData(link, data)
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -591,6 +953,10 @@ func linkDeserialize(m []byte) (Link, error) {
|
|
|
base.MasterIndex = int(native.Uint32(attr.Value[0:4]))
|
|
|
case syscall.IFLA_TXQLEN:
|
|
|
base.TxQLen = int(native.Uint32(attr.Value[0:4]))
|
|
|
+ case syscall.IFLA_IFALIAS:
|
|
|
+ base.Alias = string(attr.Value[:len(attr.Value)-1])
|
|
|
+ case syscall.IFLA_STATS:
|
|
|
+ base.Statistics = parseLinkStats(attr.Value[:])
|
|
|
}
|
|
|
}
|
|
|
// Links that don't have IFLA_INFO_KIND are hardware devices
|
|
@@ -605,9 +971,15 @@ func linkDeserialize(m []byte) (Link, error) {
|
|
|
// LinkList gets a list of link devices.
|
|
|
// Equivalent to: `ip link show`
|
|
|
func LinkList() ([]Link, error) {
|
|
|
+ return pkgHandle.LinkList()
|
|
|
+}
|
|
|
+
|
|
|
+// LinkList gets a list of link devices.
|
|
|
+// Equivalent to: `ip link show`
|
|
|
+func (h *Handle) LinkList() ([]Link, error) {
|
|
|
// NOTE(vish): This duplicates functionality in net/iface_linux.go, but we need
|
|
|
// to get the message ourselves to parse link type.
|
|
|
- req := nl.NewNetlinkRequest(syscall.RTM_GETLINK, syscall.NLM_F_DUMP)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_GETLINK, syscall.NLM_F_DUMP)
|
|
|
|
|
|
msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
|
|
|
req.AddData(msg)
|
|
@@ -632,6 +1004,7 @@ func LinkList() ([]Link, error) {
|
|
|
// LinkUpdate is used to pass information back from LinkSubscribe()
|
|
|
type LinkUpdate struct {
|
|
|
nl.IfInfomsg
|
|
|
+ Header syscall.NlMsghdr
|
|
|
Link
|
|
|
}
|
|
|
|
|
@@ -661,7 +1034,7 @@ func LinkSubscribe(ch chan<- LinkUpdate, done <-chan struct{}) error {
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
- ch <- LinkUpdate{IfInfomsg: *ifmsg, Link: link}
|
|
|
+ ch <- LinkUpdate{IfInfomsg: *ifmsg, Header: m.Header, Link: link}
|
|
|
}
|
|
|
}
|
|
|
}()
|
|
@@ -670,33 +1043,57 @@ func LinkSubscribe(ch chan<- LinkUpdate, done <-chan struct{}) error {
|
|
|
}
|
|
|
|
|
|
func LinkSetHairpin(link Link, mode bool) error {
|
|
|
- return setProtinfoAttr(link, mode, nl.IFLA_BRPORT_MODE)
|
|
|
+ return pkgHandle.LinkSetHairpin(link, mode)
|
|
|
+}
|
|
|
+
|
|
|
+func (h *Handle) LinkSetHairpin(link Link, mode bool) error {
|
|
|
+ return h.setProtinfoAttr(link, mode, nl.IFLA_BRPORT_MODE)
|
|
|
}
|
|
|
|
|
|
func LinkSetGuard(link Link, mode bool) error {
|
|
|
- return setProtinfoAttr(link, mode, nl.IFLA_BRPORT_GUARD)
|
|
|
+ return pkgHandle.LinkSetGuard(link, mode)
|
|
|
+}
|
|
|
+
|
|
|
+func (h *Handle) LinkSetGuard(link Link, mode bool) error {
|
|
|
+ return h.setProtinfoAttr(link, mode, nl.IFLA_BRPORT_GUARD)
|
|
|
}
|
|
|
|
|
|
func LinkSetFastLeave(link Link, mode bool) error {
|
|
|
- return setProtinfoAttr(link, mode, nl.IFLA_BRPORT_FAST_LEAVE)
|
|
|
+ return pkgHandle.LinkSetFastLeave(link, mode)
|
|
|
+}
|
|
|
+
|
|
|
+func (h *Handle) LinkSetFastLeave(link Link, mode bool) error {
|
|
|
+ return h.setProtinfoAttr(link, mode, nl.IFLA_BRPORT_FAST_LEAVE)
|
|
|
}
|
|
|
|
|
|
func LinkSetLearning(link Link, mode bool) error {
|
|
|
- return setProtinfoAttr(link, mode, nl.IFLA_BRPORT_LEARNING)
|
|
|
+ return pkgHandle.LinkSetLearning(link, mode)
|
|
|
+}
|
|
|
+
|
|
|
+func (h *Handle) LinkSetLearning(link Link, mode bool) error {
|
|
|
+ return h.setProtinfoAttr(link, mode, nl.IFLA_BRPORT_LEARNING)
|
|
|
}
|
|
|
|
|
|
func LinkSetRootBlock(link Link, mode bool) error {
|
|
|
- return setProtinfoAttr(link, mode, nl.IFLA_BRPORT_PROTECT)
|
|
|
+ return pkgHandle.LinkSetRootBlock(link, mode)
|
|
|
+}
|
|
|
+
|
|
|
+func (h *Handle) LinkSetRootBlock(link Link, mode bool) error {
|
|
|
+ return h.setProtinfoAttr(link, mode, nl.IFLA_BRPORT_PROTECT)
|
|
|
}
|
|
|
|
|
|
func LinkSetFlood(link Link, mode bool) error {
|
|
|
- return setProtinfoAttr(link, mode, nl.IFLA_BRPORT_UNICAST_FLOOD)
|
|
|
+ return pkgHandle.LinkSetFlood(link, mode)
|
|
|
}
|
|
|
|
|
|
-func setProtinfoAttr(link Link, mode bool, attr int) error {
|
|
|
+func (h *Handle) LinkSetFlood(link Link, mode bool) error {
|
|
|
+ return h.setProtinfoAttr(link, mode, nl.IFLA_BRPORT_UNICAST_FLOOD)
|
|
|
+}
|
|
|
+
|
|
|
+func (h *Handle) setProtinfoAttr(link Link, mode bool, attr int) error {
|
|
|
base := link.Attrs()
|
|
|
- ensureIndex(base)
|
|
|
- req := nl.NewNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
+ h.ensureIndex(base)
|
|
|
+ req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
|
|
|
|
|
|
msg := nl.NewIfInfomsg(syscall.AF_BRIDGE)
|
|
|
msg.Index = int32(base.Index)
|
|
@@ -752,6 +1149,8 @@ func parseVxlanData(link Link, data []syscall.NetlinkRouteAttr) {
|
|
|
vxlan.L2miss = int8(datum.Value[0]) != 0
|
|
|
case nl.IFLA_VXLAN_L3MISS:
|
|
|
vxlan.L3miss = int8(datum.Value[0]) != 0
|
|
|
+ case nl.IFLA_VXLAN_UDP_CSUM:
|
|
|
+ vxlan.UDPCSum = int8(datum.Value[0]) != 0
|
|
|
case nl.IFLA_VXLAN_GBP:
|
|
|
vxlan.GBP = int8(datum.Value[0]) != 0
|
|
|
case nl.IFLA_VXLAN_AGEING:
|
|
@@ -760,7 +1159,7 @@ func parseVxlanData(link Link, data []syscall.NetlinkRouteAttr) {
|
|
|
case nl.IFLA_VXLAN_LIMIT:
|
|
|
vxlan.Limit = int(native.Uint32(datum.Value[0:4]))
|
|
|
case nl.IFLA_VXLAN_PORT:
|
|
|
- vxlan.Port = int(native.Uint16(datum.Value[0:2]))
|
|
|
+ vxlan.Port = int(ntohs(datum.Value[0:2]))
|
|
|
case nl.IFLA_VXLAN_PORT_RANGE:
|
|
|
buf := bytes.NewBuffer(datum.Value[0:4])
|
|
|
var pr vxlanPortRange
|
|
@@ -772,6 +1171,60 @@ func parseVxlanData(link Link, data []syscall.NetlinkRouteAttr) {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+func parseBondData(link Link, data []syscall.NetlinkRouteAttr) {
|
|
|
+ bond := NewLinkBond(NewLinkAttrs())
|
|
|
+ for i := range data {
|
|
|
+ switch data[i].Attr.Type {
|
|
|
+ case nl.IFLA_BOND_MODE:
|
|
|
+ bond.Mode = BondMode(data[i].Value[0])
|
|
|
+ case nl.IFLA_BOND_ACTIVE_SLAVE:
|
|
|
+ bond.ActiveSlave = int(native.Uint32(data[i].Value[0:4]))
|
|
|
+ case nl.IFLA_BOND_MIIMON:
|
|
|
+ bond.Miimon = int(native.Uint32(data[i].Value[0:4]))
|
|
|
+ case nl.IFLA_BOND_UPDELAY:
|
|
|
+ bond.UpDelay = int(native.Uint32(data[i].Value[0:4]))
|
|
|
+ case nl.IFLA_BOND_DOWNDELAY:
|
|
|
+ bond.DownDelay = int(native.Uint32(data[i].Value[0:4]))
|
|
|
+ case nl.IFLA_BOND_USE_CARRIER:
|
|
|
+ bond.UseCarrier = int(data[i].Value[0])
|
|
|
+ case nl.IFLA_BOND_ARP_INTERVAL:
|
|
|
+ bond.ArpInterval = int(native.Uint32(data[i].Value[0:4]))
|
|
|
+ case nl.IFLA_BOND_ARP_IP_TARGET:
|
|
|
+ // TODO: implement
|
|
|
+ case nl.IFLA_BOND_ARP_VALIDATE:
|
|
|
+ bond.ArpValidate = BondArpValidate(native.Uint32(data[i].Value[0:4]))
|
|
|
+ case nl.IFLA_BOND_ARP_ALL_TARGETS:
|
|
|
+ bond.ArpAllTargets = BondArpAllTargets(native.Uint32(data[i].Value[0:4]))
|
|
|
+ case nl.IFLA_BOND_PRIMARY:
|
|
|
+ bond.Primary = int(native.Uint32(data[i].Value[0:4]))
|
|
|
+ case nl.IFLA_BOND_PRIMARY_RESELECT:
|
|
|
+ bond.PrimaryReselect = BondPrimaryReselect(data[i].Value[0])
|
|
|
+ case nl.IFLA_BOND_FAIL_OVER_MAC:
|
|
|
+ bond.FailOverMac = BondFailOverMac(data[i].Value[0])
|
|
|
+ case nl.IFLA_BOND_XMIT_HASH_POLICY:
|
|
|
+ bond.XmitHashPolicy = BondXmitHashPolicy(data[i].Value[0])
|
|
|
+ case nl.IFLA_BOND_RESEND_IGMP:
|
|
|
+ bond.ResendIgmp = int(native.Uint32(data[i].Value[0:4]))
|
|
|
+ case nl.IFLA_BOND_NUM_PEER_NOTIF:
|
|
|
+ bond.NumPeerNotif = int(data[i].Value[0])
|
|
|
+ case nl.IFLA_BOND_ALL_SLAVES_ACTIVE:
|
|
|
+ bond.AllSlavesActive = int(data[i].Value[0])
|
|
|
+ case nl.IFLA_BOND_MIN_LINKS:
|
|
|
+ bond.MinLinks = int(native.Uint32(data[i].Value[0:4]))
|
|
|
+ case nl.IFLA_BOND_LP_INTERVAL:
|
|
|
+ bond.LpInterval = int(native.Uint32(data[i].Value[0:4]))
|
|
|
+ case nl.IFLA_BOND_PACKETS_PER_SLAVE:
|
|
|
+ bond.PackersPerSlave = int(native.Uint32(data[i].Value[0:4]))
|
|
|
+ case nl.IFLA_BOND_AD_LACP_RATE:
|
|
|
+ bond.LacpRate = BondLacpRate(data[i].Value[0])
|
|
|
+ case nl.IFLA_BOND_AD_SELECT:
|
|
|
+ bond.AdSelect = BondAdSelect(data[i].Value[0])
|
|
|
+ case nl.IFLA_BOND_AD_INFO:
|
|
|
+ // TODO: implement
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
func parseIPVlanData(link Link, data []syscall.NetlinkRouteAttr) {
|
|
|
ipv := link.(*IPVlan)
|
|
|
for _, datum := range data {
|
|
@@ -828,3 +1281,100 @@ func linkFlags(rawFlags uint32) net.Flags {
|
|
|
}
|
|
|
return f
|
|
|
}
|
|
|
+
|
|
|
+func htonl(val uint32) []byte {
|
|
|
+ bytes := make([]byte, 4)
|
|
|
+ binary.BigEndian.PutUint32(bytes, val)
|
|
|
+ return bytes
|
|
|
+}
|
|
|
+
|
|
|
+func htons(val uint16) []byte {
|
|
|
+ bytes := make([]byte, 2)
|
|
|
+ binary.BigEndian.PutUint16(bytes, val)
|
|
|
+ return bytes
|
|
|
+}
|
|
|
+
|
|
|
+func ntohl(buf []byte) uint32 {
|
|
|
+ return binary.BigEndian.Uint32(buf)
|
|
|
+}
|
|
|
+
|
|
|
+func ntohs(buf []byte) uint16 {
|
|
|
+ return binary.BigEndian.Uint16(buf)
|
|
|
+}
|
|
|
+
|
|
|
+func addGretapAttrs(gretap *Gretap, linkInfo *nl.RtAttr) {
|
|
|
+ data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
|
|
|
+
|
|
|
+ ip := gretap.Local.To4()
|
|
|
+ if ip != nil {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_GRE_LOCAL, []byte(ip))
|
|
|
+ }
|
|
|
+ ip = gretap.Remote.To4()
|
|
|
+ if ip != nil {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_GRE_REMOTE, []byte(ip))
|
|
|
+ }
|
|
|
+
|
|
|
+ if gretap.IKey != 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_GRE_IKEY, htonl(gretap.IKey))
|
|
|
+ gretap.IFlags |= uint16(nl.GRE_KEY)
|
|
|
+ }
|
|
|
+
|
|
|
+ if gretap.OKey != 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_GRE_OKEY, htonl(gretap.OKey))
|
|
|
+ gretap.OFlags |= uint16(nl.GRE_KEY)
|
|
|
+ }
|
|
|
+
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_GRE_IFLAGS, htons(gretap.IFlags))
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_GRE_OFLAGS, htons(gretap.OFlags))
|
|
|
+
|
|
|
+ if gretap.Link != 0 {
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_GRE_LINK, nl.Uint32Attr(gretap.Link))
|
|
|
+ }
|
|
|
+
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_GRE_PMTUDISC, nl.Uint8Attr(gretap.PMtuDisc))
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_GRE_TTL, nl.Uint8Attr(gretap.Ttl))
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_GRE_TOS, nl.Uint8Attr(gretap.Tos))
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_GRE_ENCAP_TYPE, nl.Uint16Attr(gretap.EncapType))
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_GRE_ENCAP_FLAGS, nl.Uint16Attr(gretap.EncapFlags))
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_GRE_ENCAP_SPORT, htons(gretap.EncapSport))
|
|
|
+ nl.NewRtAttrChild(data, nl.IFLA_GRE_ENCAP_DPORT, htons(gretap.EncapDport))
|
|
|
+}
|
|
|
+
|
|
|
+func parseGretapData(link Link, data []syscall.NetlinkRouteAttr) {
|
|
|
+ gre := link.(*Gretap)
|
|
|
+ for _, datum := range data {
|
|
|
+ switch datum.Attr.Type {
|
|
|
+ case nl.IFLA_GRE_OKEY:
|
|
|
+ gre.IKey = ntohl(datum.Value[0:4])
|
|
|
+ case nl.IFLA_GRE_IKEY:
|
|
|
+ gre.OKey = ntohl(datum.Value[0:4])
|
|
|
+ case nl.IFLA_GRE_LOCAL:
|
|
|
+ gre.Local = net.IP(datum.Value[0:4])
|
|
|
+ case nl.IFLA_GRE_REMOTE:
|
|
|
+ gre.Remote = net.IP(datum.Value[0:4])
|
|
|
+ case nl.IFLA_GRE_ENCAP_SPORT:
|
|
|
+ gre.EncapSport = ntohs(datum.Value[0:2])
|
|
|
+ case nl.IFLA_GRE_ENCAP_DPORT:
|
|
|
+ gre.EncapDport = ntohs(datum.Value[0:2])
|
|
|
+ case nl.IFLA_GRE_IFLAGS:
|
|
|
+ gre.IFlags = ntohs(datum.Value[0:2])
|
|
|
+ case nl.IFLA_GRE_OFLAGS:
|
|
|
+ gre.OFlags = ntohs(datum.Value[0:2])
|
|
|
+
|
|
|
+ case nl.IFLA_GRE_TTL:
|
|
|
+ gre.Ttl = uint8(datum.Value[0])
|
|
|
+ case nl.IFLA_GRE_TOS:
|
|
|
+ gre.Tos = uint8(datum.Value[0])
|
|
|
+ case nl.IFLA_GRE_PMTUDISC:
|
|
|
+ gre.PMtuDisc = uint8(datum.Value[0])
|
|
|
+ case nl.IFLA_GRE_ENCAP_TYPE:
|
|
|
+ gre.EncapType = native.Uint16(datum.Value[0:2])
|
|
|
+ case nl.IFLA_GRE_ENCAP_FLAGS:
|
|
|
+ gre.EncapFlags = native.Uint16(datum.Value[0:2])
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+func parseLinkStats(data []byte) *LinkStatistics {
|
|
|
+ return (*LinkStatistics)(unsafe.Pointer(&data[0:SizeofLinkStats][0]))
|
|
|
+}
|