cwinfo/yggdrasil-go
5
0
Fork 0
mirror of https://github.com/cwinfo/yggdrasil-go.git synced 2024-12-22 19:55:39 +00:00
Code Releases Activity

Merge pull request #7 from neilalexander/master

Browse Source 
Fix MTU issues with TAP adapters
This commit is contained in:
Arceliar 2018-01-25 11:57:08 -06:00 committed by GitHub
commit 742a755bb7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 31 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/yggdrasil/tun.go
View File

@ -5,6 +5,7 @@ package yggdrasil
import ethernet "github.com/songgao/packets/ethernet"
const IPv6_HEADER_LENGTH = 40
const ETHER_HEADER_LENGTH = 14
type tunInterface interface {
IsTUN() bool
@ -40,13 +41,13 @@ func (tun *tunDevice) write() error {
ethernet.NotTagged, // VLAN tagging
ethernet.IPv6, // Ethertype
len(data)) // Payload length
copy(frame[14:], data[:])
copy(frame[ETHER_HEADER_LENGTH:], data[:])
if _, err := tun.iface.Write(frame); err != nil {
return err
panic(err)
}
} else {
if _, err := tun.iface.Write(data); err != nil {
return err
panic(err)
}
}
util_putBytes(data)
@ -54,15 +55,19 @@ func (tun *tunDevice) write() error {
}
func (tun *tunDevice) read() error {
buf := make([]byte, tun.mtu)
mtu := tun.mtu
if tun.iface.IsTAP() {
mtu += ETHER_HEADER_LENGTH
}
buf := make([]byte, mtu)
for {
n, err := tun.iface.Read(buf)
if err != nil {
return err
panic(err)
}
o := 0
if tun.iface.IsTAP() {
o = 14
o = ETHER_HEADER_LENGTH
b := make([]byte, n)
copy(b, buf)
tun.ndp.recv <- b

21
src/yggdrasil/tun_windows.go
View File

@ -39,12 +39,31 @@ func (tun *tunDevice) setup(ifname string, addr string, mtu int) error {
}
tun.iface = iface
tun.mtu = mtu
err = tun.setupMTU(tun.mtu)
if err != nil {
panic(err)
}
return tun.setupAddress(addr)
}
func (tun *tunDevice) setupMTU(mtu int) error {
// Set MTU
cmd := exec.Command("netsh", "interface", "ipv6", "set", "subinterface",
fmt.Sprintf("interface=%s", tun.iface.Name()),
fmt.Sprintf("mtu=%d", mtu),
"store=active")
tun.core.log.Printf("netsh command: %v", strings.Join(cmd.Args, " "))
output, err := cmd.CombinedOutput()
if err != nil {
tun.core.log.Printf("Windows netsh failed: %v.", err)
tun.core.log.Println(string(output))
return err
}
return nil
}
func (tun *tunDevice) setupAddress(addr string) error {
// Set address
// addr = strings.TrimRight(addr, "/8")
cmd := exec.Command("netsh", "interface", "ipv6", "add", "address",
fmt.Sprintf("interface=%s", tun.iface.Name()),
fmt.Sprintf("addr=%s", addr),