nebula/overlay/tun_android.go

101 lines
2.1 KiB
Go
Raw Normal View History

2021-10-21 15:24:11 -06:00
//go:build !e2e_testing
// +build !e2e_testing
2021-11-11 15:37:29 -07:00
package overlay
2020-07-01 09:20:52 -06:00
import (
"fmt"
"io"
"net"
"os"
2024-03-28 14:17:28 -06:00
"sync/atomic"
2020-07-01 09:20:52 -06:00
2021-03-26 08:46:30 -06:00
"github.com/sirupsen/logrus"
"github.com/slackhq/nebula/cidr"
2024-03-28 14:17:28 -06:00
"github.com/slackhq/nebula/config"
"github.com/slackhq/nebula/iputil"
2024-03-28 14:17:28 -06:00
"github.com/slackhq/nebula/util"
2020-07-01 09:20:52 -06:00
)
type tun struct {
2020-07-01 09:20:52 -06:00
io.ReadWriteCloser
fd int
cidr *net.IPNet
2024-03-28 14:17:28 -06:00
Routes atomic.Pointer[[]Route]
routeTree atomic.Pointer[cidr.Tree4[iputil.VpnIp]]
l *logrus.Logger
2020-07-01 09:20:52 -06:00
}
2024-03-28 14:17:28 -06:00
func newTunFromFd(c *config.C, l *logrus.Logger, deviceFd int, cidr *net.IPNet) (*tun, error) {
// XXX Android returns an fd in non-blocking mode which is necessary for shutdown to work properly.
// Be sure not to call file.Fd() as it will set the fd to blocking mode.
2020-07-01 09:20:52 -06:00
file := os.NewFile(uintptr(deviceFd), "/dev/net/tun")
2024-03-28 14:17:28 -06:00
t := &tun{
2020-07-01 09:20:52 -06:00
ReadWriteCloser: file,
fd: deviceFd,
cidr: cidr,
2021-03-26 08:46:30 -06:00
l: l,
2024-03-28 14:17:28 -06:00
}
err := t.reload(c, true)
if err != nil {
return nil, err
}
c.RegisterReloadCallback(func(c *config.C) {
err := t.reload(c, false)
if err != nil {
util.LogWithContextIfNeeded("failed to reload tun device", err, t.l)
}
})
return t, nil
2020-07-01 09:20:52 -06:00
}
2024-03-28 14:17:28 -06:00
func newTun(_ *config.C, _ *logrus.Logger, _ *net.IPNet, _ bool) (*tun, error) {
2020-07-01 09:20:52 -06:00
return nil, fmt.Errorf("newTun not supported in Android")
}
func (t *tun) RouteFor(ip iputil.VpnIp) iputil.VpnIp {
2024-03-28 14:17:28 -06:00
_, r := t.routeTree.Load().MostSpecificContains(ip)
2023-12-06 14:18:21 -07:00
return r
}
func (t tun) Activate() error {
2020-07-01 09:20:52 -06:00
return nil
}
2024-03-28 14:17:28 -06:00
func (t *tun) reload(c *config.C, initial bool) error {
change, routes, err := getAllRoutesFromConfig(c, t.cidr, initial)
if err != nil {
return err
}
if !initial && !change {
return nil
}
routeTree, err := makeRouteTree(t.l, routes, false)
if err != nil {
return err
}
// Teach nebula how to handle the routes
t.Routes.Store(&routes)
t.routeTree.Store(routeTree)
return nil
}
func (t *tun) Cidr() *net.IPNet {
return t.cidr
}
func (t *tun) Name() string {
return "android"
}
func (t *tun) NewMultiQueueReader() (io.ReadWriteCloser, error) {
return nil, fmt.Errorf("TODO: multiqueue not implemented for android")
}