link_linux.go 57 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017
  1. package netlink
  2. import (
  3. "bytes"
  4. "encoding/binary"
  5. "fmt"
  6. "net"
  7. "os"
  8. "syscall"
  9. "unsafe"
  10. "github.com/vishvananda/netlink/nl"
  11. "github.com/vishvananda/netns"
  12. )
  13. const (
  14. SizeofLinkStats32 = 0x5c
  15. SizeofLinkStats64 = 0xd8
  16. IFLA_STATS64 = 0x17 // syscall pkg does not contain this one
  17. )
  18. const (
  19. TUNTAP_MODE_TUN TuntapMode = syscall.IFF_TUN
  20. TUNTAP_MODE_TAP TuntapMode = syscall.IFF_TAP
  21. TUNTAP_DEFAULTS TuntapFlag = syscall.IFF_TUN_EXCL | syscall.IFF_ONE_QUEUE
  22. TUNTAP_VNET_HDR TuntapFlag = syscall.IFF_VNET_HDR
  23. TUNTAP_TUN_EXCL TuntapFlag = syscall.IFF_TUN_EXCL
  24. TUNTAP_NO_PI TuntapFlag = syscall.IFF_NO_PI
  25. TUNTAP_ONE_QUEUE TuntapFlag = syscall.IFF_ONE_QUEUE
  26. )
  27. var lookupByDump = false
  28. var macvlanModes = [...]uint32{
  29. 0,
  30. nl.MACVLAN_MODE_PRIVATE,
  31. nl.MACVLAN_MODE_VEPA,
  32. nl.MACVLAN_MODE_BRIDGE,
  33. nl.MACVLAN_MODE_PASSTHRU,
  34. nl.MACVLAN_MODE_SOURCE,
  35. }
  36. func ensureIndex(link *LinkAttrs) {
  37. if link != nil && link.Index == 0 {
  38. newlink, _ := LinkByName(link.Name)
  39. if newlink != nil {
  40. link.Index = newlink.Attrs().Index
  41. }
  42. }
  43. }
  44. func (h *Handle) ensureIndex(link *LinkAttrs) {
  45. if link != nil && link.Index == 0 {
  46. newlink, _ := h.LinkByName(link.Name)
  47. if newlink != nil {
  48. link.Index = newlink.Attrs().Index
  49. }
  50. }
  51. }
  52. func (h *Handle) LinkSetARPOff(link Link) error {
  53. base := link.Attrs()
  54. h.ensureIndex(base)
  55. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  56. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  57. msg.Change |= syscall.IFF_NOARP
  58. msg.Flags |= syscall.IFF_NOARP
  59. msg.Index = int32(base.Index)
  60. req.AddData(msg)
  61. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  62. return err
  63. }
  64. func LinkSetARPOff(link Link) error {
  65. return pkgHandle.LinkSetARPOff(link)
  66. }
  67. func (h *Handle) LinkSetARPOn(link Link) error {
  68. base := link.Attrs()
  69. h.ensureIndex(base)
  70. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  71. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  72. msg.Change |= syscall.IFF_NOARP
  73. msg.Flags &= ^uint32(syscall.IFF_NOARP)
  74. msg.Index = int32(base.Index)
  75. req.AddData(msg)
  76. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  77. return err
  78. }
  79. func LinkSetARPOn(link Link) error {
  80. return pkgHandle.LinkSetARPOn(link)
  81. }
  82. func (h *Handle) SetPromiscOn(link Link) error {
  83. base := link.Attrs()
  84. h.ensureIndex(base)
  85. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  86. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  87. msg.Change = syscall.IFF_PROMISC
  88. msg.Flags = syscall.IFF_PROMISC
  89. msg.Index = int32(base.Index)
  90. req.AddData(msg)
  91. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  92. return err
  93. }
  94. func BridgeSetMcastSnoop(link Link, on bool) error {
  95. return pkgHandle.BridgeSetMcastSnoop(link, on)
  96. }
  97. func (h *Handle) BridgeSetMcastSnoop(link Link, on bool) error {
  98. bridge := link.(*Bridge)
  99. bridge.MulticastSnooping = &on
  100. return h.linkModify(bridge, syscall.NLM_F_ACK)
  101. }
  102. func SetPromiscOn(link Link) error {
  103. return pkgHandle.SetPromiscOn(link)
  104. }
  105. func (h *Handle) SetPromiscOff(link Link) error {
  106. base := link.Attrs()
  107. h.ensureIndex(base)
  108. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  109. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  110. msg.Change = syscall.IFF_PROMISC
  111. msg.Flags = 0 & ^syscall.IFF_PROMISC
  112. msg.Index = int32(base.Index)
  113. req.AddData(msg)
  114. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  115. return err
  116. }
  117. func SetPromiscOff(link Link) error {
  118. return pkgHandle.SetPromiscOff(link)
  119. }
  120. // LinkSetUp enables the link device.
  121. // Equivalent to: `ip link set $link up`
  122. func LinkSetUp(link Link) error {
  123. return pkgHandle.LinkSetUp(link)
  124. }
  125. // LinkSetUp enables the link device.
  126. // Equivalent to: `ip link set $link up`
  127. func (h *Handle) LinkSetUp(link Link) error {
  128. base := link.Attrs()
  129. h.ensureIndex(base)
  130. req := h.newNetlinkRequest(syscall.RTM_NEWLINK, syscall.NLM_F_ACK)
  131. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  132. msg.Change = syscall.IFF_UP
  133. msg.Flags = syscall.IFF_UP
  134. msg.Index = int32(base.Index)
  135. req.AddData(msg)
  136. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  137. return err
  138. }
  139. // LinkSetDown disables link device.
  140. // Equivalent to: `ip link set $link down`
  141. func LinkSetDown(link Link) error {
  142. return pkgHandle.LinkSetDown(link)
  143. }
  144. // LinkSetDown disables link device.
  145. // Equivalent to: `ip link set $link down`
  146. func (h *Handle) LinkSetDown(link Link) error {
  147. base := link.Attrs()
  148. h.ensureIndex(base)
  149. req := h.newNetlinkRequest(syscall.RTM_NEWLINK, syscall.NLM_F_ACK)
  150. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  151. msg.Change = syscall.IFF_UP
  152. msg.Flags = 0 & ^syscall.IFF_UP
  153. msg.Index = int32(base.Index)
  154. req.AddData(msg)
  155. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  156. return err
  157. }
  158. // LinkSetMTU sets the mtu of the link device.
  159. // Equivalent to: `ip link set $link mtu $mtu`
  160. func LinkSetMTU(link Link, mtu int) error {
  161. return pkgHandle.LinkSetMTU(link, mtu)
  162. }
  163. // LinkSetMTU sets the mtu of the link device.
  164. // Equivalent to: `ip link set $link mtu $mtu`
  165. func (h *Handle) LinkSetMTU(link Link, mtu int) error {
  166. base := link.Attrs()
  167. h.ensureIndex(base)
  168. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  169. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  170. msg.Index = int32(base.Index)
  171. req.AddData(msg)
  172. b := make([]byte, 4)
  173. native.PutUint32(b, uint32(mtu))
  174. data := nl.NewRtAttr(syscall.IFLA_MTU, b)
  175. req.AddData(data)
  176. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  177. return err
  178. }
  179. // LinkSetName sets the name of the link device.
  180. // Equivalent to: `ip link set $link name $name`
  181. func LinkSetName(link Link, name string) error {
  182. return pkgHandle.LinkSetName(link, name)
  183. }
  184. // LinkSetName sets the name of the link device.
  185. // Equivalent to: `ip link set $link name $name`
  186. func (h *Handle) LinkSetName(link Link, name string) error {
  187. base := link.Attrs()
  188. h.ensureIndex(base)
  189. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  190. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  191. msg.Index = int32(base.Index)
  192. req.AddData(msg)
  193. data := nl.NewRtAttr(syscall.IFLA_IFNAME, []byte(name))
  194. req.AddData(data)
  195. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  196. return err
  197. }
  198. // LinkSetAlias sets the alias of the link device.
  199. // Equivalent to: `ip link set dev $link alias $name`
  200. func LinkSetAlias(link Link, name string) error {
  201. return pkgHandle.LinkSetAlias(link, name)
  202. }
  203. // LinkSetAlias sets the alias of the link device.
  204. // Equivalent to: `ip link set dev $link alias $name`
  205. func (h *Handle) LinkSetAlias(link Link, name string) error {
  206. base := link.Attrs()
  207. h.ensureIndex(base)
  208. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  209. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  210. msg.Index = int32(base.Index)
  211. req.AddData(msg)
  212. data := nl.NewRtAttr(syscall.IFLA_IFALIAS, []byte(name))
  213. req.AddData(data)
  214. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  215. return err
  216. }
  217. // LinkSetHardwareAddr sets the hardware address of the link device.
  218. // Equivalent to: `ip link set $link address $hwaddr`
  219. func LinkSetHardwareAddr(link Link, hwaddr net.HardwareAddr) error {
  220. return pkgHandle.LinkSetHardwareAddr(link, hwaddr)
  221. }
  222. // LinkSetHardwareAddr sets the hardware address of the link device.
  223. // Equivalent to: `ip link set $link address $hwaddr`
  224. func (h *Handle) LinkSetHardwareAddr(link Link, hwaddr net.HardwareAddr) error {
  225. base := link.Attrs()
  226. h.ensureIndex(base)
  227. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  228. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  229. msg.Index = int32(base.Index)
  230. req.AddData(msg)
  231. data := nl.NewRtAttr(syscall.IFLA_ADDRESS, []byte(hwaddr))
  232. req.AddData(data)
  233. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  234. return err
  235. }
  236. // LinkSetVfHardwareAddr sets the hardware address of a vf for the link.
  237. // Equivalent to: `ip link set $link vf $vf mac $hwaddr`
  238. func LinkSetVfHardwareAddr(link Link, vf int, hwaddr net.HardwareAddr) error {
  239. return pkgHandle.LinkSetVfHardwareAddr(link, vf, hwaddr)
  240. }
  241. // LinkSetVfHardwareAddr sets the hardware address of a vf for the link.
  242. // Equivalent to: `ip link set $link vf $vf mac $hwaddr`
  243. func (h *Handle) LinkSetVfHardwareAddr(link Link, vf int, hwaddr net.HardwareAddr) error {
  244. base := link.Attrs()
  245. h.ensureIndex(base)
  246. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  247. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  248. msg.Index = int32(base.Index)
  249. req.AddData(msg)
  250. data := nl.NewRtAttr(nl.IFLA_VFINFO_LIST, nil)
  251. info := nl.NewRtAttrChild(data, nl.IFLA_VF_INFO, nil)
  252. vfmsg := nl.VfMac{
  253. Vf: uint32(vf),
  254. }
  255. copy(vfmsg.Mac[:], []byte(hwaddr))
  256. nl.NewRtAttrChild(info, nl.IFLA_VF_MAC, vfmsg.Serialize())
  257. req.AddData(data)
  258. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  259. return err
  260. }
  261. // LinkSetVfVlan sets the vlan of a vf for the link.
  262. // Equivalent to: `ip link set $link vf $vf vlan $vlan`
  263. func LinkSetVfVlan(link Link, vf, vlan int) error {
  264. return pkgHandle.LinkSetVfVlan(link, vf, vlan)
  265. }
  266. // LinkSetVfVlan sets the vlan of a vf for the link.
  267. // Equivalent to: `ip link set $link vf $vf vlan $vlan`
  268. func (h *Handle) LinkSetVfVlan(link Link, vf, vlan int) error {
  269. base := link.Attrs()
  270. h.ensureIndex(base)
  271. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  272. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  273. msg.Index = int32(base.Index)
  274. req.AddData(msg)
  275. data := nl.NewRtAttr(nl.IFLA_VFINFO_LIST, nil)
  276. info := nl.NewRtAttrChild(data, nl.IFLA_VF_INFO, nil)
  277. vfmsg := nl.VfVlan{
  278. Vf: uint32(vf),
  279. Vlan: uint32(vlan),
  280. }
  281. nl.NewRtAttrChild(info, nl.IFLA_VF_VLAN, vfmsg.Serialize())
  282. req.AddData(data)
  283. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  284. return err
  285. }
  286. // LinkSetVfTxRate sets the tx rate of a vf for the link.
  287. // Equivalent to: `ip link set $link vf $vf rate $rate`
  288. func LinkSetVfTxRate(link Link, vf, rate int) error {
  289. return pkgHandle.LinkSetVfTxRate(link, vf, rate)
  290. }
  291. // LinkSetVfTxRate sets the tx rate of a vf for the link.
  292. // Equivalent to: `ip link set $link vf $vf rate $rate`
  293. func (h *Handle) LinkSetVfTxRate(link Link, vf, rate int) error {
  294. base := link.Attrs()
  295. h.ensureIndex(base)
  296. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  297. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  298. msg.Index = int32(base.Index)
  299. req.AddData(msg)
  300. data := nl.NewRtAttr(nl.IFLA_VFINFO_LIST, nil)
  301. info := nl.NewRtAttrChild(data, nl.IFLA_VF_INFO, nil)
  302. vfmsg := nl.VfTxRate{
  303. Vf: uint32(vf),
  304. Rate: uint32(rate),
  305. }
  306. nl.NewRtAttrChild(info, nl.IFLA_VF_TX_RATE, vfmsg.Serialize())
  307. req.AddData(data)
  308. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  309. return err
  310. }
  311. // LinkSetVfSpoofchk enables/disables spoof check on a vf for the link.
  312. // Equivalent to: `ip link set $link vf $vf spoofchk $check`
  313. func LinkSetVfSpoofchk(link Link, vf int, check bool) error {
  314. return pkgHandle.LinkSetVfSpoofchk(link, vf, check)
  315. }
  316. // LinkSetVfSpookfchk enables/disables spoof check on a vf for the link.
  317. // Equivalent to: `ip link set $link vf $vf spoofchk $check`
  318. func (h *Handle) LinkSetVfSpoofchk(link Link, vf int, check bool) error {
  319. var setting uint32
  320. base := link.Attrs()
  321. h.ensureIndex(base)
  322. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  323. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  324. msg.Index = int32(base.Index)
  325. req.AddData(msg)
  326. data := nl.NewRtAttr(nl.IFLA_VFINFO_LIST, nil)
  327. info := nl.NewRtAttrChild(data, nl.IFLA_VF_INFO, nil)
  328. if check {
  329. setting = 1
  330. }
  331. vfmsg := nl.VfSpoofchk{
  332. Vf: uint32(vf),
  333. Setting: setting,
  334. }
  335. nl.NewRtAttrChild(info, nl.IFLA_VF_SPOOFCHK, vfmsg.Serialize())
  336. req.AddData(data)
  337. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  338. return err
  339. }
  340. // LinkSetVfTrust enables/disables trust state on a vf for the link.
  341. // Equivalent to: `ip link set $link vf $vf trust $state`
  342. func LinkSetVfTrust(link Link, vf int, state bool) error {
  343. return pkgHandle.LinkSetVfTrust(link, vf, state)
  344. }
  345. // LinkSetVfTrust enables/disables trust state on a vf for the link.
  346. // Equivalent to: `ip link set $link vf $vf trust $state`
  347. func (h *Handle) LinkSetVfTrust(link Link, vf int, state bool) error {
  348. var setting uint32
  349. base := link.Attrs()
  350. h.ensureIndex(base)
  351. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  352. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  353. msg.Index = int32(base.Index)
  354. req.AddData(msg)
  355. data := nl.NewRtAttr(nl.IFLA_VFINFO_LIST, nil)
  356. info := nl.NewRtAttrChild(data, nl.IFLA_VF_INFO, nil)
  357. if state {
  358. setting = 1
  359. }
  360. vfmsg := nl.VfTrust{
  361. Vf: uint32(vf),
  362. Setting: setting,
  363. }
  364. nl.NewRtAttrChild(info, nl.IFLA_VF_TRUST, vfmsg.Serialize())
  365. req.AddData(data)
  366. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  367. return err
  368. }
  369. // LinkSetMaster sets the master of the link device.
  370. // Equivalent to: `ip link set $link master $master`
  371. func LinkSetMaster(link Link, master *Bridge) error {
  372. return pkgHandle.LinkSetMaster(link, master)
  373. }
  374. // LinkSetMaster sets the master of the link device.
  375. // Equivalent to: `ip link set $link master $master`
  376. func (h *Handle) LinkSetMaster(link Link, master *Bridge) error {
  377. index := 0
  378. if master != nil {
  379. masterBase := master.Attrs()
  380. h.ensureIndex(masterBase)
  381. index = masterBase.Index
  382. }
  383. if index <= 0 {
  384. return fmt.Errorf("Device does not exist")
  385. }
  386. return h.LinkSetMasterByIndex(link, index)
  387. }
  388. // LinkSetNoMaster removes the master of the link device.
  389. // Equivalent to: `ip link set $link nomaster`
  390. func LinkSetNoMaster(link Link) error {
  391. return pkgHandle.LinkSetNoMaster(link)
  392. }
  393. // LinkSetNoMaster removes the master of the link device.
  394. // Equivalent to: `ip link set $link nomaster`
  395. func (h *Handle) LinkSetNoMaster(link Link) error {
  396. return h.LinkSetMasterByIndex(link, 0)
  397. }
  398. // LinkSetMasterByIndex sets the master of the link device.
  399. // Equivalent to: `ip link set $link master $master`
  400. func LinkSetMasterByIndex(link Link, masterIndex int) error {
  401. return pkgHandle.LinkSetMasterByIndex(link, masterIndex)
  402. }
  403. // LinkSetMasterByIndex sets the master of the link device.
  404. // Equivalent to: `ip link set $link master $master`
  405. func (h *Handle) LinkSetMasterByIndex(link Link, masterIndex int) error {
  406. base := link.Attrs()
  407. h.ensureIndex(base)
  408. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  409. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  410. msg.Index = int32(base.Index)
  411. req.AddData(msg)
  412. b := make([]byte, 4)
  413. native.PutUint32(b, uint32(masterIndex))
  414. data := nl.NewRtAttr(syscall.IFLA_MASTER, b)
  415. req.AddData(data)
  416. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  417. return err
  418. }
  419. // LinkSetNsPid puts the device into a new network namespace. The
  420. // pid must be a pid of a running process.
  421. // Equivalent to: `ip link set $link netns $pid`
  422. func LinkSetNsPid(link Link, nspid int) error {
  423. return pkgHandle.LinkSetNsPid(link, nspid)
  424. }
  425. // LinkSetNsPid puts the device into a new network namespace. The
  426. // pid must be a pid of a running process.
  427. // Equivalent to: `ip link set $link netns $pid`
  428. func (h *Handle) LinkSetNsPid(link Link, nspid int) error {
  429. base := link.Attrs()
  430. h.ensureIndex(base)
  431. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  432. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  433. msg.Index = int32(base.Index)
  434. req.AddData(msg)
  435. b := make([]byte, 4)
  436. native.PutUint32(b, uint32(nspid))
  437. data := nl.NewRtAttr(syscall.IFLA_NET_NS_PID, b)
  438. req.AddData(data)
  439. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  440. return err
  441. }
  442. // LinkSetNsFd puts the device into a new network namespace. The
  443. // fd must be an open file descriptor to a network namespace.
  444. // Similar to: `ip link set $link netns $ns`
  445. func LinkSetNsFd(link Link, fd int) error {
  446. return pkgHandle.LinkSetNsFd(link, fd)
  447. }
  448. // LinkSetNsFd puts the device into a new network namespace. The
  449. // fd must be an open file descriptor to a network namespace.
  450. // Similar to: `ip link set $link netns $ns`
  451. func (h *Handle) LinkSetNsFd(link Link, fd int) error {
  452. base := link.Attrs()
  453. h.ensureIndex(base)
  454. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  455. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  456. msg.Index = int32(base.Index)
  457. req.AddData(msg)
  458. b := make([]byte, 4)
  459. native.PutUint32(b, uint32(fd))
  460. data := nl.NewRtAttr(nl.IFLA_NET_NS_FD, b)
  461. req.AddData(data)
  462. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  463. return err
  464. }
  465. // LinkSetXdpFd adds a bpf function to the driver. The fd must be a bpf
  466. // program loaded with bpf(type=BPF_PROG_TYPE_XDP)
  467. func LinkSetXdpFd(link Link, fd int) error {
  468. return LinkSetXdpFdWithFlags(link, fd, 0)
  469. }
  470. // LinkSetXdpFdWithFlags adds a bpf function to the driver with the given
  471. // options. The fd must be a bpf program loaded with bpf(type=BPF_PROG_TYPE_XDP)
  472. func LinkSetXdpFdWithFlags(link Link, fd, flags int) error {
  473. base := link.Attrs()
  474. ensureIndex(base)
  475. req := nl.NewNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  476. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  477. msg.Index = int32(base.Index)
  478. req.AddData(msg)
  479. addXdpAttrs(&LinkXdp{Fd: fd, Flags: uint32(flags)}, req)
  480. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  481. return err
  482. }
  483. func boolAttr(val bool) []byte {
  484. var v uint8
  485. if val {
  486. v = 1
  487. }
  488. return nl.Uint8Attr(v)
  489. }
  490. type vxlanPortRange struct {
  491. Lo, Hi uint16
  492. }
  493. func addVxlanAttrs(vxlan *Vxlan, linkInfo *nl.RtAttr) {
  494. data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
  495. if vxlan.FlowBased {
  496. vxlan.VxlanId = 0
  497. }
  498. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_ID, nl.Uint32Attr(uint32(vxlan.VxlanId)))
  499. if vxlan.VtepDevIndex != 0 {
  500. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_LINK, nl.Uint32Attr(uint32(vxlan.VtepDevIndex)))
  501. }
  502. if vxlan.SrcAddr != nil {
  503. ip := vxlan.SrcAddr.To4()
  504. if ip != nil {
  505. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_LOCAL, []byte(ip))
  506. } else {
  507. ip = vxlan.SrcAddr.To16()
  508. if ip != nil {
  509. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_LOCAL6, []byte(ip))
  510. }
  511. }
  512. }
  513. if vxlan.Group != nil {
  514. group := vxlan.Group.To4()
  515. if group != nil {
  516. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_GROUP, []byte(group))
  517. } else {
  518. group = vxlan.Group.To16()
  519. if group != nil {
  520. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_GROUP6, []byte(group))
  521. }
  522. }
  523. }
  524. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_TTL, nl.Uint8Attr(uint8(vxlan.TTL)))
  525. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_TOS, nl.Uint8Attr(uint8(vxlan.TOS)))
  526. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_LEARNING, boolAttr(vxlan.Learning))
  527. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_PROXY, boolAttr(vxlan.Proxy))
  528. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_RSC, boolAttr(vxlan.RSC))
  529. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_L2MISS, boolAttr(vxlan.L2miss))
  530. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_L3MISS, boolAttr(vxlan.L3miss))
  531. if vxlan.UDPCSum {
  532. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_UDP_CSUM, boolAttr(vxlan.UDPCSum))
  533. }
  534. if vxlan.GBP {
  535. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_GBP, []byte{})
  536. }
  537. if vxlan.FlowBased {
  538. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_FLOWBASED, boolAttr(vxlan.FlowBased))
  539. }
  540. if vxlan.NoAge {
  541. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_AGEING, nl.Uint32Attr(0))
  542. } else if vxlan.Age > 0 {
  543. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_AGEING, nl.Uint32Attr(uint32(vxlan.Age)))
  544. }
  545. if vxlan.Limit > 0 {
  546. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_LIMIT, nl.Uint32Attr(uint32(vxlan.Limit)))
  547. }
  548. if vxlan.Port > 0 {
  549. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_PORT, htons(uint16(vxlan.Port)))
  550. }
  551. if vxlan.PortLow > 0 || vxlan.PortHigh > 0 {
  552. pr := vxlanPortRange{uint16(vxlan.PortLow), uint16(vxlan.PortHigh)}
  553. buf := new(bytes.Buffer)
  554. binary.Write(buf, binary.BigEndian, &pr)
  555. nl.NewRtAttrChild(data, nl.IFLA_VXLAN_PORT_RANGE, buf.Bytes())
  556. }
  557. }
  558. func addBondAttrs(bond *Bond, linkInfo *nl.RtAttr) {
  559. data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
  560. if bond.Mode >= 0 {
  561. nl.NewRtAttrChild(data, nl.IFLA_BOND_MODE, nl.Uint8Attr(uint8(bond.Mode)))
  562. }
  563. if bond.ActiveSlave >= 0 {
  564. nl.NewRtAttrChild(data, nl.IFLA_BOND_ACTIVE_SLAVE, nl.Uint32Attr(uint32(bond.ActiveSlave)))
  565. }
  566. if bond.Miimon >= 0 {
  567. nl.NewRtAttrChild(data, nl.IFLA_BOND_MIIMON, nl.Uint32Attr(uint32(bond.Miimon)))
  568. }
  569. if bond.UpDelay >= 0 {
  570. nl.NewRtAttrChild(data, nl.IFLA_BOND_UPDELAY, nl.Uint32Attr(uint32(bond.UpDelay)))
  571. }
  572. if bond.DownDelay >= 0 {
  573. nl.NewRtAttrChild(data, nl.IFLA_BOND_DOWNDELAY, nl.Uint32Attr(uint32(bond.DownDelay)))
  574. }
  575. if bond.UseCarrier >= 0 {
  576. nl.NewRtAttrChild(data, nl.IFLA_BOND_USE_CARRIER, nl.Uint8Attr(uint8(bond.UseCarrier)))
  577. }
  578. if bond.ArpInterval >= 0 {
  579. nl.NewRtAttrChild(data, nl.IFLA_BOND_ARP_INTERVAL, nl.Uint32Attr(uint32(bond.ArpInterval)))
  580. }
  581. if bond.ArpIpTargets != nil {
  582. msg := nl.NewRtAttrChild(data, nl.IFLA_BOND_ARP_IP_TARGET, nil)
  583. for i := range bond.ArpIpTargets {
  584. ip := bond.ArpIpTargets[i].To4()
  585. if ip != nil {
  586. nl.NewRtAttrChild(msg, i, []byte(ip))
  587. continue
  588. }
  589. ip = bond.ArpIpTargets[i].To16()
  590. if ip != nil {
  591. nl.NewRtAttrChild(msg, i, []byte(ip))
  592. }
  593. }
  594. }
  595. if bond.ArpValidate >= 0 {
  596. nl.NewRtAttrChild(data, nl.IFLA_BOND_ARP_VALIDATE, nl.Uint32Attr(uint32(bond.ArpValidate)))
  597. }
  598. if bond.ArpAllTargets >= 0 {
  599. nl.NewRtAttrChild(data, nl.IFLA_BOND_ARP_ALL_TARGETS, nl.Uint32Attr(uint32(bond.ArpAllTargets)))
  600. }
  601. if bond.Primary >= 0 {
  602. nl.NewRtAttrChild(data, nl.IFLA_BOND_PRIMARY, nl.Uint32Attr(uint32(bond.Primary)))
  603. }
  604. if bond.PrimaryReselect >= 0 {
  605. nl.NewRtAttrChild(data, nl.IFLA_BOND_PRIMARY_RESELECT, nl.Uint8Attr(uint8(bond.PrimaryReselect)))
  606. }
  607. if bond.FailOverMac >= 0 {
  608. nl.NewRtAttrChild(data, nl.IFLA_BOND_FAIL_OVER_MAC, nl.Uint8Attr(uint8(bond.FailOverMac)))
  609. }
  610. if bond.XmitHashPolicy >= 0 {
  611. nl.NewRtAttrChild(data, nl.IFLA_BOND_XMIT_HASH_POLICY, nl.Uint8Attr(uint8(bond.XmitHashPolicy)))
  612. }
  613. if bond.ResendIgmp >= 0 {
  614. nl.NewRtAttrChild(data, nl.IFLA_BOND_RESEND_IGMP, nl.Uint32Attr(uint32(bond.ResendIgmp)))
  615. }
  616. if bond.NumPeerNotif >= 0 {
  617. nl.NewRtAttrChild(data, nl.IFLA_BOND_NUM_PEER_NOTIF, nl.Uint8Attr(uint8(bond.NumPeerNotif)))
  618. }
  619. if bond.AllSlavesActive >= 0 {
  620. nl.NewRtAttrChild(data, nl.IFLA_BOND_ALL_SLAVES_ACTIVE, nl.Uint8Attr(uint8(bond.AllSlavesActive)))
  621. }
  622. if bond.MinLinks >= 0 {
  623. nl.NewRtAttrChild(data, nl.IFLA_BOND_MIN_LINKS, nl.Uint32Attr(uint32(bond.MinLinks)))
  624. }
  625. if bond.LpInterval >= 0 {
  626. nl.NewRtAttrChild(data, nl.IFLA_BOND_LP_INTERVAL, nl.Uint32Attr(uint32(bond.LpInterval)))
  627. }
  628. if bond.PackersPerSlave >= 0 {
  629. nl.NewRtAttrChild(data, nl.IFLA_BOND_PACKETS_PER_SLAVE, nl.Uint32Attr(uint32(bond.PackersPerSlave)))
  630. }
  631. if bond.LacpRate >= 0 {
  632. nl.NewRtAttrChild(data, nl.IFLA_BOND_AD_LACP_RATE, nl.Uint8Attr(uint8(bond.LacpRate)))
  633. }
  634. if bond.AdSelect >= 0 {
  635. nl.NewRtAttrChild(data, nl.IFLA_BOND_AD_SELECT, nl.Uint8Attr(uint8(bond.AdSelect)))
  636. }
  637. if bond.AdActorSysPrio >= 0 {
  638. nl.NewRtAttrChild(data, nl.IFLA_BOND_AD_ACTOR_SYS_PRIO, nl.Uint16Attr(uint16(bond.AdActorSysPrio)))
  639. }
  640. if bond.AdUserPortKey >= 0 {
  641. nl.NewRtAttrChild(data, nl.IFLA_BOND_AD_USER_PORT_KEY, nl.Uint16Attr(uint16(bond.AdUserPortKey)))
  642. }
  643. if bond.AdActorSystem != nil {
  644. nl.NewRtAttrChild(data, nl.IFLA_BOND_AD_ACTOR_SYSTEM, []byte(bond.AdActorSystem))
  645. }
  646. if bond.TlbDynamicLb >= 0 {
  647. nl.NewRtAttrChild(data, nl.IFLA_BOND_TLB_DYNAMIC_LB, nl.Uint8Attr(uint8(bond.TlbDynamicLb)))
  648. }
  649. }
  650. // LinkAdd adds a new link device. The type and features of the device
  651. // are taken from the parameters in the link object.
  652. // Equivalent to: `ip link add $link`
  653. func LinkAdd(link Link) error {
  654. return pkgHandle.LinkAdd(link)
  655. }
  656. // LinkAdd adds a new link device. The type and features of the device
  657. // are taken fromt the parameters in the link object.
  658. // Equivalent to: `ip link add $link`
  659. func (h *Handle) LinkAdd(link Link) error {
  660. return h.linkModify(link, syscall.NLM_F_CREATE|syscall.NLM_F_EXCL|syscall.NLM_F_ACK)
  661. }
  662. func (h *Handle) linkModify(link Link, flags int) error {
  663. // TODO: support extra data for macvlan
  664. base := link.Attrs()
  665. if base.Name == "" {
  666. return fmt.Errorf("LinkAttrs.Name cannot be empty!")
  667. }
  668. if tuntap, ok := link.(*Tuntap); ok {
  669. // TODO: support user
  670. // TODO: support group
  671. // TODO: multi_queue
  672. // TODO: support non- persistent
  673. if tuntap.Mode < syscall.IFF_TUN || tuntap.Mode > syscall.IFF_TAP {
  674. return fmt.Errorf("Tuntap.Mode %v unknown!", tuntap.Mode)
  675. }
  676. file, err := os.OpenFile("/dev/net/tun", os.O_RDWR, 0)
  677. if err != nil {
  678. return err
  679. }
  680. defer file.Close()
  681. var req ifReq
  682. if tuntap.Flags == 0 {
  683. req.Flags = uint16(TUNTAP_DEFAULTS)
  684. } else {
  685. req.Flags = uint16(tuntap.Flags)
  686. }
  687. req.Flags |= uint16(tuntap.Mode)
  688. copy(req.Name[:15], base.Name)
  689. _, _, errno := syscall.Syscall(syscall.SYS_IOCTL, file.Fd(), uintptr(syscall.TUNSETIFF), uintptr(unsafe.Pointer(&req)))
  690. if errno != 0 {
  691. return fmt.Errorf("Tuntap IOCTL TUNSETIFF failed, errno %v", errno)
  692. }
  693. _, _, errno = syscall.Syscall(syscall.SYS_IOCTL, file.Fd(), uintptr(syscall.TUNSETPERSIST), 1)
  694. if errno != 0 {
  695. return fmt.Errorf("Tuntap IOCTL TUNSETPERSIST failed, errno %v", errno)
  696. }
  697. h.ensureIndex(base)
  698. // can't set master during create, so set it afterwards
  699. if base.MasterIndex != 0 {
  700. // TODO: verify MasterIndex is actually a bridge?
  701. return h.LinkSetMasterByIndex(link, base.MasterIndex)
  702. }
  703. return nil
  704. }
  705. req := h.newNetlinkRequest(syscall.RTM_NEWLINK, flags)
  706. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  707. // TODO: make it shorter
  708. if base.Flags&net.FlagUp != 0 {
  709. msg.Change = syscall.IFF_UP
  710. msg.Flags = syscall.IFF_UP
  711. }
  712. if base.Flags&net.FlagBroadcast != 0 {
  713. msg.Change |= syscall.IFF_BROADCAST
  714. msg.Flags |= syscall.IFF_BROADCAST
  715. }
  716. if base.Flags&net.FlagLoopback != 0 {
  717. msg.Change |= syscall.IFF_LOOPBACK
  718. msg.Flags |= syscall.IFF_LOOPBACK
  719. }
  720. if base.Flags&net.FlagPointToPoint != 0 {
  721. msg.Change |= syscall.IFF_POINTOPOINT
  722. msg.Flags |= syscall.IFF_POINTOPOINT
  723. }
  724. if base.Flags&net.FlagMulticast != 0 {
  725. msg.Change |= syscall.IFF_MULTICAST
  726. msg.Flags |= syscall.IFF_MULTICAST
  727. }
  728. req.AddData(msg)
  729. if base.ParentIndex != 0 {
  730. b := make([]byte, 4)
  731. native.PutUint32(b, uint32(base.ParentIndex))
  732. data := nl.NewRtAttr(syscall.IFLA_LINK, b)
  733. req.AddData(data)
  734. } else if link.Type() == "ipvlan" {
  735. return fmt.Errorf("Can't create ipvlan link without ParentIndex")
  736. }
  737. nameData := nl.NewRtAttr(syscall.IFLA_IFNAME, nl.ZeroTerminated(base.Name))
  738. req.AddData(nameData)
  739. if base.MTU > 0 {
  740. mtu := nl.NewRtAttr(syscall.IFLA_MTU, nl.Uint32Attr(uint32(base.MTU)))
  741. req.AddData(mtu)
  742. }
  743. if base.TxQLen >= 0 {
  744. qlen := nl.NewRtAttr(syscall.IFLA_TXQLEN, nl.Uint32Attr(uint32(base.TxQLen)))
  745. req.AddData(qlen)
  746. }
  747. if base.HardwareAddr != nil {
  748. hwaddr := nl.NewRtAttr(syscall.IFLA_ADDRESS, []byte(base.HardwareAddr))
  749. req.AddData(hwaddr)
  750. }
  751. if base.Namespace != nil {
  752. var attr *nl.RtAttr
  753. switch base.Namespace.(type) {
  754. case NsPid:
  755. val := nl.Uint32Attr(uint32(base.Namespace.(NsPid)))
  756. attr = nl.NewRtAttr(syscall.IFLA_NET_NS_PID, val)
  757. case NsFd:
  758. val := nl.Uint32Attr(uint32(base.Namespace.(NsFd)))
  759. attr = nl.NewRtAttr(nl.IFLA_NET_NS_FD, val)
  760. }
  761. req.AddData(attr)
  762. }
  763. if base.Xdp != nil {
  764. addXdpAttrs(base.Xdp, req)
  765. }
  766. linkInfo := nl.NewRtAttr(syscall.IFLA_LINKINFO, nil)
  767. nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_KIND, nl.NonZeroTerminated(link.Type()))
  768. switch link := link.(type) {
  769. case *Vlan:
  770. b := make([]byte, 2)
  771. native.PutUint16(b, uint16(link.VlanId))
  772. data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
  773. nl.NewRtAttrChild(data, nl.IFLA_VLAN_ID, b)
  774. case *Veth:
  775. data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
  776. peer := nl.NewRtAttrChild(data, nl.VETH_INFO_PEER, nil)
  777. nl.NewIfInfomsgChild(peer, syscall.AF_UNSPEC)
  778. nl.NewRtAttrChild(peer, syscall.IFLA_IFNAME, nl.ZeroTerminated(link.PeerName))
  779. if base.TxQLen >= 0 {
  780. nl.NewRtAttrChild(peer, syscall.IFLA_TXQLEN, nl.Uint32Attr(uint32(base.TxQLen)))
  781. }
  782. if base.MTU > 0 {
  783. nl.NewRtAttrChild(peer, syscall.IFLA_MTU, nl.Uint32Attr(uint32(base.MTU)))
  784. }
  785. case *Vxlan:
  786. addVxlanAttrs(link, linkInfo)
  787. case *Bond:
  788. addBondAttrs(link, linkInfo)
  789. case *IPVlan:
  790. data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
  791. nl.NewRtAttrChild(data, nl.IFLA_IPVLAN_MODE, nl.Uint16Attr(uint16(link.Mode)))
  792. case *Macvlan:
  793. if link.Mode != MACVLAN_MODE_DEFAULT {
  794. data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
  795. nl.NewRtAttrChild(data, nl.IFLA_MACVLAN_MODE, nl.Uint32Attr(macvlanModes[link.Mode]))
  796. }
  797. case *Macvtap:
  798. if link.Mode != MACVLAN_MODE_DEFAULT {
  799. data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
  800. nl.NewRtAttrChild(data, nl.IFLA_MACVLAN_MODE, nl.Uint32Attr(macvlanModes[link.Mode]))
  801. }
  802. case *Gretap:
  803. addGretapAttrs(link, linkInfo)
  804. case *Iptun:
  805. addIptunAttrs(link, linkInfo)
  806. case *Gretun:
  807. addGretunAttrs(link, linkInfo)
  808. case *Vti:
  809. addVtiAttrs(link, linkInfo)
  810. case *Vrf:
  811. addVrfAttrs(link, linkInfo)
  812. case *Bridge:
  813. addBridgeAttrs(link, linkInfo)
  814. case *GTP:
  815. addGTPAttrs(link, linkInfo)
  816. }
  817. req.AddData(linkInfo)
  818. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  819. if err != nil {
  820. return err
  821. }
  822. h.ensureIndex(base)
  823. // can't set master during create, so set it afterwards
  824. if base.MasterIndex != 0 {
  825. // TODO: verify MasterIndex is actually a bridge?
  826. return h.LinkSetMasterByIndex(link, base.MasterIndex)
  827. }
  828. return nil
  829. }
  830. // LinkDel deletes link device. Either Index or Name must be set in
  831. // the link object for it to be deleted. The other values are ignored.
  832. // Equivalent to: `ip link del $link`
  833. func LinkDel(link Link) error {
  834. return pkgHandle.LinkDel(link)
  835. }
  836. // LinkDel deletes link device. Either Index or Name must be set in
  837. // the link object for it to be deleted. The other values are ignored.
  838. // Equivalent to: `ip link del $link`
  839. func (h *Handle) LinkDel(link Link) error {
  840. base := link.Attrs()
  841. h.ensureIndex(base)
  842. req := h.newNetlinkRequest(syscall.RTM_DELLINK, syscall.NLM_F_ACK)
  843. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  844. msg.Index = int32(base.Index)
  845. req.AddData(msg)
  846. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  847. return err
  848. }
  849. func (h *Handle) linkByNameDump(name string) (Link, error) {
  850. links, err := h.LinkList()
  851. if err != nil {
  852. return nil, err
  853. }
  854. for _, link := range links {
  855. if link.Attrs().Name == name {
  856. return link, nil
  857. }
  858. }
  859. return nil, LinkNotFoundError{fmt.Errorf("Link %s not found", name)}
  860. }
  861. func (h *Handle) linkByAliasDump(alias string) (Link, error) {
  862. links, err := h.LinkList()
  863. if err != nil {
  864. return nil, err
  865. }
  866. for _, link := range links {
  867. if link.Attrs().Alias == alias {
  868. return link, nil
  869. }
  870. }
  871. return nil, LinkNotFoundError{fmt.Errorf("Link alias %s not found", alias)}
  872. }
  873. // LinkByName finds a link by name and returns a pointer to the object.
  874. func LinkByName(name string) (Link, error) {
  875. return pkgHandle.LinkByName(name)
  876. }
  877. // LinkByName finds a link by name and returns a pointer to the object.
  878. func (h *Handle) LinkByName(name string) (Link, error) {
  879. if h.lookupByDump {
  880. return h.linkByNameDump(name)
  881. }
  882. req := h.newNetlinkRequest(syscall.RTM_GETLINK, syscall.NLM_F_ACK)
  883. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  884. req.AddData(msg)
  885. nameData := nl.NewRtAttr(syscall.IFLA_IFNAME, nl.ZeroTerminated(name))
  886. req.AddData(nameData)
  887. link, err := execGetLink(req)
  888. if err == syscall.EINVAL {
  889. // older kernels don't support looking up via IFLA_IFNAME
  890. // so fall back to dumping all links
  891. h.lookupByDump = true
  892. return h.linkByNameDump(name)
  893. }
  894. return link, err
  895. }
  896. // LinkByAlias finds a link by its alias and returns a pointer to the object.
  897. // If there are multiple links with the alias it returns the first one
  898. func LinkByAlias(alias string) (Link, error) {
  899. return pkgHandle.LinkByAlias(alias)
  900. }
  901. // LinkByAlias finds a link by its alias and returns a pointer to the object.
  902. // If there are multiple links with the alias it returns the first one
  903. func (h *Handle) LinkByAlias(alias string) (Link, error) {
  904. if h.lookupByDump {
  905. return h.linkByAliasDump(alias)
  906. }
  907. req := h.newNetlinkRequest(syscall.RTM_GETLINK, syscall.NLM_F_ACK)
  908. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  909. req.AddData(msg)
  910. nameData := nl.NewRtAttr(syscall.IFLA_IFALIAS, nl.ZeroTerminated(alias))
  911. req.AddData(nameData)
  912. link, err := execGetLink(req)
  913. if err == syscall.EINVAL {
  914. // older kernels don't support looking up via IFLA_IFALIAS
  915. // so fall back to dumping all links
  916. h.lookupByDump = true
  917. return h.linkByAliasDump(alias)
  918. }
  919. return link, err
  920. }
  921. // LinkByIndex finds a link by index and returns a pointer to the object.
  922. func LinkByIndex(index int) (Link, error) {
  923. return pkgHandle.LinkByIndex(index)
  924. }
  925. // LinkByIndex finds a link by index and returns a pointer to the object.
  926. func (h *Handle) LinkByIndex(index int) (Link, error) {
  927. req := h.newNetlinkRequest(syscall.RTM_GETLINK, syscall.NLM_F_ACK)
  928. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  929. msg.Index = int32(index)
  930. req.AddData(msg)
  931. return execGetLink(req)
  932. }
  933. func execGetLink(req *nl.NetlinkRequest) (Link, error) {
  934. msgs, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  935. if err != nil {
  936. if errno, ok := err.(syscall.Errno); ok {
  937. if errno == syscall.ENODEV {
  938. return nil, LinkNotFoundError{fmt.Errorf("Link not found")}
  939. }
  940. }
  941. return nil, err
  942. }
  943. switch {
  944. case len(msgs) == 0:
  945. return nil, LinkNotFoundError{fmt.Errorf("Link not found")}
  946. case len(msgs) == 1:
  947. return LinkDeserialize(nil, msgs[0])
  948. default:
  949. return nil, fmt.Errorf("More than one link found")
  950. }
  951. }
  952. // linkDeserialize deserializes a raw message received from netlink into
  953. // a link object.
  954. func LinkDeserialize(hdr *syscall.NlMsghdr, m []byte) (Link, error) {
  955. msg := nl.DeserializeIfInfomsg(m)
  956. attrs, err := nl.ParseRouteAttr(m[msg.Len():])
  957. if err != nil {
  958. return nil, err
  959. }
  960. base := LinkAttrs{Index: int(msg.Index), RawFlags: msg.Flags, Flags: linkFlags(msg.Flags), EncapType: msg.EncapType()}
  961. if msg.Flags&syscall.IFF_PROMISC != 0 {
  962. base.Promisc = 1
  963. }
  964. var (
  965. link Link
  966. stats32 []byte
  967. stats64 []byte
  968. linkType string
  969. )
  970. for _, attr := range attrs {
  971. switch attr.Attr.Type {
  972. case syscall.IFLA_LINKINFO:
  973. infos, err := nl.ParseRouteAttr(attr.Value)
  974. if err != nil {
  975. return nil, err
  976. }
  977. for _, info := range infos {
  978. switch info.Attr.Type {
  979. case nl.IFLA_INFO_KIND:
  980. linkType = string(info.Value[:len(info.Value)-1])
  981. switch linkType {
  982. case "dummy":
  983. link = &Dummy{}
  984. case "ifb":
  985. link = &Ifb{}
  986. case "bridge":
  987. link = &Bridge{}
  988. case "vlan":
  989. link = &Vlan{}
  990. case "veth":
  991. link = &Veth{}
  992. case "vxlan":
  993. link = &Vxlan{}
  994. case "bond":
  995. link = &Bond{}
  996. case "ipvlan":
  997. link = &IPVlan{}
  998. case "macvlan":
  999. link = &Macvlan{}
  1000. case "macvtap":
  1001. link = &Macvtap{}
  1002. case "gretap":
  1003. link = &Gretap{}
  1004. case "ipip":
  1005. link = &Iptun{}
  1006. case "gre":
  1007. link = &Gretun{}
  1008. case "vti":
  1009. link = &Vti{}
  1010. case "vrf":
  1011. link = &Vrf{}
  1012. case "gtp":
  1013. link = &GTP{}
  1014. default:
  1015. link = &GenericLink{LinkType: linkType}
  1016. }
  1017. case nl.IFLA_INFO_DATA:
  1018. data, err := nl.ParseRouteAttr(info.Value)
  1019. if err != nil {
  1020. return nil, err
  1021. }
  1022. switch linkType {
  1023. case "vlan":
  1024. parseVlanData(link, data)
  1025. case "vxlan":
  1026. parseVxlanData(link, data)
  1027. case "bond":
  1028. parseBondData(link, data)
  1029. case "ipvlan":
  1030. parseIPVlanData(link, data)
  1031. case "macvlan":
  1032. parseMacvlanData(link, data)
  1033. case "macvtap":
  1034. parseMacvtapData(link, data)
  1035. case "gretap":
  1036. parseGretapData(link, data)
  1037. case "ipip":
  1038. parseIptunData(link, data)
  1039. case "gre":
  1040. parseGretunData(link, data)
  1041. case "vti":
  1042. parseVtiData(link, data)
  1043. case "vrf":
  1044. parseVrfData(link, data)
  1045. case "bridge":
  1046. parseBridgeData(link, data)
  1047. case "gtp":
  1048. parseGTPData(link, data)
  1049. }
  1050. }
  1051. }
  1052. case syscall.IFLA_ADDRESS:
  1053. var nonzero bool
  1054. for _, b := range attr.Value {
  1055. if b != 0 {
  1056. nonzero = true
  1057. }
  1058. }
  1059. if nonzero {
  1060. base.HardwareAddr = attr.Value[:]
  1061. }
  1062. case syscall.IFLA_IFNAME:
  1063. base.Name = string(attr.Value[:len(attr.Value)-1])
  1064. case syscall.IFLA_MTU:
  1065. base.MTU = int(native.Uint32(attr.Value[0:4]))
  1066. case syscall.IFLA_LINK:
  1067. base.ParentIndex = int(native.Uint32(attr.Value[0:4]))
  1068. case syscall.IFLA_MASTER:
  1069. base.MasterIndex = int(native.Uint32(attr.Value[0:4]))
  1070. case syscall.IFLA_TXQLEN:
  1071. base.TxQLen = int(native.Uint32(attr.Value[0:4]))
  1072. case syscall.IFLA_IFALIAS:
  1073. base.Alias = string(attr.Value[:len(attr.Value)-1])
  1074. case syscall.IFLA_STATS:
  1075. stats32 = attr.Value[:]
  1076. case IFLA_STATS64:
  1077. stats64 = attr.Value[:]
  1078. case nl.IFLA_XDP:
  1079. xdp, err := parseLinkXdp(attr.Value[:])
  1080. if err != nil {
  1081. return nil, err
  1082. }
  1083. base.Xdp = xdp
  1084. case syscall.IFLA_PROTINFO | syscall.NLA_F_NESTED:
  1085. if hdr != nil && hdr.Type == syscall.RTM_NEWLINK &&
  1086. msg.Family == syscall.AF_BRIDGE {
  1087. attrs, err := nl.ParseRouteAttr(attr.Value[:])
  1088. if err != nil {
  1089. return nil, err
  1090. }
  1091. base.Protinfo = parseProtinfo(attrs)
  1092. }
  1093. case syscall.IFLA_OPERSTATE:
  1094. base.OperState = LinkOperState(uint8(attr.Value[0]))
  1095. case nl.IFLA_LINK_NETNSID:
  1096. base.NetNsID = int(native.Uint32(attr.Value[0:4]))
  1097. }
  1098. }
  1099. if stats64 != nil {
  1100. base.Statistics = parseLinkStats64(stats64)
  1101. } else if stats32 != nil {
  1102. base.Statistics = parseLinkStats32(stats32)
  1103. }
  1104. // Links that don't have IFLA_INFO_KIND are hardware devices
  1105. if link == nil {
  1106. link = &Device{}
  1107. }
  1108. *link.Attrs() = base
  1109. return link, nil
  1110. }
  1111. // LinkList gets a list of link devices.
  1112. // Equivalent to: `ip link show`
  1113. func LinkList() ([]Link, error) {
  1114. return pkgHandle.LinkList()
  1115. }
  1116. // LinkList gets a list of link devices.
  1117. // Equivalent to: `ip link show`
  1118. func (h *Handle) LinkList() ([]Link, error) {
  1119. // NOTE(vish): This duplicates functionality in net/iface_linux.go, but we need
  1120. // to get the message ourselves to parse link type.
  1121. req := h.newNetlinkRequest(syscall.RTM_GETLINK, syscall.NLM_F_DUMP)
  1122. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  1123. req.AddData(msg)
  1124. msgs, err := req.Execute(syscall.NETLINK_ROUTE, syscall.RTM_NEWLINK)
  1125. if err != nil {
  1126. return nil, err
  1127. }
  1128. var res []Link
  1129. for _, m := range msgs {
  1130. link, err := LinkDeserialize(nil, m)
  1131. if err != nil {
  1132. return nil, err
  1133. }
  1134. res = append(res, link)
  1135. }
  1136. return res, nil
  1137. }
  1138. // LinkUpdate is used to pass information back from LinkSubscribe()
  1139. type LinkUpdate struct {
  1140. nl.IfInfomsg
  1141. Header syscall.NlMsghdr
  1142. Link
  1143. }
  1144. // LinkSubscribe takes a chan down which notifications will be sent
  1145. // when links change. Close the 'done' chan to stop subscription.
  1146. func LinkSubscribe(ch chan<- LinkUpdate, done <-chan struct{}) error {
  1147. return linkSubscribeAt(netns.None(), netns.None(), ch, done, nil)
  1148. }
  1149. // LinkSubscribeAt works like LinkSubscribe plus it allows the caller
  1150. // to choose the network namespace in which to subscribe (ns).
  1151. func LinkSubscribeAt(ns netns.NsHandle, ch chan<- LinkUpdate, done <-chan struct{}) error {
  1152. return linkSubscribeAt(ns, netns.None(), ch, done, nil)
  1153. }
  1154. // LinkSubscribeOptions contains a set of options to use with
  1155. // LinkSubscribeWithOptions.
  1156. type LinkSubscribeOptions struct {
  1157. Namespace *netns.NsHandle
  1158. ErrorCallback func(error)
  1159. }
  1160. // LinkSubscribeWithOptions work like LinkSubscribe but enable to
  1161. // provide additional options to modify the behavior. Currently, the
  1162. // namespace can be provided as well as an error callback.
  1163. func LinkSubscribeWithOptions(ch chan<- LinkUpdate, done <-chan struct{}, options LinkSubscribeOptions) error {
  1164. if options.Namespace == nil {
  1165. none := netns.None()
  1166. options.Namespace = &none
  1167. }
  1168. return linkSubscribeAt(*options.Namespace, netns.None(), ch, done, options.ErrorCallback)
  1169. }
  1170. func linkSubscribeAt(newNs, curNs netns.NsHandle, ch chan<- LinkUpdate, done <-chan struct{}, cberr func(error)) error {
  1171. s, err := nl.SubscribeAt(newNs, curNs, syscall.NETLINK_ROUTE, syscall.RTNLGRP_LINK)
  1172. if err != nil {
  1173. return err
  1174. }
  1175. if done != nil {
  1176. go func() {
  1177. <-done
  1178. s.Close()
  1179. }()
  1180. }
  1181. go func() {
  1182. defer close(ch)
  1183. for {
  1184. msgs, err := s.Receive()
  1185. if err != nil {
  1186. if cberr != nil {
  1187. cberr(err)
  1188. }
  1189. return
  1190. }
  1191. for _, m := range msgs {
  1192. ifmsg := nl.DeserializeIfInfomsg(m.Data)
  1193. link, err := LinkDeserialize(&m.Header, m.Data)
  1194. if err != nil {
  1195. if cberr != nil {
  1196. cberr(err)
  1197. }
  1198. return
  1199. }
  1200. ch <- LinkUpdate{IfInfomsg: *ifmsg, Header: m.Header, Link: link}
  1201. }
  1202. }
  1203. }()
  1204. return nil
  1205. }
  1206. func LinkSetHairpin(link Link, mode bool) error {
  1207. return pkgHandle.LinkSetHairpin(link, mode)
  1208. }
  1209. func (h *Handle) LinkSetHairpin(link Link, mode bool) error {
  1210. return h.setProtinfoAttr(link, mode, nl.IFLA_BRPORT_MODE)
  1211. }
  1212. func LinkSetGuard(link Link, mode bool) error {
  1213. return pkgHandle.LinkSetGuard(link, mode)
  1214. }
  1215. func (h *Handle) LinkSetGuard(link Link, mode bool) error {
  1216. return h.setProtinfoAttr(link, mode, nl.IFLA_BRPORT_GUARD)
  1217. }
  1218. func LinkSetFastLeave(link Link, mode bool) error {
  1219. return pkgHandle.LinkSetFastLeave(link, mode)
  1220. }
  1221. func (h *Handle) LinkSetFastLeave(link Link, mode bool) error {
  1222. return h.setProtinfoAttr(link, mode, nl.IFLA_BRPORT_FAST_LEAVE)
  1223. }
  1224. func LinkSetLearning(link Link, mode bool) error {
  1225. return pkgHandle.LinkSetLearning(link, mode)
  1226. }
  1227. func (h *Handle) LinkSetLearning(link Link, mode bool) error {
  1228. return h.setProtinfoAttr(link, mode, nl.IFLA_BRPORT_LEARNING)
  1229. }
  1230. func LinkSetRootBlock(link Link, mode bool) error {
  1231. return pkgHandle.LinkSetRootBlock(link, mode)
  1232. }
  1233. func (h *Handle) LinkSetRootBlock(link Link, mode bool) error {
  1234. return h.setProtinfoAttr(link, mode, nl.IFLA_BRPORT_PROTECT)
  1235. }
  1236. func LinkSetFlood(link Link, mode bool) error {
  1237. return pkgHandle.LinkSetFlood(link, mode)
  1238. }
  1239. func (h *Handle) LinkSetFlood(link Link, mode bool) error {
  1240. return h.setProtinfoAttr(link, mode, nl.IFLA_BRPORT_UNICAST_FLOOD)
  1241. }
  1242. func LinkSetBrProxyArp(link Link, mode bool) error {
  1243. return pkgHandle.LinkSetBrProxyArp(link, mode)
  1244. }
  1245. func (h *Handle) LinkSetBrProxyArp(link Link, mode bool) error {
  1246. return h.setProtinfoAttr(link, mode, nl.IFLA_BRPORT_PROXYARP)
  1247. }
  1248. func LinkSetBrProxyArpWiFi(link Link, mode bool) error {
  1249. return pkgHandle.LinkSetBrProxyArpWiFi(link, mode)
  1250. }
  1251. func (h *Handle) LinkSetBrProxyArpWiFi(link Link, mode bool) error {
  1252. return h.setProtinfoAttr(link, mode, nl.IFLA_BRPORT_PROXYARP_WIFI)
  1253. }
  1254. func (h *Handle) setProtinfoAttr(link Link, mode bool, attr int) error {
  1255. base := link.Attrs()
  1256. h.ensureIndex(base)
  1257. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  1258. msg := nl.NewIfInfomsg(syscall.AF_BRIDGE)
  1259. msg.Index = int32(base.Index)
  1260. req.AddData(msg)
  1261. br := nl.NewRtAttr(syscall.IFLA_PROTINFO|syscall.NLA_F_NESTED, nil)
  1262. nl.NewRtAttrChild(br, attr, boolToByte(mode))
  1263. req.AddData(br)
  1264. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  1265. if err != nil {
  1266. return err
  1267. }
  1268. return nil
  1269. }
  1270. // LinkSetTxQLen sets the transaction queue length for the link.
  1271. // Equivalent to: `ip link set $link txqlen $qlen`
  1272. func LinkSetTxQLen(link Link, qlen int) error {
  1273. return pkgHandle.LinkSetTxQLen(link, qlen)
  1274. }
  1275. // LinkSetTxQLen sets the transaction queue length for the link.
  1276. // Equivalent to: `ip link set $link txqlen $qlen`
  1277. func (h *Handle) LinkSetTxQLen(link Link, qlen int) error {
  1278. base := link.Attrs()
  1279. h.ensureIndex(base)
  1280. req := h.newNetlinkRequest(syscall.RTM_SETLINK, syscall.NLM_F_ACK)
  1281. msg := nl.NewIfInfomsg(syscall.AF_UNSPEC)
  1282. msg.Index = int32(base.Index)
  1283. req.AddData(msg)
  1284. b := make([]byte, 4)
  1285. native.PutUint32(b, uint32(qlen))
  1286. data := nl.NewRtAttr(syscall.IFLA_TXQLEN, b)
  1287. req.AddData(data)
  1288. _, err := req.Execute(syscall.NETLINK_ROUTE, 0)
  1289. return err
  1290. }
  1291. func parseVlanData(link Link, data []syscall.NetlinkRouteAttr) {
  1292. vlan := link.(*Vlan)
  1293. for _, datum := range data {
  1294. switch datum.Attr.Type {
  1295. case nl.IFLA_VLAN_ID:
  1296. vlan.VlanId = int(native.Uint16(datum.Value[0:2]))
  1297. }
  1298. }
  1299. }
  1300. func parseVxlanData(link Link, data []syscall.NetlinkRouteAttr) {
  1301. vxlan := link.(*Vxlan)
  1302. for _, datum := range data {
  1303. switch datum.Attr.Type {
  1304. case nl.IFLA_VXLAN_ID:
  1305. vxlan.VxlanId = int(native.Uint32(datum.Value[0:4]))
  1306. case nl.IFLA_VXLAN_LINK:
  1307. vxlan.VtepDevIndex = int(native.Uint32(datum.Value[0:4]))
  1308. case nl.IFLA_VXLAN_LOCAL:
  1309. vxlan.SrcAddr = net.IP(datum.Value[0:4])
  1310. case nl.IFLA_VXLAN_LOCAL6:
  1311. vxlan.SrcAddr = net.IP(datum.Value[0:16])
  1312. case nl.IFLA_VXLAN_GROUP:
  1313. vxlan.Group = net.IP(datum.Value[0:4])
  1314. case nl.IFLA_VXLAN_GROUP6:
  1315. vxlan.Group = net.IP(datum.Value[0:16])
  1316. case nl.IFLA_VXLAN_TTL:
  1317. vxlan.TTL = int(datum.Value[0])
  1318. case nl.IFLA_VXLAN_TOS:
  1319. vxlan.TOS = int(datum.Value[0])
  1320. case nl.IFLA_VXLAN_LEARNING:
  1321. vxlan.Learning = int8(datum.Value[0]) != 0
  1322. case nl.IFLA_VXLAN_PROXY:
  1323. vxlan.Proxy = int8(datum.Value[0]) != 0
  1324. case nl.IFLA_VXLAN_RSC:
  1325. vxlan.RSC = int8(datum.Value[0]) != 0
  1326. case nl.IFLA_VXLAN_L2MISS:
  1327. vxlan.L2miss = int8(datum.Value[0]) != 0
  1328. case nl.IFLA_VXLAN_L3MISS:
  1329. vxlan.L3miss = int8(datum.Value[0]) != 0
  1330. case nl.IFLA_VXLAN_UDP_CSUM:
  1331. vxlan.UDPCSum = int8(datum.Value[0]) != 0
  1332. case nl.IFLA_VXLAN_GBP:
  1333. vxlan.GBP = true
  1334. case nl.IFLA_VXLAN_FLOWBASED:
  1335. vxlan.FlowBased = int8(datum.Value[0]) != 0
  1336. case nl.IFLA_VXLAN_AGEING:
  1337. vxlan.Age = int(native.Uint32(datum.Value[0:4]))
  1338. vxlan.NoAge = vxlan.Age == 0
  1339. case nl.IFLA_VXLAN_LIMIT:
  1340. vxlan.Limit = int(native.Uint32(datum.Value[0:4]))
  1341. case nl.IFLA_VXLAN_PORT:
  1342. vxlan.Port = int(ntohs(datum.Value[0:2]))
  1343. case nl.IFLA_VXLAN_PORT_RANGE:
  1344. buf := bytes.NewBuffer(datum.Value[0:4])
  1345. var pr vxlanPortRange
  1346. if binary.Read(buf, binary.BigEndian, &pr) != nil {
  1347. vxlan.PortLow = int(pr.Lo)
  1348. vxlan.PortHigh = int(pr.Hi)
  1349. }
  1350. }
  1351. }
  1352. }
  1353. func parseBondData(link Link, data []syscall.NetlinkRouteAttr) {
  1354. bond := link.(*Bond)
  1355. for i := range data {
  1356. switch data[i].Attr.Type {
  1357. case nl.IFLA_BOND_MODE:
  1358. bond.Mode = BondMode(data[i].Value[0])
  1359. case nl.IFLA_BOND_ACTIVE_SLAVE:
  1360. bond.ActiveSlave = int(native.Uint32(data[i].Value[0:4]))
  1361. case nl.IFLA_BOND_MIIMON:
  1362. bond.Miimon = int(native.Uint32(data[i].Value[0:4]))
  1363. case nl.IFLA_BOND_UPDELAY:
  1364. bond.UpDelay = int(native.Uint32(data[i].Value[0:4]))
  1365. case nl.IFLA_BOND_DOWNDELAY:
  1366. bond.DownDelay = int(native.Uint32(data[i].Value[0:4]))
  1367. case nl.IFLA_BOND_USE_CARRIER:
  1368. bond.UseCarrier = int(data[i].Value[0])
  1369. case nl.IFLA_BOND_ARP_INTERVAL:
  1370. bond.ArpInterval = int(native.Uint32(data[i].Value[0:4]))
  1371. case nl.IFLA_BOND_ARP_IP_TARGET:
  1372. // TODO: implement
  1373. case nl.IFLA_BOND_ARP_VALIDATE:
  1374. bond.ArpValidate = BondArpValidate(native.Uint32(data[i].Value[0:4]))
  1375. case nl.IFLA_BOND_ARP_ALL_TARGETS:
  1376. bond.ArpAllTargets = BondArpAllTargets(native.Uint32(data[i].Value[0:4]))
  1377. case nl.IFLA_BOND_PRIMARY:
  1378. bond.Primary = int(native.Uint32(data[i].Value[0:4]))
  1379. case nl.IFLA_BOND_PRIMARY_RESELECT:
  1380. bond.PrimaryReselect = BondPrimaryReselect(data[i].Value[0])
  1381. case nl.IFLA_BOND_FAIL_OVER_MAC:
  1382. bond.FailOverMac = BondFailOverMac(data[i].Value[0])
  1383. case nl.IFLA_BOND_XMIT_HASH_POLICY:
  1384. bond.XmitHashPolicy = BondXmitHashPolicy(data[i].Value[0])
  1385. case nl.IFLA_BOND_RESEND_IGMP:
  1386. bond.ResendIgmp = int(native.Uint32(data[i].Value[0:4]))
  1387. case nl.IFLA_BOND_NUM_PEER_NOTIF:
  1388. bond.NumPeerNotif = int(data[i].Value[0])
  1389. case nl.IFLA_BOND_ALL_SLAVES_ACTIVE:
  1390. bond.AllSlavesActive = int(data[i].Value[0])
  1391. case nl.IFLA_BOND_MIN_LINKS:
  1392. bond.MinLinks = int(native.Uint32(data[i].Value[0:4]))
  1393. case nl.IFLA_BOND_LP_INTERVAL:
  1394. bond.LpInterval = int(native.Uint32(data[i].Value[0:4]))
  1395. case nl.IFLA_BOND_PACKETS_PER_SLAVE:
  1396. bond.PackersPerSlave = int(native.Uint32(data[i].Value[0:4]))
  1397. case nl.IFLA_BOND_AD_LACP_RATE:
  1398. bond.LacpRate = BondLacpRate(data[i].Value[0])
  1399. case nl.IFLA_BOND_AD_SELECT:
  1400. bond.AdSelect = BondAdSelect(data[i].Value[0])
  1401. case nl.IFLA_BOND_AD_INFO:
  1402. // TODO: implement
  1403. case nl.IFLA_BOND_AD_ACTOR_SYS_PRIO:
  1404. bond.AdActorSysPrio = int(native.Uint16(data[i].Value[0:2]))
  1405. case nl.IFLA_BOND_AD_USER_PORT_KEY:
  1406. bond.AdUserPortKey = int(native.Uint16(data[i].Value[0:2]))
  1407. case nl.IFLA_BOND_AD_ACTOR_SYSTEM:
  1408. bond.AdActorSystem = net.HardwareAddr(data[i].Value[0:6])
  1409. case nl.IFLA_BOND_TLB_DYNAMIC_LB:
  1410. bond.TlbDynamicLb = int(data[i].Value[0])
  1411. }
  1412. }
  1413. }
  1414. func parseIPVlanData(link Link, data []syscall.NetlinkRouteAttr) {
  1415. ipv := link.(*IPVlan)
  1416. for _, datum := range data {
  1417. if datum.Attr.Type == nl.IFLA_IPVLAN_MODE {
  1418. ipv.Mode = IPVlanMode(native.Uint32(datum.Value[0:4]))
  1419. return
  1420. }
  1421. }
  1422. }
  1423. func parseMacvtapData(link Link, data []syscall.NetlinkRouteAttr) {
  1424. macv := link.(*Macvtap)
  1425. parseMacvlanData(&macv.Macvlan, data)
  1426. }
  1427. func parseMacvlanData(link Link, data []syscall.NetlinkRouteAttr) {
  1428. macv := link.(*Macvlan)
  1429. for _, datum := range data {
  1430. if datum.Attr.Type == nl.IFLA_MACVLAN_MODE {
  1431. switch native.Uint32(datum.Value[0:4]) {
  1432. case nl.MACVLAN_MODE_PRIVATE:
  1433. macv.Mode = MACVLAN_MODE_PRIVATE
  1434. case nl.MACVLAN_MODE_VEPA:
  1435. macv.Mode = MACVLAN_MODE_VEPA
  1436. case nl.MACVLAN_MODE_BRIDGE:
  1437. macv.Mode = MACVLAN_MODE_BRIDGE
  1438. case nl.MACVLAN_MODE_PASSTHRU:
  1439. macv.Mode = MACVLAN_MODE_PASSTHRU
  1440. case nl.MACVLAN_MODE_SOURCE:
  1441. macv.Mode = MACVLAN_MODE_SOURCE
  1442. }
  1443. return
  1444. }
  1445. }
  1446. }
  1447. // copied from pkg/net_linux.go
  1448. func linkFlags(rawFlags uint32) net.Flags {
  1449. var f net.Flags
  1450. if rawFlags&syscall.IFF_UP != 0 {
  1451. f |= net.FlagUp
  1452. }
  1453. if rawFlags&syscall.IFF_BROADCAST != 0 {
  1454. f |= net.FlagBroadcast
  1455. }
  1456. if rawFlags&syscall.IFF_LOOPBACK != 0 {
  1457. f |= net.FlagLoopback
  1458. }
  1459. if rawFlags&syscall.IFF_POINTOPOINT != 0 {
  1460. f |= net.FlagPointToPoint
  1461. }
  1462. if rawFlags&syscall.IFF_MULTICAST != 0 {
  1463. f |= net.FlagMulticast
  1464. }
  1465. return f
  1466. }
  1467. func addGretapAttrs(gretap *Gretap, linkInfo *nl.RtAttr) {
  1468. data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
  1469. if gretap.FlowBased {
  1470. // In flow based mode, no other attributes need to be configured
  1471. nl.NewRtAttrChild(data, nl.IFLA_GRE_COLLECT_METADATA, boolAttr(gretap.FlowBased))
  1472. return
  1473. }
  1474. ip := gretap.Local.To4()
  1475. if ip != nil {
  1476. nl.NewRtAttrChild(data, nl.IFLA_GRE_LOCAL, []byte(ip))
  1477. }
  1478. ip = gretap.Remote.To4()
  1479. if ip != nil {
  1480. nl.NewRtAttrChild(data, nl.IFLA_GRE_REMOTE, []byte(ip))
  1481. }
  1482. if gretap.IKey != 0 {
  1483. nl.NewRtAttrChild(data, nl.IFLA_GRE_IKEY, htonl(gretap.IKey))
  1484. gretap.IFlags |= uint16(nl.GRE_KEY)
  1485. }
  1486. if gretap.OKey != 0 {
  1487. nl.NewRtAttrChild(data, nl.IFLA_GRE_OKEY, htonl(gretap.OKey))
  1488. gretap.OFlags |= uint16(nl.GRE_KEY)
  1489. }
  1490. nl.NewRtAttrChild(data, nl.IFLA_GRE_IFLAGS, htons(gretap.IFlags))
  1491. nl.NewRtAttrChild(data, nl.IFLA_GRE_OFLAGS, htons(gretap.OFlags))
  1492. if gretap.Link != 0 {
  1493. nl.NewRtAttrChild(data, nl.IFLA_GRE_LINK, nl.Uint32Attr(gretap.Link))
  1494. }
  1495. nl.NewRtAttrChild(data, nl.IFLA_GRE_PMTUDISC, nl.Uint8Attr(gretap.PMtuDisc))
  1496. nl.NewRtAttrChild(data, nl.IFLA_GRE_TTL, nl.Uint8Attr(gretap.Ttl))
  1497. nl.NewRtAttrChild(data, nl.IFLA_GRE_TOS, nl.Uint8Attr(gretap.Tos))
  1498. nl.NewRtAttrChild(data, nl.IFLA_GRE_ENCAP_TYPE, nl.Uint16Attr(gretap.EncapType))
  1499. nl.NewRtAttrChild(data, nl.IFLA_GRE_ENCAP_FLAGS, nl.Uint16Attr(gretap.EncapFlags))
  1500. nl.NewRtAttrChild(data, nl.IFLA_GRE_ENCAP_SPORT, htons(gretap.EncapSport))
  1501. nl.NewRtAttrChild(data, nl.IFLA_GRE_ENCAP_DPORT, htons(gretap.EncapDport))
  1502. }
  1503. func parseGretapData(link Link, data []syscall.NetlinkRouteAttr) {
  1504. gre := link.(*Gretap)
  1505. for _, datum := range data {
  1506. switch datum.Attr.Type {
  1507. case nl.IFLA_GRE_OKEY:
  1508. gre.IKey = ntohl(datum.Value[0:4])
  1509. case nl.IFLA_GRE_IKEY:
  1510. gre.OKey = ntohl(datum.Value[0:4])
  1511. case nl.IFLA_GRE_LOCAL:
  1512. gre.Local = net.IP(datum.Value[0:4])
  1513. case nl.IFLA_GRE_REMOTE:
  1514. gre.Remote = net.IP(datum.Value[0:4])
  1515. case nl.IFLA_GRE_ENCAP_SPORT:
  1516. gre.EncapSport = ntohs(datum.Value[0:2])
  1517. case nl.IFLA_GRE_ENCAP_DPORT:
  1518. gre.EncapDport = ntohs(datum.Value[0:2])
  1519. case nl.IFLA_GRE_IFLAGS:
  1520. gre.IFlags = ntohs(datum.Value[0:2])
  1521. case nl.IFLA_GRE_OFLAGS:
  1522. gre.OFlags = ntohs(datum.Value[0:2])
  1523. case nl.IFLA_GRE_TTL:
  1524. gre.Ttl = uint8(datum.Value[0])
  1525. case nl.IFLA_GRE_TOS:
  1526. gre.Tos = uint8(datum.Value[0])
  1527. case nl.IFLA_GRE_PMTUDISC:
  1528. gre.PMtuDisc = uint8(datum.Value[0])
  1529. case nl.IFLA_GRE_ENCAP_TYPE:
  1530. gre.EncapType = native.Uint16(datum.Value[0:2])
  1531. case nl.IFLA_GRE_ENCAP_FLAGS:
  1532. gre.EncapFlags = native.Uint16(datum.Value[0:2])
  1533. case nl.IFLA_GRE_COLLECT_METADATA:
  1534. gre.FlowBased = int8(datum.Value[0]) != 0
  1535. }
  1536. }
  1537. }
  1538. func addGretunAttrs(gre *Gretun, linkInfo *nl.RtAttr) {
  1539. data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
  1540. ip := gre.Local.To4()
  1541. if ip != nil {
  1542. nl.NewRtAttrChild(data, nl.IFLA_GRE_LOCAL, []byte(ip))
  1543. }
  1544. ip = gre.Remote.To4()
  1545. if ip != nil {
  1546. nl.NewRtAttrChild(data, nl.IFLA_GRE_REMOTE, []byte(ip))
  1547. }
  1548. if gre.IKey != 0 {
  1549. nl.NewRtAttrChild(data, nl.IFLA_GRE_IKEY, htonl(gre.IKey))
  1550. gre.IFlags |= uint16(nl.GRE_KEY)
  1551. }
  1552. if gre.OKey != 0 {
  1553. nl.NewRtAttrChild(data, nl.IFLA_GRE_OKEY, htonl(gre.OKey))
  1554. gre.OFlags |= uint16(nl.GRE_KEY)
  1555. }
  1556. nl.NewRtAttrChild(data, nl.IFLA_GRE_IFLAGS, htons(gre.IFlags))
  1557. nl.NewRtAttrChild(data, nl.IFLA_GRE_OFLAGS, htons(gre.OFlags))
  1558. if gre.Link != 0 {
  1559. nl.NewRtAttrChild(data, nl.IFLA_GRE_LINK, nl.Uint32Attr(gre.Link))
  1560. }
  1561. nl.NewRtAttrChild(data, nl.IFLA_GRE_PMTUDISC, nl.Uint8Attr(gre.PMtuDisc))
  1562. nl.NewRtAttrChild(data, nl.IFLA_GRE_TTL, nl.Uint8Attr(gre.Ttl))
  1563. nl.NewRtAttrChild(data, nl.IFLA_GRE_TOS, nl.Uint8Attr(gre.Tos))
  1564. }
  1565. func parseGretunData(link Link, data []syscall.NetlinkRouteAttr) {
  1566. gre := link.(*Gretun)
  1567. for _, datum := range data {
  1568. switch datum.Attr.Type {
  1569. case nl.IFLA_GRE_OKEY:
  1570. gre.IKey = ntohl(datum.Value[0:4])
  1571. case nl.IFLA_GRE_IKEY:
  1572. gre.OKey = ntohl(datum.Value[0:4])
  1573. case nl.IFLA_GRE_LOCAL:
  1574. gre.Local = net.IP(datum.Value[0:4])
  1575. case nl.IFLA_GRE_REMOTE:
  1576. gre.Remote = net.IP(datum.Value[0:4])
  1577. case nl.IFLA_GRE_IFLAGS:
  1578. gre.IFlags = ntohs(datum.Value[0:2])
  1579. case nl.IFLA_GRE_OFLAGS:
  1580. gre.OFlags = ntohs(datum.Value[0:2])
  1581. case nl.IFLA_GRE_TTL:
  1582. gre.Ttl = uint8(datum.Value[0])
  1583. case nl.IFLA_GRE_TOS:
  1584. gre.Tos = uint8(datum.Value[0])
  1585. case nl.IFLA_GRE_PMTUDISC:
  1586. gre.PMtuDisc = uint8(datum.Value[0])
  1587. }
  1588. }
  1589. }
  1590. func parseLinkStats32(data []byte) *LinkStatistics {
  1591. return (*LinkStatistics)((*LinkStatistics32)(unsafe.Pointer(&data[0:SizeofLinkStats32][0])).to64())
  1592. }
  1593. func parseLinkStats64(data []byte) *LinkStatistics {
  1594. return (*LinkStatistics)((*LinkStatistics64)(unsafe.Pointer(&data[0:SizeofLinkStats64][0])))
  1595. }
  1596. func addXdpAttrs(xdp *LinkXdp, req *nl.NetlinkRequest) {
  1597. attrs := nl.NewRtAttr(nl.IFLA_XDP|syscall.NLA_F_NESTED, nil)
  1598. b := make([]byte, 4)
  1599. native.PutUint32(b, uint32(xdp.Fd))
  1600. nl.NewRtAttrChild(attrs, nl.IFLA_XDP_FD, b)
  1601. if xdp.Flags != 0 {
  1602. native.PutUint32(b, xdp.Flags)
  1603. nl.NewRtAttrChild(attrs, nl.IFLA_XDP_FLAGS, b)
  1604. }
  1605. req.AddData(attrs)
  1606. }
  1607. func parseLinkXdp(data []byte) (*LinkXdp, error) {
  1608. attrs, err := nl.ParseRouteAttr(data)
  1609. if err != nil {
  1610. return nil, err
  1611. }
  1612. xdp := &LinkXdp{}
  1613. for _, attr := range attrs {
  1614. switch attr.Attr.Type {
  1615. case nl.IFLA_XDP_FD:
  1616. xdp.Fd = int(native.Uint32(attr.Value[0:4]))
  1617. case nl.IFLA_XDP_ATTACHED:
  1618. xdp.Attached = attr.Value[0] != 0
  1619. case nl.IFLA_XDP_FLAGS:
  1620. xdp.Flags = native.Uint32(attr.Value[0:4])
  1621. case nl.IFLA_XDP_PROG_ID:
  1622. xdp.ProgId = native.Uint32(attr.Value[0:4])
  1623. }
  1624. }
  1625. return xdp, nil
  1626. }
  1627. func addIptunAttrs(iptun *Iptun, linkInfo *nl.RtAttr) {
  1628. data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
  1629. ip := iptun.Local.To4()
  1630. if ip != nil {
  1631. nl.NewRtAttrChild(data, nl.IFLA_IPTUN_LOCAL, []byte(ip))
  1632. }
  1633. ip = iptun.Remote.To4()
  1634. if ip != nil {
  1635. nl.NewRtAttrChild(data, nl.IFLA_IPTUN_REMOTE, []byte(ip))
  1636. }
  1637. if iptun.Link != 0 {
  1638. nl.NewRtAttrChild(data, nl.IFLA_IPTUN_LINK, nl.Uint32Attr(iptun.Link))
  1639. }
  1640. nl.NewRtAttrChild(data, nl.IFLA_IPTUN_PMTUDISC, nl.Uint8Attr(iptun.PMtuDisc))
  1641. nl.NewRtAttrChild(data, nl.IFLA_IPTUN_TTL, nl.Uint8Attr(iptun.Ttl))
  1642. nl.NewRtAttrChild(data, nl.IFLA_IPTUN_TOS, nl.Uint8Attr(iptun.Tos))
  1643. }
  1644. func parseIptunData(link Link, data []syscall.NetlinkRouteAttr) {
  1645. iptun := link.(*Iptun)
  1646. for _, datum := range data {
  1647. switch datum.Attr.Type {
  1648. case nl.IFLA_IPTUN_LOCAL:
  1649. iptun.Local = net.IP(datum.Value[0:4])
  1650. case nl.IFLA_IPTUN_REMOTE:
  1651. iptun.Remote = net.IP(datum.Value[0:4])
  1652. case nl.IFLA_IPTUN_TTL:
  1653. iptun.Ttl = uint8(datum.Value[0])
  1654. case nl.IFLA_IPTUN_TOS:
  1655. iptun.Tos = uint8(datum.Value[0])
  1656. case nl.IFLA_IPTUN_PMTUDISC:
  1657. iptun.PMtuDisc = uint8(datum.Value[0])
  1658. }
  1659. }
  1660. }
  1661. func addVtiAttrs(vti *Vti, linkInfo *nl.RtAttr) {
  1662. data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
  1663. ip := vti.Local.To4()
  1664. if ip != nil {
  1665. nl.NewRtAttrChild(data, nl.IFLA_VTI_LOCAL, []byte(ip))
  1666. }
  1667. ip = vti.Remote.To4()
  1668. if ip != nil {
  1669. nl.NewRtAttrChild(data, nl.IFLA_VTI_REMOTE, []byte(ip))
  1670. }
  1671. if vti.Link != 0 {
  1672. nl.NewRtAttrChild(data, nl.IFLA_VTI_LINK, nl.Uint32Attr(vti.Link))
  1673. }
  1674. nl.NewRtAttrChild(data, nl.IFLA_VTI_IKEY, htonl(vti.IKey))
  1675. nl.NewRtAttrChild(data, nl.IFLA_VTI_OKEY, htonl(vti.OKey))
  1676. }
  1677. func parseVtiData(link Link, data []syscall.NetlinkRouteAttr) {
  1678. vti := link.(*Vti)
  1679. for _, datum := range data {
  1680. switch datum.Attr.Type {
  1681. case nl.IFLA_VTI_LOCAL:
  1682. vti.Local = net.IP(datum.Value[0:4])
  1683. case nl.IFLA_VTI_REMOTE:
  1684. vti.Remote = net.IP(datum.Value[0:4])
  1685. case nl.IFLA_VTI_IKEY:
  1686. vti.IKey = ntohl(datum.Value[0:4])
  1687. case nl.IFLA_VTI_OKEY:
  1688. vti.OKey = ntohl(datum.Value[0:4])
  1689. }
  1690. }
  1691. }
  1692. func addVrfAttrs(vrf *Vrf, linkInfo *nl.RtAttr) {
  1693. data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
  1694. b := make([]byte, 4)
  1695. native.PutUint32(b, uint32(vrf.Table))
  1696. nl.NewRtAttrChild(data, nl.IFLA_VRF_TABLE, b)
  1697. }
  1698. func parseVrfData(link Link, data []syscall.NetlinkRouteAttr) {
  1699. vrf := link.(*Vrf)
  1700. for _, datum := range data {
  1701. switch datum.Attr.Type {
  1702. case nl.IFLA_VRF_TABLE:
  1703. vrf.Table = native.Uint32(datum.Value[0:4])
  1704. }
  1705. }
  1706. }
  1707. func addBridgeAttrs(bridge *Bridge, linkInfo *nl.RtAttr) {
  1708. data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
  1709. if bridge.MulticastSnooping != nil {
  1710. nl.NewRtAttrChild(data, nl.IFLA_BR_MCAST_SNOOPING, boolToByte(*bridge.MulticastSnooping))
  1711. }
  1712. if bridge.HelloTime != nil {
  1713. nl.NewRtAttrChild(data, nl.IFLA_BR_HELLO_TIME, nl.Uint32Attr(*bridge.HelloTime))
  1714. }
  1715. }
  1716. func parseBridgeData(bridge Link, data []syscall.NetlinkRouteAttr) {
  1717. br := bridge.(*Bridge)
  1718. for _, datum := range data {
  1719. switch datum.Attr.Type {
  1720. case nl.IFLA_BR_HELLO_TIME:
  1721. helloTime := native.Uint32(datum.Value[0:4])
  1722. br.HelloTime = &helloTime
  1723. case nl.IFLA_BR_MCAST_SNOOPING:
  1724. mcastSnooping := datum.Value[0] == 1
  1725. br.MulticastSnooping = &mcastSnooping
  1726. }
  1727. }
  1728. }
  1729. func addGTPAttrs(gtp *GTP, linkInfo *nl.RtAttr) {
  1730. data := nl.NewRtAttrChild(linkInfo, nl.IFLA_INFO_DATA, nil)
  1731. nl.NewRtAttrChild(data, nl.IFLA_GTP_FD0, nl.Uint32Attr(uint32(gtp.FD0)))
  1732. nl.NewRtAttrChild(data, nl.IFLA_GTP_FD1, nl.Uint32Attr(uint32(gtp.FD1)))
  1733. nl.NewRtAttrChild(data, nl.IFLA_GTP_PDP_HASHSIZE, nl.Uint32Attr(131072))
  1734. if gtp.Role != nl.GTP_ROLE_GGSN {
  1735. nl.NewRtAttrChild(data, nl.IFLA_GTP_ROLE, nl.Uint32Attr(uint32(gtp.Role)))
  1736. }
  1737. }
  1738. func parseGTPData(link Link, data []syscall.NetlinkRouteAttr) {
  1739. gtp := link.(*GTP)
  1740. for _, datum := range data {
  1741. switch datum.Attr.Type {
  1742. case nl.IFLA_GTP_FD0:
  1743. gtp.FD0 = int(native.Uint32(datum.Value))
  1744. case nl.IFLA_GTP_FD1:
  1745. gtp.FD1 = int(native.Uint32(datum.Value))
  1746. case nl.IFLA_GTP_PDP_HASHSIZE:
  1747. gtp.PDPHashsize = int(native.Uint32(datum.Value))
  1748. case nl.IFLA_GTP_ROLE:
  1749. gtp.Role = int(native.Uint32(datum.Value))
  1750. }
  1751. }
  1752. }