12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667 |
- package nebula
- import (
- "fmt"
- "net"
- "os/exec"
- "strconv"
- "github.com/songgao/water"
- )
- type Tun struct {
- Device string
- Cidr *net.IPNet
- MTU int
- UnsafeRoutes []route
- *water.Interface
- }
- func newTun(deviceName string, cidr *net.IPNet, defaultMTU int, routes []route, unsafeRoutes []route, txQueueLen int) (ifce *Tun, err error) {
- if len(routes) > 0 {
- return nil, fmt.Errorf("Route MTU not supported in Darwin")
- }
- // NOTE: You cannot set the deviceName under Darwin, so you must check tun.Device after calling .Activate()
- return &Tun{
- Cidr: cidr,
- MTU: defaultMTU,
- UnsafeRoutes: unsafeRoutes,
- }, nil
- }
- func (c *Tun) Activate() error {
- var err error
- c.Interface, err = water.New(water.Config{
- DeviceType: water.TUN,
- })
- if err != nil {
- return fmt.Errorf("Activate failed: %v", err)
- }
- c.Device = c.Interface.Name()
- // TODO use syscalls instead of exec.Command
- if err = exec.Command("/sbin/ifconfig", c.Device, c.Cidr.String(), c.Cidr.IP.String()).Run(); err != nil {
- return fmt.Errorf("failed to run 'ifconfig': %s", err)
- }
- if err = exec.Command("/sbin/route", "-n", "add", "-net", c.Cidr.String(), "-interface", c.Device).Run(); err != nil {
- return fmt.Errorf("failed to run 'route add': %s", err)
- }
- if err = exec.Command("/sbin/ifconfig", c.Device, "mtu", strconv.Itoa(c.MTU)).Run(); err != nil {
- return fmt.Errorf("failed to run 'ifconfig': %s", err)
- }
- // Unsafe path routes
- for _, r := range c.UnsafeRoutes {
- if err = exec.Command("/sbin/route", "-n", "add", "-net", r.route.String(), "-interface", c.Device).Run(); err != nil {
- return fmt.Errorf("failed to run 'route add' for unsafe_route %s: %s", r.route.String(), err)
- }
- }
- return nil
- }
- func (c *Tun) WriteRaw(b []byte) error {
- _, err := c.Write(b)
- return err
- }
|