link_linux.go 48 KB

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