}
}
-func regularConnString(nc net.Conn) string {
+// Creates the PeerConn.connString for a regular net.Conn PeerConn.
+func regularNetConnPeerConnConnString(nc net.Conn) string {
return fmt.Sprintf("%s-%s", nc.LocalAddr(), nc.RemoteAddr())
}
tc.SetLinger(0)
}
c := cl.newConnection(nc, false, nc.RemoteAddr(), nc.RemoteAddr().Network(),
- regularConnString(nc))
+ regularNetConnPeerConnConnString(nc))
c.Discovery = PeerSourceIncoming
cl.runReceivedConn(c)
}
}
return nil, errors.New("dial failed")
}
- c, err := cl.initiateProtocolHandshakes(context.Background(), nc, t, true, obfuscatedHeader, addr, dr.Network, regularConnString(nc))
+ c, err := cl.initiateProtocolHandshakes(context.Background(), nc, t, true, obfuscatedHeader, addr, dr.Network, regularNetConnPeerConnConnString(nc))
if err != nil {
nc.Close()
}
RemoteAddr: remoteAddr,
network: network,
- connString: connString,
},
+ connString: connString,
conn: nc,
writeBuffer: new(bytes.Buffer),
}