diff --git a/packages/gossip/transport/handshake.go b/packages/gossip/transport/handshake.go index 2be73aaba04ad1facaceb1e178cc60dd1c382f45..a33b332966593921b00101294c76ab8eed0f5b79 100644 --- a/packages/gossip/transport/handshake.go +++ b/packages/gossip/transport/handshake.go @@ -56,7 +56,7 @@ func (t *TCP) validateHandshakeRequest(reqData []byte, fromAddr string) bool { ) return false } - if m.GetTo() != t.pubIP { + if m.GetTo() != t.pubAddr { t.log.Debugw("invalid handshake", "to", m.GetTo(), ) diff --git a/packages/gossip/transport/transport.go b/packages/gossip/transport/transport.go index 83fd6eddc2ba39f54c2f58915c0d0ea281088e89..61690e0fb0d087ade9aac98c739215818ee7a501 100644 --- a/packages/gossip/transport/transport.go +++ b/packages/gossip/transport/transport.go @@ -41,7 +41,7 @@ const ( // TCP establishes verified incoming and outgoing TCP connections to other peers. type TCP struct { local *peer.Local - pubIP string + pubAddr string listener *net.TCPListener log *zap.SugaredLogger @@ -86,7 +86,7 @@ func Listen(local *peer.Local, log *zap.SugaredLogger) (*TCP, error) { return nil, ErrNoGossip } - t.pubIP = gossipAddr.String() + t.pubAddr = gossipAddr.String() host, port, _ := net.SplitHostPort(gossipAddr.String()) if host != "127.0.0.1" { @@ -304,7 +304,7 @@ func (t *TCP) listenLoop() { func (t *TCP) doHandshake(key peer.PublicKey, remoteAddr string, conn net.Conn) error { _, connPort, _ := net.SplitHostPort(conn.LocalAddr().String()) - from, _, _ := net.SplitHostPort(t.pubIP) + from, _, _ := net.SplitHostPort(t.pubAddr) reqData, err := newHandshakeRequest(from+":"+connPort, remoteAddr) if err != nil {