diff options
Diffstat (limited to 'lib/pure/sockets.nim')
-rwxr-xr-x | lib/pure/sockets.nim | 30 |
1 files changed, 13 insertions, 17 deletions
diff --git a/lib/pure/sockets.nim b/lib/pure/sockets.nim index ae590c99f..564b76343 100755 --- a/lib/pure/sockets.nim +++ b/lib/pure/sockets.nim @@ -443,6 +443,11 @@ proc connectAsync*(socket: TSocket, name: string, port = TPort(0), if not success: OSError() +proc timeValFromMilliseconds(timeout = 500): TTimeVal = + if timeout != -1: + var seconds = timeout div 1000 + result.tv_sec = seconds + result.tv_usec = (timeout - seconds * 1000) * 1000 #proc recvfrom*(s: TWinSocket, buf: cstring, len, flags: cint, # fromm: ptr TSockAddr, fromlen: ptr cint): cint @@ -475,9 +480,7 @@ proc select*(readfds, writefds, exceptfds: var seq[TSocket], ## You can determine whether a socket is ready by checking if it's still ## in one of the TSocket sequences. - var tv: TTimeVal - tv.tv_sec = 0 - tv.tv_usec = timeout * 1000 + var tv {.noInit.}: TTimeVal = timeValFromMilliseconds(timeout) var rd, wr, ex: TFdSet var m = 0 @@ -495,10 +498,8 @@ proc select*(readfds, writefds, exceptfds: var seq[TSocket], pruneSocketSet(exceptfds, (ex)) proc select*(readfds, writefds: var seq[TSocket], - timeout = 500): int = - var tv: TTimeVal - tv.tv_sec = 0 - tv.tv_usec = timeout * 1000 + timeout = 500): int = + var tv {.noInit.}: TTimeVal = timeValFromMilliseconds(timeout) var rd, wr: TFdSet var m = 0 @@ -514,10 +515,8 @@ proc select*(readfds, writefds: var seq[TSocket], pruneSocketSet(writefds, (wr)) proc selectWrite*(writefds: var seq[TSocket], - timeout = 500): int = - var tv: TTimeVal - tv.tv_sec = 0 - tv.tv_usec = timeout * 1000 + timeout = 500): int = + var tv {.noInit.}: TTimeVal = timeValFromMilliseconds(timeout) var wr: TFdSet var m = 0 @@ -530,11 +529,8 @@ proc selectWrite*(writefds: var seq[TSocket], pruneSocketSet(writefds, (wr)) - -proc select*(readfds: var seq[TSocket], timeout = 500): int = - var tv: TTimeVal - tv.tv_sec = 0 - tv.tv_usec = timeout * 1000 +proc select*(readfds: var seq[TSocket], timeout = 500): int = + var tv {.noInit.}: TTimeVal = timeValFromMilliseconds(timeout) var rd: TFdSet var m = 0 @@ -643,7 +639,7 @@ proc skip*(socket: TSocket) = proc send*(socket: TSocket, data: pointer, size: int): int = ## sends data to a socket. - when defined(windows): + when defined(windows) or defined(macosx): result = send(cint(socket), data, size, 0'i32) else: result = send(cint(socket), data, size, int32(MSG_NOSIGNAL)) |