zishuo/libp2p
1
0
Fork 0
mirror of https://github.com/libp2p/go-reuseport.git synced 2025-10-05 14:56:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

connect: try 3x

Browse Source
This commit is contained in:
Juan Batiz-Benet
2015-01-19 16:50:21 -08:00
parent b11afac096
commit fa34c52093
1 changed files with 19 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
impl_unix.go
View File

@@ -106,18 +106,27 @@ func dial(dialer net.Dialer, netw, addr string) (c net.Conn, err error) {
}
}
if fd, err = socket(rfamily, socktype, rprotocol); err != nil {
return nil, err
}
// look at dialTCP in http://golang.org/src/net/tcpsock_posix.go .... !
// here we just try again 3 times.
for i := 0; i < 3; i++ {
if fd, err = socket(rfamily, socktype, rprotocol); err != nil {
return nil, err
}
if err = syscall.Bind(fd, localSockaddr); err != nil {
// fmt.Println("bind failed")
syscall.Close(fd)
return nil, err
if err = syscall.Bind(fd, localSockaddr); err != nil {
// fmt.Println("bind failed")
syscall.Close(fd)
return nil, err
}
if err = connect(fd, remoteSockaddr); err != nil {
syscall.Close(fd)
// fmt.Println("connect failed", localSockaddr, err)
continue // try again.
}
break
}
if err = connect(fd, remoteSockaddr); err != nil {
syscall.Close(fd)
// fmt.Println("connect failed", localSockaddr, err)
if err != nil {
return nil, err
}