if err != nil {
log.Fatalln("Can not connect to address:", err)
}
- govpn.Println("Connected to TCP:" + *remoteAddr)
+ govpn.Printf(`[connected remote="%s"]`, *remoteAddr)
handleTCP(conn, timeouted, rehandshaking, termination)
}
default:
}
if prev == len(buf) {
- govpn.Println("Timeouted waiting for the packet")
+ govpn.Printf(`[packet-timeouted remote="%s"]`, *remoteAddr)
timeouted <- struct{}{}
break HandshakeCycle
}
conn.SetReadDeadline(time.Now().Add(time.Duration(timeout) * time.Second))
n, err = conn.Read(buf[prev:])
if err != nil {
- govpn.Println("Connection timeouted")
+ govpn.Printf(`[connection-timeouted remote="%s"]`, *remoteAddr)
timeouted <- struct{}{}
break HandshakeCycle
}
if peer == nil {
continue
}
- govpn.Println("Handshake completed")
+ govpn.Printf(`[handshake-completed remote="%s"]`, *remoteAddr)
knownPeers = govpn.KnownPeers(map[string]**govpn.Peer{*remoteAddr: &peer})
if firstUpCall {
go govpn.ScriptCall(*upPath, *ifaceName, *remoteAddr)
default:
}
if prev == len(buf) {
- govpn.Println("Timeouted waiting for the packet")
+ govpn.Printf(`[packet-timeouted remote="%s"]`, *remoteAddr)
timeouted <- struct{}{}
break TransportCycle
}
conn.SetReadDeadline(time.Now().Add(time.Duration(timeout) * time.Second))
n, err = conn.Read(buf[prev:])
if err != nil {
- govpn.Println("Connection timeouted")
+ govpn.Printf(`[connection-timeouted remote="%s"]`, *remoteAddr)
timeouted <- struct{}{}
break TransportCycle
}
continue
}
if !peer.PktProcess(buf[:i+govpn.NonceSize], tap, false) {
- govpn.Println("Unauthenticated packet, dropping connection")
+ govpn.Printf(`[packet-unauthenticated remote="%s"]`, *remoteAddr)
timeouted <- struct{}{}
break TransportCycle
}
if atomic.LoadUint64(&peer.BytesIn)+atomic.LoadUint64(&peer.BytesOut) > govpn.MaxBytesPerKey {
- govpn.Println("Need rehandshake")
+ govpn.Printf(`[rehandshake-required remote="%s"]`, *remoteAddr)
rehandshaking <- struct{}{}
break TransportCycle
}