Merge pull request #822 from onionhammer/devel
Corrected prunesocketset and pruneprocessset
This commit is contained in:
commit
d23c2b5dcc
5 changed files with 6 additions and 6 deletions
|
|
@ -298,7 +298,7 @@ proc getLines(ftp: PFTPClient, async: bool = false): bool =
|
||||||
var readSocks: seq[TSocket] = @[ftp.getCSock()]
|
var readSocks: seq[TSocket] = @[ftp.getCSock()]
|
||||||
# This is only needed here. Asyncio gets this socket...
|
# This is only needed here. Asyncio gets this socket...
|
||||||
blockingOperation(ftp.getCSock()):
|
blockingOperation(ftp.getCSock()):
|
||||||
if readSocks.select(1) != 0 and ftp.getCSock() notin readSocks:
|
if readSocks.select(1) != 0 and ftp.getCSock() in readSocks:
|
||||||
assertReply ftp.expectReply(), "226"
|
assertReply ftp.expectReply(), "226"
|
||||||
return true
|
return true
|
||||||
|
|
||||||
|
|
@ -434,7 +434,7 @@ proc getFile(ftp: PFTPClient, async = false): bool =
|
||||||
if not async:
|
if not async:
|
||||||
var readSocks: seq[TSocket] = @[ftp.getCSock()]
|
var readSocks: seq[TSocket] = @[ftp.getCSock()]
|
||||||
blockingOperation(ftp.getCSock()):
|
blockingOperation(ftp.getCSock()):
|
||||||
if readSocks.select(1) != 0 and ftp.getCSock() notin readSocks:
|
if readSocks.select(1) != 0 and ftp.getCSock() in readSocks:
|
||||||
assertReply ftp.expectReply(), "226"
|
assertReply ftp.expectReply(), "226"
|
||||||
return true
|
return true
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -346,7 +346,7 @@ proc poll*(irc: PIRC, ev: var TIRCEvent,
|
||||||
var line = TaintedString""
|
var line = TaintedString""
|
||||||
var socks = @[irc.sock]
|
var socks = @[irc.sock]
|
||||||
var ret = socks.select(timeout)
|
var ret = socks.select(timeout)
|
||||||
if socks.len() == 0 and ret != 0:
|
if socks.len() != 0 and ret != 0:
|
||||||
irc.sock.readLine(line)
|
irc.sock.readLine(line)
|
||||||
ev = irc.processLine(line.string)
|
ev = irc.processLine(line.string)
|
||||||
result = true
|
result = true
|
||||||
|
|
|
||||||
|
|
@ -800,7 +800,7 @@ elif not defined(useNimRtl):
|
||||||
var i = 0
|
var i = 0
|
||||||
var L = s.len
|
var L = s.len
|
||||||
while i < L:
|
while i < L:
|
||||||
if FD_ISSET(cint(s[i].outHandle), fd) != 0'i32:
|
if FD_ISSET(cint(s[i].outHandle), fd) == 0'i32:
|
||||||
s[i] = s[L-1]
|
s[i] = s[L-1]
|
||||||
dec(L)
|
dec(L)
|
||||||
else:
|
else:
|
||||||
|
|
|
||||||
|
|
@ -119,7 +119,7 @@ proc next*(s: var TScgistate, timeout: int = -1): bool =
|
||||||
## request, if ``timeout`` is `-1` then this function will never time out.
|
## request, if ``timeout`` is `-1` then this function will never time out.
|
||||||
## Returns `True` if a new request has been processed.
|
## Returns `True` if a new request has been processed.
|
||||||
var rsocks = @[s.server]
|
var rsocks = @[s.server]
|
||||||
if select(rsocks, timeout) == 1 and rsocks.len == 0:
|
if select(rsocks, timeout) == 1 and rsocks.len == 1:
|
||||||
new(s.client)
|
new(s.client)
|
||||||
accept(s.server, s.client)
|
accept(s.server, s.client)
|
||||||
var L = 0
|
var L = 0
|
||||||
|
|
|
||||||
|
|
@ -928,7 +928,7 @@ proc pruneSocketSet(s: var seq[TSocket], fd: var TFdSet) =
|
||||||
var i = 0
|
var i = 0
|
||||||
var L = s.len
|
var L = s.len
|
||||||
while i < L:
|
while i < L:
|
||||||
if FD_ISSET(s[i].fd, fd) != 0'i32:
|
if FD_ISSET(s[i].fd, fd) == 0'i32:
|
||||||
s[i] = s[L-1]
|
s[i] = s[L-1]
|
||||||
dec(L)
|
dec(L)
|
||||||
else:
|
else:
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue