github/vtun
5
0
Fork 0
mirror of https://github.com/net-byte/vtun synced 2024-03-14 10:50:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor

Browse Source
This commit is contained in:
netbyte 2021-09-23 22:31:49 +08:00
parent cbda10bcac
commit 9713cfe503
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tun/tun.go
View File

@ -15,9 +15,9 @@ func CreateTun(config config.Config) (iface *water.Interface) {
c := water.Config{DeviceType: water.TUN} c := water.Config{DeviceType: water.TUN}
iface, err := water.New(c) iface, err := water.New(c)
if err != nil { if err != nil {
log.Fatalln("failed to allocate TUN interface:", err) log.Fatalln("failed to create tun interface:", err)
} }
log.Println("interface allocated:", iface.Name()) log.Println("interface created:", iface.Name())
configTun(config, iface) configTun(config, iface)
return iface return iface
} }

4
udp/udpclient.go
View File

@ -27,7 +27,7 @@ func StartClient(config config.Config) {
} }
defer conn.Close() defer conn.Close()
log.Printf("vtun udp client started on %v", config.LocalAddr) log.Printf("vtun udp client started on %v", config.LocalAddr)
// read data from server // server -> client
go func() { go func() {
buf := make([]byte, 1500) buf := make([]byte, 1500)
for { for {
@ -47,7 +47,7 @@ func StartClient(config config.Config) {
iface.Write(b) iface.Write(b)
} }
}() }()
// read data from tun // client -> server
packet := make([]byte, 1500) packet := make([]byte, 1500)
for { for {
n, err := iface.Read(packet) n, err := iface.Read(packet)

2
udp/udpserver.go
View File

@ -36,7 +36,7 @@ func StartServer(config config.Config) {
log.Fatalln("failed to listen on udp socket:", err) log.Fatalln("failed to listen on udp socket:", err)
} }
defer conn.Close() defer conn.Close()
log.Printf("vtun udp server started on %v,CIDR is %v", config.LocalAddr, config.CIDR) log.Printf("vtun udp server started on %v", config.LocalAddr)
// server -> client // server -> client
reply := &Reply{localConn: conn, connCache: cache.New(30*time.Minute, 10*time.Minute)} reply := &Reply{localConn: conn, connCache: cache.New(30*time.Minute, 10*time.Minute)}
go reply.toClient(config, iface, conn) go reply.toClient(config, iface, conn)