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

proper waiting

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

8
impl_unix.go
View File

@@ -314,6 +314,7 @@ func connect(fd int, ra syscall.Sockaddr) error {
}
var err error
start := time.Now()
for {
// if err := fd.pd.WaitWrite(); err != nil {
// return err
@@ -321,7 +322,8 @@ func connect(fd int, ra syscall.Sockaddr) error {
// i'd use the above fd.pd.WaitWrite to poll io correctly, just like net sockets...
// but of course, it uses fucking runtime_* functions that _cannot_ be used by
// non-go-stdlib source... seriously guys, what kind of bullshit is that!?
<-time.After(20 * time.Microsecond)
// we're relegated to using syscall.Select (what nightmare that is) or using
// a simple but totally bogus time-based wait. garbage.
var nerr int
nerr, err = syscall.GetsockoptInt(fd, syscall.SOL_SOCKET, syscall.SO_ERROR)
if err != nil {
@@ -329,6 +331,10 @@ func connect(fd int, ra syscall.Sockaddr) error {
}
switch err = syscall.Errno(nerr); err {
case syscall.EINPROGRESS, syscall.EALREADY, syscall.EINTR:
if time.Now().Sub(start) > time.Second {
return err
}
<-time.After(20 * time.Microsecond)
case syscall.Errno(0), syscall.EISCONN:
return nil
default: