status-im/nim-chronos
2
0
Fork 0
mirror of https://github.com/status-im/nim-chronos.git synced 2025-01-23 09:48:54 +00:00
Code Issues Projects Releases Wiki Activity

Add support of TCP_NODELAY option for TCP transport.

Browse Source 
Bump version to 2.1.0.
This commit is contained in:
cheatfate 2018-08-27 21:41:11 +03:00
parent 530905f276
commit c84b8cb143
4 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
asyncdispatch2.nimble
View File

@ -1,5 +1,5 @@
packageName = "asyncdispatch2" packageName = "asyncdispatch2"
version = "2.0.9" version = "2.1.0"
author = "Status Research & Development GmbH" author = "Status Research & Development GmbH"
description = "Asyncdispatch2" description = "Asyncdispatch2"
license = "Apache License 2.0 or MIT" license = "Apache License 2.0 or MIT"

4
asyncdispatch2/handles.nim
View File

@ -13,10 +13,14 @@ when defined(windows):
import winlean import winlean
const const
asyncInvalidSocket* = AsyncFD(-1) asyncInvalidSocket* = AsyncFD(-1)
TCP_NODELAY* = 1
IPPROTO_TCP* = 6
else: else:
import posix import posix
const const
asyncInvalidSocket* = AsyncFD(posix.INVALID_SOCKET) asyncInvalidSocket* = AsyncFD(posix.INVALID_SOCKET)
TCP_NODELAY* = 1
IPPROTO_TCP* = 6
proc setSocketBlocking*(s: SocketHandle, blocking: bool): bool = proc setSocketBlocking*(s: SocketHandle, blocking: bool): bool =
## Sets blocking mode on socket. ## Sets blocking mode on socket.

2
asyncdispatch2/transports/common.nim
View File

@ -25,7 +25,7 @@ const
type type
ServerFlags* = enum ServerFlags* = enum
## Server's flags ## Server's flags
ReuseAddr, ReusePort, NoAutoRead, GCUserData ReuseAddr, ReusePort, TcpNoDelay, NoAutoRead, GCUserData
TransportAddress* = object TransportAddress* = object
## Transport network address ## Transport network address

8
asyncdispatch2/transports/stream.nim
View File

@ -853,6 +853,14 @@ proc createStreamServer*(host: TransportAddress,
serverSocket.closeSocket() serverSocket.closeSocket()
raiseTransportOsError(err) raiseTransportOsError(err)
if ServerFlags.TcpNoDelay in flags:
if not setSockOpt(serverSocket, handles.IPPROTO_TCP,
handles.TCP_NODELAY, 1):
let err = osLastError()
if sock == asyncInvalidSocket:
serverSocket.closeSocket()
raiseTransportOsError(err)
toSockAddr(host.address, host.port, saddr, slen) toSockAddr(host.address, host.port, saddr, slen)
if bindAddr(SocketHandle(serverSocket), cast[ptr SockAddr](addr saddr), if bindAddr(SocketHandle(serverSocket), cast[ptr SockAddr](addr saddr),
slen) != 0: slen) != 0: