X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=src%2Fgovpn%2Fcmd%2Fgovpn-client%2Ftcp.go;h=7f3c172105ce0bf709ff15cbee4e549c55a4bca0;hb=933703051138e099c2fde03861278477058c3517;hp=e96d5bf41ccb52d1e8115d45be4afb3893126ec5;hpb=020a4f02b6ffe3bffd17ca6fd078278010e53025;p=govpn.git diff --git a/src/govpn/cmd/govpn-client/tcp.go b/src/govpn/cmd/govpn-client/tcp.go index e96d5bf..7f3c172 100644 --- a/src/govpn/cmd/govpn-client/tcp.go +++ b/src/govpn/cmd/govpn-client/tcp.go @@ -43,7 +43,7 @@ func startTCP(timeouted, rehandshaking, termination chan struct{}) { func handleTCP(conn *net.TCPConn, timeouted, rehandshaking, termination chan struct{}) { hs := govpn.HandshakeStart(*remoteAddr, conn, conf) - buf := make([]byte, govpn.MTU) + buf := make([]byte, 2*(govpn.EncLessEnlargeSize+govpn.MTU)+govpn.MTU) var n int var err error var prev int @@ -56,7 +56,7 @@ HandshakeCycle: break HandshakeCycle default: } - if prev == govpn.MTU { + if prev == len(buf) { log.Println("Timeouted waiting for the packet") timeouted <- struct{}{} break HandshakeCycle @@ -125,7 +125,7 @@ TransportCycle: break TransportCycle default: } - if prev == govpn.MTU { + if prev == len(buf) { log.Println("Timeouted waiting for the packet") timeouted <- struct{}{} break TransportCycle