tun_linux.go 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904
  1. //go:build !android && !e2e_testing
  2. // +build !android,!e2e_testing
  3. package overlay
  4. import (
  5. "fmt"
  6. "io"
  7. "net"
  8. "net/netip"
  9. "os"
  10. "sync/atomic"
  11. "time"
  12. "unsafe"
  13. "github.com/gaissmai/bart"
  14. "github.com/sirupsen/logrus"
  15. "github.com/slackhq/nebula/config"
  16. "github.com/slackhq/nebula/routing"
  17. "github.com/slackhq/nebula/util"
  18. "github.com/vishvananda/netlink"
  19. "golang.org/x/sys/unix"
  20. wgtun "golang.zx2c4.com/wireguard/tun"
  21. )
  22. type tun struct {
  23. io.ReadWriteCloser
  24. wgDevice wgtun.Device
  25. fd int
  26. Device string
  27. vpnNetworks []netip.Prefix
  28. MaxMTU int
  29. DefaultMTU int
  30. TXQueueLen int
  31. deviceIndex int
  32. ioctlFd uintptr
  33. Routes atomic.Pointer[[]Route]
  34. routeTree atomic.Pointer[bart.Table[routing.Gateways]]
  35. routeChan chan struct{}
  36. useSystemRoutes bool
  37. useSystemRoutesBufferSize int
  38. l *logrus.Logger
  39. }
  40. func (t *tun) Networks() []netip.Prefix {
  41. return t.vpnNetworks
  42. }
  43. type ifReq struct {
  44. Name [16]byte
  45. Flags uint16
  46. pad [8]byte
  47. }
  48. type ifreqMTU struct {
  49. Name [16]byte
  50. MTU int32
  51. pad [8]byte
  52. }
  53. type ifreqQLEN struct {
  54. Name [16]byte
  55. Value int32
  56. pad [8]byte
  57. }
  58. const (
  59. virtioNetHdrLen = 10 // Size of virtio_net_hdr structure
  60. )
  61. // wgDeviceWrapper wraps a wireguard Device to implement io.ReadWriteCloser
  62. // This allows multiqueue readers to use the same wireguard Device batching as the main device
  63. type wgDeviceWrapper struct {
  64. dev wgtun.Device
  65. buf []byte // Reusable buffer for single packet reads
  66. }
  67. func (w *wgDeviceWrapper) Read(b []byte) (int, error) {
  68. // Use wireguard Device's batch API for single packet
  69. bufs := [][]byte{b}
  70. sizes := make([]int, 1)
  71. n, err := w.dev.Read(bufs, sizes, 0)
  72. if err != nil {
  73. return 0, err
  74. }
  75. if n == 0 {
  76. return 0, io.EOF
  77. }
  78. return sizes[0], nil
  79. }
  80. func (w *wgDeviceWrapper) Write(b []byte) (int, error) {
  81. // Check if buffer has the expected headroom pattern to avoid copy
  82. var buf []byte
  83. if cap(b) >= len(b)+virtioNetHdrLen {
  84. buf = b[:cap(b)]
  85. if len(buf) == len(b)+virtioNetHdrLen {
  86. // Perfect! Buffer has headroom, no copy needed
  87. buf = buf[:len(b)+virtioNetHdrLen]
  88. } else {
  89. // Unexpected capacity, safer to copy
  90. buf = make([]byte, virtioNetHdrLen+len(b))
  91. copy(buf[virtioNetHdrLen:], b)
  92. }
  93. } else {
  94. // No headroom, need to allocate and copy
  95. buf = make([]byte, virtioNetHdrLen+len(b))
  96. copy(buf[virtioNetHdrLen:], b)
  97. }
  98. bufs := [][]byte{buf}
  99. n, err := w.dev.Write(bufs, virtioNetHdrLen)
  100. if err != nil {
  101. return 0, err
  102. }
  103. if n == 0 {
  104. return 0, io.ErrShortWrite
  105. }
  106. return len(b), nil
  107. }
  108. func (w *wgDeviceWrapper) Close() error {
  109. return w.dev.Close()
  110. }
  111. // BatchRead implements batching for multiqueue readers
  112. func (w *wgDeviceWrapper) BatchRead(bufs [][]byte, sizes []int) (int, error) {
  113. return w.dev.Read(bufs, sizes, 0)
  114. }
  115. // BatchSize returns the optimal batch size
  116. func (w *wgDeviceWrapper) BatchSize() int {
  117. return w.dev.BatchSize()
  118. }
  119. func newTunFromFd(c *config.C, l *logrus.Logger, deviceFd int, vpnNetworks []netip.Prefix) (*tun, error) {
  120. wgDev, name, err := wgtun.CreateUnmonitoredTUNFromFD(deviceFd)
  121. if err != nil {
  122. return nil, fmt.Errorf("failed to create TUN from FD: %w", err)
  123. }
  124. file := wgDev.File()
  125. t, err := newTunGeneric(c, l, file, vpnNetworks)
  126. if err != nil {
  127. _ = wgDev.Close()
  128. return nil, err
  129. }
  130. t.wgDevice = wgDev
  131. t.Device = name
  132. return t, nil
  133. }
  134. func newTun(c *config.C, l *logrus.Logger, vpnNetworks []netip.Prefix, multiqueue bool) (*tun, error) {
  135. // Check if /dev/net/tun exists, create if needed (for docker containers)
  136. if _, err := os.Stat("/dev/net/tun"); os.IsNotExist(err) {
  137. if err := os.MkdirAll("/dev/net", 0755); err != nil {
  138. return nil, fmt.Errorf("/dev/net/tun doesn't exist, failed to mkdir -p /dev/net: %w", err)
  139. }
  140. if err := unix.Mknod("/dev/net/tun", unix.S_IFCHR|0600, int(unix.Mkdev(10, 200))); err != nil {
  141. return nil, fmt.Errorf("failed to create /dev/net/tun: %w", err)
  142. }
  143. }
  144. devName := c.GetString("tun.dev", "")
  145. mtu := c.GetInt("tun.mtu", DefaultMTU)
  146. // Create TUN device manually to support multiqueue
  147. fd, err := unix.Open("/dev/net/tun", os.O_RDWR, 0)
  148. if err != nil {
  149. return nil, err
  150. }
  151. var req ifReq
  152. req.Flags = uint16(unix.IFF_TUN | unix.IFF_NO_PI | unix.IFF_VNET_HDR)
  153. if multiqueue {
  154. req.Flags |= unix.IFF_MULTI_QUEUE
  155. }
  156. copy(req.Name[:], devName)
  157. if err = ioctl(uintptr(fd), uintptr(unix.TUNSETIFF), uintptr(unsafe.Pointer(&req))); err != nil {
  158. unix.Close(fd)
  159. return nil, err
  160. }
  161. // Set nonblocking
  162. if err = unix.SetNonblock(fd, true); err != nil {
  163. unix.Close(fd)
  164. return nil, err
  165. }
  166. // Enable TCP and UDP offload (TSO/GRO) for performance
  167. // This allows the kernel to handle segmentation/coalescing
  168. const (
  169. tunTCPOffloads = unix.TUN_F_CSUM | unix.TUN_F_TSO4 | unix.TUN_F_TSO6
  170. tunUDPOffloads = unix.TUN_F_USO4 | unix.TUN_F_USO6
  171. )
  172. offloads := tunTCPOffloads | tunUDPOffloads
  173. if err = unix.IoctlSetInt(fd, unix.TUNSETOFFLOAD, offloads); err != nil {
  174. // Log warning but don't fail - offload is optional
  175. l.WithError(err).Warn("Failed to enable TUN offload (TSO/GRO), performance may be reduced")
  176. }
  177. file := os.NewFile(uintptr(fd), "/dev/net/tun")
  178. // Create wireguard device from file descriptor
  179. wgDev, err := wgtun.CreateTUNFromFile(file, mtu)
  180. if err != nil {
  181. file.Close()
  182. return nil, fmt.Errorf("failed to create TUN from file: %w", err)
  183. }
  184. name, err := wgDev.Name()
  185. if err != nil {
  186. _ = wgDev.Close()
  187. return nil, fmt.Errorf("failed to get TUN device name: %w", err)
  188. }
  189. // file is now owned by wgDev, get a new reference
  190. file = wgDev.File()
  191. t, err := newTunGeneric(c, l, file, vpnNetworks)
  192. if err != nil {
  193. _ = wgDev.Close()
  194. return nil, err
  195. }
  196. t.wgDevice = wgDev
  197. t.Device = name
  198. return t, nil
  199. }
  200. func newTunGeneric(c *config.C, l *logrus.Logger, file *os.File, vpnNetworks []netip.Prefix) (*tun, error) {
  201. t := &tun{
  202. ReadWriteCloser: file,
  203. fd: int(file.Fd()),
  204. vpnNetworks: vpnNetworks,
  205. TXQueueLen: c.GetInt("tun.tx_queue", 500),
  206. useSystemRoutes: c.GetBool("tun.use_system_route_table", false),
  207. useSystemRoutesBufferSize: c.GetInt("tun.use_system_route_table_buffer_size", 0),
  208. l: l,
  209. }
  210. err := t.reload(c, true)
  211. if err != nil {
  212. return nil, err
  213. }
  214. c.RegisterReloadCallback(func(c *config.C) {
  215. err := t.reload(c, false)
  216. if err != nil {
  217. util.LogWithContextIfNeeded("failed to reload tun device", err, t.l)
  218. }
  219. })
  220. return t, nil
  221. }
  222. func (t *tun) reload(c *config.C, initial bool) error {
  223. routeChange, routes, err := getAllRoutesFromConfig(c, t.vpnNetworks, initial)
  224. if err != nil {
  225. return err
  226. }
  227. if !initial && !routeChange && !c.HasChanged("tun.mtu") {
  228. return nil
  229. }
  230. routeTree, err := makeRouteTree(t.l, routes, true)
  231. if err != nil {
  232. return err
  233. }
  234. oldDefaultMTU := t.DefaultMTU
  235. oldMaxMTU := t.MaxMTU
  236. newDefaultMTU := c.GetInt("tun.mtu", DefaultMTU)
  237. newMaxMTU := newDefaultMTU
  238. for i, r := range routes {
  239. if r.MTU == 0 {
  240. routes[i].MTU = newDefaultMTU
  241. }
  242. if r.MTU > t.MaxMTU {
  243. newMaxMTU = r.MTU
  244. }
  245. }
  246. t.MaxMTU = newMaxMTU
  247. t.DefaultMTU = newDefaultMTU
  248. // Teach nebula how to handle the routes before establishing them in the system table
  249. oldRoutes := t.Routes.Swap(&routes)
  250. t.routeTree.Store(routeTree)
  251. if !initial {
  252. if oldMaxMTU != newMaxMTU {
  253. t.setMTU()
  254. t.l.Infof("Set max MTU to %v was %v", t.MaxMTU, oldMaxMTU)
  255. }
  256. if oldDefaultMTU != newDefaultMTU {
  257. for i := range t.vpnNetworks {
  258. err := t.setDefaultRoute(t.vpnNetworks[i])
  259. if err != nil {
  260. t.l.Warn(err)
  261. } else {
  262. t.l.Infof("Set default MTU to %v was %v", t.DefaultMTU, oldDefaultMTU)
  263. }
  264. }
  265. }
  266. // Remove first, if the system removes a wanted route hopefully it will be re-added next
  267. t.removeRoutes(findRemovedRoutes(routes, *oldRoutes))
  268. // Ensure any routes we actually want are installed
  269. err = t.addRoutes(true)
  270. if err != nil {
  271. // This should never be called since addRoutes should log its own errors in a reload condition
  272. util.LogWithContextIfNeeded("Failed to refresh routes", err, t.l)
  273. }
  274. }
  275. return nil
  276. }
  277. func (t *tun) NewMultiQueueReader() (io.ReadWriteCloser, error) {
  278. fd, err := unix.Open("/dev/net/tun", os.O_RDWR, 0)
  279. if err != nil {
  280. return nil, err
  281. }
  282. var req ifReq
  283. // MUST match the flags used in newTun - includes IFF_VNET_HDR
  284. req.Flags = uint16(unix.IFF_TUN | unix.IFF_NO_PI | unix.IFF_VNET_HDR | unix.IFF_MULTI_QUEUE)
  285. copy(req.Name[:], t.Device)
  286. if err = ioctl(uintptr(fd), uintptr(unix.TUNSETIFF), uintptr(unsafe.Pointer(&req))); err != nil {
  287. unix.Close(fd)
  288. return nil, err
  289. }
  290. // Set nonblocking mode - CRITICAL for proper netpoller integration
  291. if err = unix.SetNonblock(fd, true); err != nil {
  292. unix.Close(fd)
  293. return nil, err
  294. }
  295. // Get MTU from main device
  296. mtu := t.MaxMTU
  297. if mtu == 0 {
  298. mtu = DefaultMTU
  299. }
  300. file := os.NewFile(uintptr(fd), "/dev/net/tun")
  301. // Create wireguard Device from the file descriptor (just like the main device)
  302. wgDev, err := wgtun.CreateTUNFromFile(file, mtu)
  303. if err != nil {
  304. file.Close()
  305. return nil, fmt.Errorf("failed to create multiqueue TUN device: %w", err)
  306. }
  307. // Return a wrapper that uses the wireguard Device for all I/O
  308. return &wgDeviceWrapper{dev: wgDev}, nil
  309. }
  310. func (t *tun) RoutesFor(ip netip.Addr) routing.Gateways {
  311. r, _ := t.routeTree.Load().Lookup(ip)
  312. return r
  313. }
  314. func (t *tun) Read(b []byte) (int, error) {
  315. if t.wgDevice != nil {
  316. // Use wireguard device which handles virtio headers internally
  317. bufs := [][]byte{b}
  318. sizes := make([]int, 1)
  319. n, err := t.wgDevice.Read(bufs, sizes, 0)
  320. if err != nil {
  321. return 0, err
  322. }
  323. if n == 0 {
  324. return 0, io.EOF
  325. }
  326. return sizes[0], nil
  327. }
  328. // Fallback: direct read from file (shouldn't happen in normal operation)
  329. return t.ReadWriteCloser.Read(b)
  330. }
  331. // BatchRead reads multiple packets at once for improved performance
  332. // bufs: slice of buffers to read into
  333. // sizes: slice that will be filled with packet sizes
  334. // Returns number of packets read
  335. func (t *tun) BatchRead(bufs [][]byte, sizes []int) (int, error) {
  336. if t.wgDevice != nil {
  337. return t.wgDevice.Read(bufs, sizes, 0)
  338. }
  339. // Fallback: single packet read
  340. n, err := t.ReadWriteCloser.Read(bufs[0])
  341. if err != nil {
  342. return 0, err
  343. }
  344. sizes[0] = n
  345. return 1, nil
  346. }
  347. // BatchSize returns the optimal number of packets to read/write in a batch
  348. func (t *tun) BatchSize() int {
  349. if t.wgDevice != nil {
  350. return t.wgDevice.BatchSize()
  351. }
  352. return 1
  353. }
  354. func (t *tun) Write(b []byte) (int, error) {
  355. if t.wgDevice != nil {
  356. // Use wireguard device which handles virtio headers internally
  357. // Check if buffer has the expected headroom pattern:
  358. // cap(b) should be len(b) + virtioNetHdrLen, indicating pre-allocated headroom
  359. var buf []byte
  360. if cap(b) >= len(b)+virtioNetHdrLen {
  361. // Buffer likely has headroom - use unsafe to access it
  362. // Create a slice that includes the headroom by re-slicing from capacity
  363. buf = b[:cap(b)]
  364. // Check if we have exactly the right amount of extra capacity
  365. if len(buf) == len(b)+virtioNetHdrLen {
  366. // Perfect! This buffer was allocated with headroom, no copy needed
  367. buf = buf[:len(b)+virtioNetHdrLen]
  368. } else {
  369. // Unexpected capacity, safer to copy
  370. buf = make([]byte, virtioNetHdrLen+len(b))
  371. copy(buf[virtioNetHdrLen:], b)
  372. }
  373. } else {
  374. // No headroom, need to allocate and copy
  375. buf = make([]byte, virtioNetHdrLen+len(b))
  376. copy(buf[virtioNetHdrLen:], b)
  377. }
  378. bufs := [][]byte{buf}
  379. n, err := t.wgDevice.Write(bufs, virtioNetHdrLen)
  380. if err != nil {
  381. return 0, err
  382. }
  383. if n == 0 {
  384. return 0, io.ErrShortWrite
  385. }
  386. return len(b), nil
  387. }
  388. // Fallback: direct write (shouldn't happen in normal operation)
  389. var nn int
  390. maximum := len(b)
  391. for {
  392. n, err := unix.Write(t.fd, b[nn:maximum])
  393. if n > 0 {
  394. nn += n
  395. }
  396. if nn == len(b) {
  397. return nn, err
  398. }
  399. if err != nil {
  400. return nn, err
  401. }
  402. if n == 0 {
  403. return nn, io.ErrUnexpectedEOF
  404. }
  405. }
  406. }
  407. func (t *tun) deviceBytes() (o [16]byte) {
  408. for i, c := range t.Device {
  409. o[i] = byte(c)
  410. }
  411. return
  412. }
  413. func hasNetlinkAddr(al []*netlink.Addr, x netlink.Addr) bool {
  414. for i := range al {
  415. if al[i].Equal(x) {
  416. return true
  417. }
  418. }
  419. return false
  420. }
  421. // addIPs uses netlink to add all addresses that don't exist, then it removes ones that should not be there
  422. func (t *tun) addIPs(link netlink.Link) error {
  423. newAddrs := make([]*netlink.Addr, len(t.vpnNetworks))
  424. for i := range t.vpnNetworks {
  425. newAddrs[i] = &netlink.Addr{
  426. IPNet: &net.IPNet{
  427. IP: t.vpnNetworks[i].Addr().AsSlice(),
  428. Mask: net.CIDRMask(t.vpnNetworks[i].Bits(), t.vpnNetworks[i].Addr().BitLen()),
  429. },
  430. Label: t.vpnNetworks[i].Addr().Zone(),
  431. }
  432. }
  433. //add all new addresses
  434. for i := range newAddrs {
  435. //AddrReplace still adds new IPs, but if their properties change it will change them as well
  436. if err := netlink.AddrReplace(link, newAddrs[i]); err != nil {
  437. return err
  438. }
  439. }
  440. //iterate over remainder, remove whoever shouldn't be there
  441. al, err := netlink.AddrList(link, netlink.FAMILY_ALL)
  442. if err != nil {
  443. return fmt.Errorf("failed to get tun address list: %s", err)
  444. }
  445. for i := range al {
  446. if hasNetlinkAddr(newAddrs, al[i]) {
  447. continue
  448. }
  449. err = netlink.AddrDel(link, &al[i])
  450. if err != nil {
  451. t.l.WithError(err).Error("failed to remove address from tun address list")
  452. } else {
  453. t.l.WithField("removed", al[i].String()).Info("removed address not listed in cert(s)")
  454. }
  455. }
  456. return nil
  457. }
  458. func (t *tun) Activate() error {
  459. devName := t.deviceBytes()
  460. if t.useSystemRoutes {
  461. t.watchRoutes()
  462. }
  463. s, err := unix.Socket(
  464. unix.AF_INET, //because everything we use t.ioctlFd for is address family independent, this is fine
  465. unix.SOCK_DGRAM,
  466. unix.IPPROTO_IP,
  467. )
  468. if err != nil {
  469. return err
  470. }
  471. t.ioctlFd = uintptr(s)
  472. // Set the device name
  473. ifrf := ifReq{Name: devName}
  474. if err = ioctl(t.ioctlFd, unix.SIOCGIFFLAGS, uintptr(unsafe.Pointer(&ifrf))); err != nil {
  475. return fmt.Errorf("failed to set tun device name: %s", err)
  476. }
  477. link, err := netlink.LinkByName(t.Device)
  478. if err != nil {
  479. return fmt.Errorf("failed to get tun device link: %s", err)
  480. }
  481. t.deviceIndex = link.Attrs().Index
  482. // Setup our default MTU
  483. t.setMTU()
  484. // Set the transmit queue length
  485. ifrq := ifreqQLEN{Name: devName, Value: int32(t.TXQueueLen)}
  486. if err = ioctl(t.ioctlFd, unix.SIOCSIFTXQLEN, uintptr(unsafe.Pointer(&ifrq))); err != nil {
  487. // If we can't set the queue length nebula will still work but it may lead to packet loss
  488. t.l.WithError(err).Error("Failed to set tun tx queue length")
  489. }
  490. const modeNone = 1
  491. if err = netlink.LinkSetIP6AddrGenMode(link, modeNone); err != nil {
  492. t.l.WithError(err).Warn("Failed to disable link local address generation")
  493. }
  494. if err = t.addIPs(link); err != nil {
  495. return err
  496. }
  497. // Bring up the interface
  498. ifrf.Flags = ifrf.Flags | unix.IFF_UP
  499. if err = ioctl(t.ioctlFd, unix.SIOCSIFFLAGS, uintptr(unsafe.Pointer(&ifrf))); err != nil {
  500. return fmt.Errorf("failed to bring the tun device up: %s", err)
  501. }
  502. //set route MTU
  503. for i := range t.vpnNetworks {
  504. if err = t.setDefaultRoute(t.vpnNetworks[i]); err != nil {
  505. return fmt.Errorf("failed to set default route MTU: %w", err)
  506. }
  507. }
  508. // Set the routes
  509. if err = t.addRoutes(false); err != nil {
  510. return err
  511. }
  512. // Run the interface
  513. ifrf.Flags = ifrf.Flags | unix.IFF_UP | unix.IFF_RUNNING
  514. if err = ioctl(t.ioctlFd, unix.SIOCSIFFLAGS, uintptr(unsafe.Pointer(&ifrf))); err != nil {
  515. return fmt.Errorf("failed to run tun device: %s", err)
  516. }
  517. return nil
  518. }
  519. func (t *tun) setMTU() {
  520. // Set the MTU on the device
  521. ifm := ifreqMTU{Name: t.deviceBytes(), MTU: int32(t.MaxMTU)}
  522. if err := ioctl(t.ioctlFd, unix.SIOCSIFMTU, uintptr(unsafe.Pointer(&ifm))); err != nil {
  523. // This is currently a non fatal condition because the route table must have the MTU set appropriately as well
  524. t.l.WithError(err).Error("Failed to set tun mtu")
  525. }
  526. }
  527. func (t *tun) setDefaultRoute(cidr netip.Prefix) error {
  528. dr := &net.IPNet{
  529. IP: cidr.Masked().Addr().AsSlice(),
  530. Mask: net.CIDRMask(cidr.Bits(), cidr.Addr().BitLen()),
  531. }
  532. nr := netlink.Route{
  533. LinkIndex: t.deviceIndex,
  534. Dst: dr,
  535. MTU: t.DefaultMTU,
  536. AdvMSS: t.advMSS(Route{}),
  537. Scope: unix.RT_SCOPE_LINK,
  538. Src: net.IP(cidr.Addr().AsSlice()),
  539. Protocol: unix.RTPROT_KERNEL,
  540. Table: unix.RT_TABLE_MAIN,
  541. Type: unix.RTN_UNICAST,
  542. }
  543. err := netlink.RouteReplace(&nr)
  544. if err != nil {
  545. t.l.WithError(err).WithField("cidr", cidr).Warn("Failed to set default route MTU, retrying")
  546. //retry twice more -- on some systems there appears to be a race condition where if we set routes too soon, netlink says `invalid argument`
  547. for i := 0; i < 2; i++ {
  548. time.Sleep(100 * time.Millisecond)
  549. err = netlink.RouteReplace(&nr)
  550. if err == nil {
  551. break
  552. } else {
  553. t.l.WithError(err).WithField("cidr", cidr).WithField("mtu", t.DefaultMTU).Warn("Failed to set default route MTU, retrying")
  554. }
  555. }
  556. if err != nil {
  557. return fmt.Errorf("failed to set mtu %v on the default route %v; %v", t.DefaultMTU, dr, err)
  558. }
  559. }
  560. return nil
  561. }
  562. func (t *tun) addRoutes(logErrors bool) error {
  563. // Path routes
  564. routes := *t.Routes.Load()
  565. for _, r := range routes {
  566. if !r.Install {
  567. continue
  568. }
  569. dr := &net.IPNet{
  570. IP: r.Cidr.Masked().Addr().AsSlice(),
  571. Mask: net.CIDRMask(r.Cidr.Bits(), r.Cidr.Addr().BitLen()),
  572. }
  573. nr := netlink.Route{
  574. LinkIndex: t.deviceIndex,
  575. Dst: dr,
  576. MTU: r.MTU,
  577. AdvMSS: t.advMSS(r),
  578. Scope: unix.RT_SCOPE_LINK,
  579. }
  580. if r.Metric > 0 {
  581. nr.Priority = r.Metric
  582. }
  583. err := netlink.RouteReplace(&nr)
  584. if err != nil {
  585. retErr := util.NewContextualError("Failed to add route", map[string]any{"route": r}, err)
  586. if logErrors {
  587. retErr.Log(t.l)
  588. } else {
  589. return retErr
  590. }
  591. } else {
  592. t.l.WithField("route", r).Info("Added route")
  593. }
  594. }
  595. return nil
  596. }
  597. func (t *tun) removeRoutes(routes []Route) {
  598. for _, r := range routes {
  599. if !r.Install {
  600. continue
  601. }
  602. dr := &net.IPNet{
  603. IP: r.Cidr.Masked().Addr().AsSlice(),
  604. Mask: net.CIDRMask(r.Cidr.Bits(), r.Cidr.Addr().BitLen()),
  605. }
  606. nr := netlink.Route{
  607. LinkIndex: t.deviceIndex,
  608. Dst: dr,
  609. MTU: r.MTU,
  610. AdvMSS: t.advMSS(r),
  611. Scope: unix.RT_SCOPE_LINK,
  612. }
  613. if r.Metric > 0 {
  614. nr.Priority = r.Metric
  615. }
  616. err := netlink.RouteDel(&nr)
  617. if err != nil {
  618. t.l.WithError(err).WithField("route", r).Error("Failed to remove route")
  619. } else {
  620. t.l.WithField("route", r).Info("Removed route")
  621. }
  622. }
  623. }
  624. func (t *tun) Name() string {
  625. return t.Device
  626. }
  627. func (t *tun) advMSS(r Route) int {
  628. mtu := r.MTU
  629. if r.MTU == 0 {
  630. mtu = t.DefaultMTU
  631. }
  632. // We only need to set advmss if the route MTU does not match the device MTU
  633. if mtu != t.MaxMTU {
  634. return mtu - 40
  635. }
  636. return 0
  637. }
  638. func (t *tun) watchRoutes() {
  639. rch := make(chan netlink.RouteUpdate)
  640. doneChan := make(chan struct{})
  641. netlinkOptions := netlink.RouteSubscribeOptions{
  642. ReceiveBufferSize: t.useSystemRoutesBufferSize,
  643. ReceiveBufferForceSize: t.useSystemRoutesBufferSize != 0,
  644. ErrorCallback: func(e error) { t.l.WithError(e).Errorf("netlink error") },
  645. }
  646. if err := netlink.RouteSubscribeWithOptions(rch, doneChan, netlinkOptions); err != nil {
  647. t.l.WithError(err).Errorf("failed to subscribe to system route changes")
  648. return
  649. }
  650. t.routeChan = doneChan
  651. go func() {
  652. for {
  653. select {
  654. case r, ok := <-rch:
  655. if ok {
  656. t.updateRoutes(r)
  657. } else {
  658. // may be should do something here as
  659. // netlink stops sending updates
  660. return
  661. }
  662. case <-doneChan:
  663. // netlink.RouteSubscriber will close the rch for us
  664. return
  665. }
  666. }
  667. }()
  668. }
  669. func (t *tun) isGatewayInVpnNetworks(gwAddr netip.Addr) bool {
  670. withinNetworks := false
  671. for i := range t.vpnNetworks {
  672. if t.vpnNetworks[i].Contains(gwAddr) {
  673. withinNetworks = true
  674. break
  675. }
  676. }
  677. return withinNetworks
  678. }
  679. func (t *tun) getGatewaysFromRoute(r *netlink.Route) routing.Gateways {
  680. var gateways routing.Gateways
  681. link, err := netlink.LinkByName(t.Device)
  682. if err != nil {
  683. t.l.WithField("Devicename", t.Device).Error("Ignoring route update: failed to get link by name")
  684. return gateways
  685. }
  686. // If this route is relevant to our interface and there is a gateway then add it
  687. if r.LinkIndex == link.Attrs().Index && len(r.Gw) > 0 {
  688. gwAddr, ok := netip.AddrFromSlice(r.Gw)
  689. if !ok {
  690. t.l.WithField("route", r).Debug("Ignoring route update, invalid gateway address")
  691. } else {
  692. gwAddr = gwAddr.Unmap()
  693. if !t.isGatewayInVpnNetworks(gwAddr) {
  694. // Gateway isn't in our overlay network, ignore
  695. t.l.WithField("route", r).Debug("Ignoring route update, not in our network")
  696. } else {
  697. gateways = append(gateways, routing.NewGateway(gwAddr, 1))
  698. }
  699. }
  700. }
  701. for _, p := range r.MultiPath {
  702. // If this route is relevant to our interface and there is a gateway then add it
  703. if p.LinkIndex == link.Attrs().Index && len(p.Gw) > 0 {
  704. gwAddr, ok := netip.AddrFromSlice(p.Gw)
  705. if !ok {
  706. t.l.WithField("route", r).Debug("Ignoring multipath route update, invalid gateway address")
  707. } else {
  708. gwAddr = gwAddr.Unmap()
  709. if !t.isGatewayInVpnNetworks(gwAddr) {
  710. // Gateway isn't in our overlay network, ignore
  711. t.l.WithField("route", r).Debug("Ignoring route update, not in our network")
  712. } else {
  713. // p.Hops+1 = weight of the route
  714. gateways = append(gateways, routing.NewGateway(gwAddr, p.Hops+1))
  715. }
  716. }
  717. }
  718. }
  719. routing.CalculateBucketsForGateways(gateways)
  720. return gateways
  721. }
  722. func (t *tun) updateRoutes(r netlink.RouteUpdate) {
  723. gateways := t.getGatewaysFromRoute(&r.Route)
  724. if len(gateways) == 0 {
  725. // No gateways relevant to our network, no routing changes required.
  726. t.l.WithField("route", r).Debug("Ignoring route update, no gateways")
  727. return
  728. }
  729. if r.Dst == nil {
  730. t.l.WithField("route", r).Debug("Ignoring route update, no destination address")
  731. return
  732. }
  733. dstAddr, ok := netip.AddrFromSlice(r.Dst.IP)
  734. if !ok {
  735. t.l.WithField("route", r).Debug("Ignoring route update, invalid destination address")
  736. return
  737. }
  738. ones, _ := r.Dst.Mask.Size()
  739. dst := netip.PrefixFrom(dstAddr, ones)
  740. newTree := t.routeTree.Load().Clone()
  741. if r.Type == unix.RTM_NEWROUTE {
  742. t.l.WithField("destination", dst).WithField("via", gateways).Info("Adding route")
  743. newTree.Insert(dst, gateways)
  744. } else {
  745. t.l.WithField("destination", dst).WithField("via", gateways).Info("Removing route")
  746. newTree.Delete(dst)
  747. }
  748. t.routeTree.Store(newTree)
  749. }
  750. func (t *tun) Close() error {
  751. if t.routeChan != nil {
  752. close(t.routeChan)
  753. }
  754. if t.wgDevice != nil {
  755. _ = t.wgDevice.Close()
  756. }
  757. if t.ReadWriteCloser != nil {
  758. _ = t.ReadWriteCloser.Close()
  759. }
  760. if t.ioctlFd > 0 {
  761. _ = os.NewFile(t.ioctlFd, "ioctlFd").Close()
  762. }
  763. return nil
  764. }