Linux async fixes.
This commit is contained in:
parent
ac8ddb0720
commit
2158952917
1 changed files with 2 additions and 2 deletions
|
|
@ -722,7 +722,7 @@ else:
|
||||||
proc cb(sock: TAsyncFD): bool =
|
proc cb(sock: TAsyncFD): bool =
|
||||||
result = true
|
result = true
|
||||||
let res = recv(sock.TSocketHandle, addr readBuffer[0], size.cint,
|
let res = recv(sock.TSocketHandle, addr readBuffer[0], size.cint,
|
||||||
flags.cint)
|
flags.toOSFlags())
|
||||||
#echo("recv cb res: ", res)
|
#echo("recv cb res: ", res)
|
||||||
if res < 0:
|
if res < 0:
|
||||||
let lastError = osLastError()
|
let lastError = osLastError()
|
||||||
|
|
@ -760,7 +760,7 @@ else:
|
||||||
let lastError = osLastError()
|
let lastError = osLastError()
|
||||||
if lastError.int32 notin {EINTR, EWOULDBLOCK, EAGAIN}:
|
if lastError.int32 notin {EINTR, EWOULDBLOCK, EAGAIN}:
|
||||||
if flags.isDisconnectionError(lastError):
|
if flags.isDisconnectionError(lastError):
|
||||||
retFuture.complete("")
|
retFuture.complete()
|
||||||
else:
|
else:
|
||||||
retFuture.fail(newException(EOS, osErrorMsg(lastError)))
|
retFuture.fail(newException(EOS, osErrorMsg(lastError)))
|
||||||
else:
|
else:
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue