}
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)
}
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
}
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
}
continue
}
if !peer.PktProcess(buf[:i+govpn.NonceSize], tap, false) {
+ log.Println("Unauthenticated packet, dropping connection")
timeouted <- struct{}{}
break TransportCycle
}