tun_linux.go 23 KB

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