}
}
- if (waittime >= 0)
+ if (waittime >= 0 && ret < 0)
{
struct timeval tv;
- fd_set rfds, wfds;
+ fd_set wfds;
- FD_ZERO(&rfds);
FD_ZERO(&wfds);
- FD_SET(sd, &rfds);
FD_SET(sd, &wfds);
tv.tv_sec = waittime / 1000;
tv.tv_usec = (waittime % 1000) * 1000;
- ret = select((int)sd+1, &rfds, &wfds, NULL, &tv);
+ ret = select((int)sd + 1, NULL, &wfds, NULL, &tv);
if (ret < 0)
{
SOCK_ERRNO;
sock_close(sd);
return -1;
}
- if (!FD_ISSET(sd, &rfds) && !FD_ISSET(sd, &wfds))
+ if (!FD_ISSET(sd, &wfds))
{
- errno = ECONNREFUSED;
- CHERROR("Cannot connect to port\n", "");
- PERROR(_("E902: Cannot connect to port"));
+ /* don't give an error, we just timed out. */
sock_close(sd);
return -1;
}
+ }
+ if (waittime >= 0)
+ {
#ifdef _WIN32
val = 0;
ioctlsocket(sd, FIONBIO, &val);
sleep 10m
call s:kill_server()
endfunc
+
+" Test that trying to connect to a non-existing port fails quickly.
+func Test_connect_waittime()
+ let start = reltime()
+ let handle = ch_open('localhost:9876')
+ if handle >= 0
+ " Oops, port does exists.
+ call ch_close(handle)
+ else
+ let elapsed = reltime(start)
+ call assert_true(elapsed < 1.0)
+ endif
+
+ let start = reltime()
+ let handle = ch_open('localhost:9867', {'waittime': 2000})
+ if handle >= 0
+ " Oops, port does exists.
+ call ch_close(handle)
+ else
+ " Failed connection doesn't wait the full time.
+ let elapsed = reltime(start)
+ call assert_true(elapsed < 1.0)
+ endif
+endfunc