duplicateConnsAvoided.Add(1)
return
}
+ dialTimeout := reducedDialTimeout(dialTimeout, me.halfOpenLimit, len(t.Peers))
t.HalfOpen[addr] = struct{}{}
go func() {
// Binding to the listen address and dialing via net.Dialer gives
// this address so that peers associate our local address with our
// listen address.
- dialTimeout := reducedDialTimeout(dialTimeout, me.halfOpenLimit, len(t.Peers))
// Initiate connections via TCP and UTP simultaneously. Use the first
// one that succeeds.
left := 2