From aed3c7e7845fbde73f720d6c82f55453038fe460 Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Mon, 14 Jan 2019 14:25:52 +0000
Subject: [PATCH] Give nodeconfig to tun

---
 src/yggdrasil/adapter.go |  8 +++++---
 src/yggdrasil/core.go    | 17 ++++++++---------
 src/yggdrasil/tun.go     | 27 ++++++++++++++++++++++++++-
 3 files changed, 39 insertions(+), 13 deletions(-)

diff --git a/src/yggdrasil/adapter.go b/src/yggdrasil/adapter.go
index 7fb6a19..3ce80d2 100644
--- a/src/yggdrasil/adapter.go
+++ b/src/yggdrasil/adapter.go
@@ -3,9 +3,10 @@ package yggdrasil
 // Defines the minimum required struct members for an adapter type (this is
 // now the base type for tunAdapter in tun.go)
 type Adapter struct {
-	core *Core
-	send chan<- []byte
-	recv <-chan []byte
+	core        *Core
+	send        chan<- []byte
+	recv        <-chan []byte
+	reconfigure chan chan error
 }
 
 // Initialises the adapter.
@@ -13,4 +14,5 @@ func (adapter *Adapter) init(core *Core, send chan<- []byte, recv <-chan []byte)
 	adapter.core = core
 	adapter.send = send
 	adapter.recv = recv
+	adapter.reconfigure = make(chan chan error, 1)
 }
diff --git a/src/yggdrasil/core.go b/src/yggdrasil/core.go
index 7e10dbc..bee09ac 100644
--- a/src/yggdrasil/core.go
+++ b/src/yggdrasil/core.go
@@ -2,7 +2,6 @@ package yggdrasil
 
 import (
 	"encoding/hex"
-	"fmt"
 	"io/ioutil"
 	"log"
 	"net"
@@ -110,12 +109,13 @@ func (c *Core) UpdateConfig(config *config.NodeConfig) {
 
 	components := []chan chan error{
 		c.admin.reconfigure,
-		//c.searches.reconfigure,
-		//c.dht.reconfigure,
-		//c.sessions.reconfigure,
-		//c.peers.reconfigure,
-		//c.router.reconfigure,
-		//c.switchTable.reconfigure,
+		c.searches.reconfigure,
+		c.dht.reconfigure,
+		c.sessions.reconfigure,
+		c.peers.reconfigure,
+		c.router.reconfigure,
+		c.router.tun.reconfigure,
+		c.switchTable.reconfigure,
 		c.tcp.reconfigure,
 		c.multicast.reconfigure,
 	}
@@ -240,8 +240,7 @@ func (c *Core) Start(nc *config.NodeConfig, log *log.Logger) error {
 		return err
 	}
 
-	ip := net.IP(c.router.addr[:]).String()
-	if err := c.router.tun.start(nc.IfName, nc.IfTAPMode, fmt.Sprintf("%s/%d", ip, 8*len(address.GetPrefix())-1), nc.IfMTU); err != nil {
+	if err := c.router.tun.start(); err != nil {
 		c.log.Println("Failed to start TUN/TAP")
 		return err
 	}
diff --git a/src/yggdrasil/tun.go b/src/yggdrasil/tun.go
index 8c0f91d..0bda312 100644
--- a/src/yggdrasil/tun.go
+++ b/src/yggdrasil/tun.go
@@ -5,6 +5,8 @@ package yggdrasil
 import (
 	"bytes"
 	"errors"
+	"fmt"
+	"net"
 	"sync"
 	"time"
 
@@ -42,11 +44,34 @@ func getSupportedMTU(mtu int) int {
 func (tun *tunAdapter) init(core *Core, send chan<- []byte, recv <-chan []byte) {
 	tun.Adapter.init(core, send, recv)
 	tun.icmpv6.init(tun)
+	go func() {
+		for {
+			select {
+			case e := <-tun.reconfigure:
+				tun.core.configMutex.RLock()
+				updated := tun.core.config.IfName != tun.core.configOld.IfName ||
+					tun.core.config.IfTAPMode != tun.core.configOld.IfTAPMode ||
+					tun.core.config.IfMTU != tun.core.configOld.IfMTU
+				tun.core.configMutex.RUnlock()
+				if updated {
+					e <- nil
+				} else {
+					e <- nil
+				}
+			}
+		}
+	}()
 }
 
 // Starts the setup process for the TUN/TAP adapter, and if successful, starts
 // the read/write goroutines to handle packets on that interface.
-func (tun *tunAdapter) start(ifname string, iftapmode bool, addr string, mtu int) error {
+func (tun *tunAdapter) start() error {
+	tun.core.configMutex.RLock()
+	ifname := tun.core.config.IfName
+	iftapmode := tun.core.config.IfTAPMode
+	addr := fmt.Sprintf("%s/%d", net.IP(tun.core.router.addr[:]).String(), 8*len(address.GetPrefix())-1)
+	mtu := tun.core.config.IfMTU
+	tun.core.configMutex.RUnlock()
 	if ifname != "none" {
 		if err := tun.setup(ifname, iftapmode, addr, mtu); err != nil {
 			return err