diff --git a/gossip/comm/conn.go b/gossip/comm/conn.go index b0d7b327a3a..af5254d1e8e 100644 --- a/gossip/comm/conn.go +++ b/gossip/comm/conn.go @@ -165,7 +165,7 @@ func (cs *connectionStore) onConnected(serverStream proto.Gossip_GossipStreamSer cs.Lock() defer cs.Unlock() - if c, exists := cs.pki2Conn[string(connInfo.Identity)]; exists { + if c, exists := cs.pki2Conn[string(connInfo.ID)]; exists { c.close() }