summaryrefslogtreecommitdiffhomepage
path: root/src/device.go
diff options
context:
space:
mode:
authorMathias Hall-Andersen <mathias@hall-andersen.dk>2017-08-22 14:57:32 +0200
committerMathias Hall-Andersen <mathias@hall-andersen.dk>2017-08-22 14:57:32 +0200
commitc6d03ef17f34f7380d95e91a6091a06bce332979 (patch)
tree475cf096e8fd45b8787c1e7b9ecff90880edb043 /src/device.go
parent04640eb629f9c6a7bd4561f2a2f5b07195aa6009 (diff)
Update MTU based on netlink messages (linux)
Diffstat (limited to 'src/device.go')
-rw-r--r--src/device.go37
1 files changed, 0 insertions, 37 deletions
diff --git a/src/device.go b/src/device.go
index 9bcd2f5..2a0d0ca 100644
--- a/src/device.go
+++ b/src/device.go
@@ -176,43 +176,6 @@ func NewDevice(tun TUNDevice, logLevel int) *Device {
return device
}
-func (device *Device) RoutineTUNEventReader() {
- logInfo := device.log.Info
- logError := device.log.Error
-
- events := device.tun.device.Events()
-
- for event := range events {
- if event&TUNEventMTUUpdate != 0 {
- mtu, err := device.tun.device.MTU()
- if err != nil {
- logError.Println("Failed to load updated MTU of device:", err)
- } else {
- if mtu+MessageTransportSize > MaxMessageSize {
- mtu = MaxMessageSize - MessageTransportSize
- }
- atomic.StoreInt32(&device.tun.mtu, int32(mtu))
- }
- }
-
- if event&TUNEventUp != 0 {
- if !device.tun.isUp.Get() {
- device.tun.isUp.Set(true)
- updateUDPConn(device)
- logInfo.Println("Interface set up")
- }
- }
-
- if event&TUNEventDown != 0 {
- if device.tun.isUp.Get() {
- device.tun.isUp.Set(false)
- closeUDPConn(device)
- logInfo.Println("Interface set down")
- }
- }
- }
-}
-
func (device *Device) LookupPeer(pk NoisePublicKey) *Peer {
device.mutex.RLock()
defer device.mutex.RUnlock()