X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=src%2Fgovpn%2Fcmd%2Fgovpn-client%2Ftcp.go;h=9a1794a59d6c30f0cb4e586a8d3a342b67c3f356;hb=5f47616ee56e27e66ebd10acef1aa84cc0b4779d;hp=511955c4400a8a48d8e337e45a9b7b57b2d8443a;hpb=d20ad6088e1b9a90cebef28901ed3ece9f970f15;p=govpn.git diff --git a/src/govpn/cmd/govpn-client/tcp.go b/src/govpn/cmd/govpn-client/tcp.go index 511955c..9a1794a 100644 --- a/src/govpn/cmd/govpn-client/tcp.go +++ b/src/govpn/cmd/govpn-client/tcp.go @@ -36,8 +36,9 @@ func startTCP(timeouted, rehandshaking, termination chan struct{}) { } conn, err := net.DialTCP("tcp", nil, remote) if err != nil { - log.Fatalln("Can not connect to remote address:", err) + log.Fatalln("Can not connect to address:", err) } + log.Println("Connected to TCP:" + *remoteAddr) handleTCP(conn, timeouted, rehandshaking, termination) } @@ -57,13 +58,16 @@ HandshakeCycle: default: } if prev == govpn.MTU { + log.Println("Timeouted waiting for the packet") + timeouted <- struct{}{} break HandshakeCycle } conn.SetReadDeadline(time.Now().Add(time.Duration(timeout) * time.Second)) n, err = conn.Read(buf[prev:]) if err != nil { - // Either EOFed or timeouted + log.Println("Connection timeouted") + timeouted <- struct{}{} break HandshakeCycle } @@ -124,13 +128,14 @@ TransportCycle: default: } if prev == govpn.MTU { + log.Println("Timeouted waiting for the packet") timeouted <- struct{}{} break TransportCycle } conn.SetReadDeadline(time.Now().Add(time.Duration(timeout) * time.Second)) n, err = conn.Read(buf[prev:]) if err != nil { - // Either EOFed or timeouted + log.Println("Connection timeouted") timeouted <- struct{}{} break TransportCycle } @@ -144,6 +149,7 @@ TransportCycle: continue } if !peer.PktProcess(buf[:i+govpn.NonceSize], tap, false) { + log.Println("Unauthenticated packet, dropping connection") timeouted <- struct{}{} break TransportCycle }