diff options
Diffstat (limited to 'tun.go')
| -rw-r--r-- | tun.go | 26 |
1 files changed, 4 insertions, 22 deletions
@@ -7,30 +7,12 @@ package main import ( - "os" + "./tun" "sync/atomic" ) const DefaultMTU = 1420 -type TUNEvent int - -const ( - TUNEventUp = 1 << iota - TUNEventDown - TUNEventMTUUpdate -) - -type TUNDevice interface { - File() *os.File // returns the file descriptor of the device - Read([]byte, int) (int, error) // read a packet from the device (without any additional headers) - Write([]byte, int) (int, error) // writes a packet to the device (without any additional headers) - MTU() (int, error) // returns the MTU of the device - Name() (string, error) // fetches and returns the current name - Events() chan TUNEvent // returns a constant channel of events related to the device - Close() error // stops the device and closes the event channel -} - func (device *Device) RoutineTUNEventReader() { setUp := false logDebug := device.log.Debug @@ -41,7 +23,7 @@ func (device *Device) RoutineTUNEventReader() { device.state.starting.Done() for event := range device.tun.device.Events() { - if event&TUNEventMTUUpdate != 0 { + if event&tun.TUNEventMTUUpdate != 0 { mtu, err := device.tun.device.MTU() old := atomic.LoadInt32(&device.tun.mtu) if err != nil { @@ -56,13 +38,13 @@ func (device *Device) RoutineTUNEventReader() { } } - if event&TUNEventUp != 0 && !setUp { + if event&tun.TUNEventUp != 0 && !setUp { logInfo.Println("Interface set up") setUp = true device.Up() } - if event&TUNEventDown != 0 && setUp { + if event&tun.TUNEventDown != 0 && setUp { logInfo.Println("Interface set down") setUp = false device.Down() |