Merge branch 'devel' into unify_waitpid_handling
This commit is contained in:
commit
77109d4c7b
14 changed files with 425 additions and 54 deletions
|
|
@ -888,10 +888,11 @@ proc genObjectFields(m: BModule, typ: PType, n: PNode, expr: Rope) =
|
||||||
else: internalError(n.info, "genObjectFields(nkRecCase)")
|
else: internalError(n.info, "genObjectFields(nkRecCase)")
|
||||||
of nkSym:
|
of nkSym:
|
||||||
var field = n.sym
|
var field = n.sym
|
||||||
addf(m.s[cfsTypeInit3], "$1.kind = 1;$n" &
|
if field.bitsize == 0:
|
||||||
"$1.offset = offsetof($2, $3);$n" & "$1.typ = $4;$n" &
|
addf(m.s[cfsTypeInit3], "$1.kind = 1;$n" &
|
||||||
"$1.name = $5;$n", [expr, getTypeDesc(m, typ),
|
"$1.offset = offsetof($2, $3);$n" & "$1.typ = $4;$n" &
|
||||||
field.loc.r, genTypeInfo(m, field.typ), makeCString(field.name.s)])
|
"$1.name = $5;$n", [expr, getTypeDesc(m, typ),
|
||||||
|
field.loc.r, genTypeInfo(m, field.typ), makeCString(field.name.s)])
|
||||||
else: internalError(n.info, "genObjectFields")
|
else: internalError(n.info, "genObjectFields")
|
||||||
|
|
||||||
proc genObjectInfo(m: BModule, typ, origType: PType, name: Rope) =
|
proc genObjectInfo(m: BModule, typ, origType: PType, name: Rope) =
|
||||||
|
|
|
||||||
|
|
@ -354,6 +354,12 @@ proc store*(ftp: AsyncFtpClient, file, dest: string,
|
||||||
|
|
||||||
await doUpload(ftp, destFile, onProgressChanged)
|
await doUpload(ftp, destFile, onProgressChanged)
|
||||||
|
|
||||||
|
proc rename*(ftp: AsyncFtpClient, nameFrom: string, nameTo: string) {.async.} =
|
||||||
|
## Rename a file or directory on the remote FTP Server from current name
|
||||||
|
## ``name_from`` to new name ``name_to``
|
||||||
|
assertReply(await ftp.send("RNFR " & name_from), "350")
|
||||||
|
assertReply(await ftp.send("RNTO " & name_to), "250")
|
||||||
|
|
||||||
proc newAsyncFtpClient*(address: string, port = Port(21),
|
proc newAsyncFtpClient*(address: string, port = Port(21),
|
||||||
user, pass = ""): AsyncFtpClient =
|
user, pass = ""): AsyncFtpClient =
|
||||||
## Creates a new ``AsyncFtpClient`` object.
|
## Creates a new ``AsyncFtpClient`` object.
|
||||||
|
|
@ -373,6 +379,7 @@ when not defined(testing) and isMainModule:
|
||||||
echo await ftp.listDirs()
|
echo await ftp.listDirs()
|
||||||
await ftp.store("payload.jpg", "payload.jpg")
|
await ftp.store("payload.jpg", "payload.jpg")
|
||||||
await ftp.retrFile("payload.jpg", "payload2.jpg")
|
await ftp.retrFile("payload.jpg", "payload2.jpg")
|
||||||
|
await ftp.rename("payload.jpg", "payload_renamed.jpg")
|
||||||
echo("Finished")
|
echo("Finished")
|
||||||
|
|
||||||
waitFor main(ftp)
|
waitFor main(ftp)
|
||||||
|
|
|
||||||
|
|
@ -41,9 +41,11 @@ type
|
||||||
## changing in the request.
|
## changing in the request.
|
||||||
HttpOptions, ## Returns the HTTP methods that the server supports
|
HttpOptions, ## Returns the HTTP methods that the server supports
|
||||||
## for specified address.
|
## for specified address.
|
||||||
HttpConnect ## Converts the request connection to a transparent
|
HttpConnect, ## Converts the request connection to a transparent
|
||||||
## TCP/IP tunnel, usually used for proxies.
|
## TCP/IP tunnel, usually used for proxies.
|
||||||
|
HttpPatch ## Added in RFC 5789. Can be used to update partial
|
||||||
|
## resources. The set of changes is represented in a
|
||||||
|
## format called a "patch document".
|
||||||
{.deprecated: [httpGet: HttpGet, httpHead: HttpHead, httpPost: HttpPost,
|
{.deprecated: [httpGet: HttpGet, httpHead: HttpHead, httpPost: HttpPost,
|
||||||
httpPut: HttpPut, httpDelete: HttpDelete, httpTrace: HttpTrace,
|
httpPut: HttpPut, httpDelete: HttpDelete, httpTrace: HttpTrace,
|
||||||
httpOptions: HttpOptions, httpConnect: HttpConnect].}
|
httpOptions: HttpOptions, httpConnect: HttpConnect].}
|
||||||
|
|
|
||||||
|
|
@ -44,14 +44,21 @@ when defined(nimdoc):
|
||||||
|
|
||||||
Event* {.pure.} = enum
|
Event* {.pure.} = enum
|
||||||
## An enum which hold event types
|
## An enum which hold event types
|
||||||
Read, ## Descriptor is available for read
|
Read, ## Descriptor is available for read
|
||||||
Write, ## Descriptor is available for write
|
Write, ## Descriptor is available for write
|
||||||
Timer, ## Timer descriptor is completed
|
Timer, ## Timer descriptor is completed
|
||||||
Signal, ## Signal is raised
|
Signal, ## Signal is raised
|
||||||
Process, ## Process is finished
|
Process, ## Process is finished
|
||||||
Vnode, ## Currently not supported
|
Vnode, ## BSD specific file change happens
|
||||||
User, ## User event is raised
|
User, ## User event is raised
|
||||||
Error ## Error happens while waiting, for descriptor
|
Error, ## Error happens while waiting, for descriptor
|
||||||
|
VnodeWrite, ## NOTE_WRITE (BSD specific, write to file occured)
|
||||||
|
VnodeDelete, ## NOTE_DELETE (BSD specific, unlink of file occured)
|
||||||
|
VnodeExtend, ## NOTE_EXTEND (BSD specific, file extended)
|
||||||
|
VnodeAttrib, ## NOTE_ATTRIB (BSD specific, file attributes changed)
|
||||||
|
VnodeLink, ## NOTE_LINK (BSD specific, file link count changed)
|
||||||
|
VnodeRename, ## NOTE_RENAME (BSD specific, file renamed)
|
||||||
|
VnodeRevoke ## NOTE_REVOKE (BSD specific, file revoke occured)
|
||||||
|
|
||||||
ReadyKey*[T] = object
|
ReadyKey*[T] = object
|
||||||
## An object which holds result for descriptor
|
## An object which holds result for descriptor
|
||||||
|
|
@ -107,6 +114,15 @@ when defined(nimdoc):
|
||||||
## ``data`` application-defined data, which to be passed, when
|
## ``data`` application-defined data, which to be passed, when
|
||||||
## ``ev`` happens.
|
## ``ev`` happens.
|
||||||
|
|
||||||
|
proc registerVnode*[T](s: Selector[T], fd: cint, events: set[Event],
|
||||||
|
data: T) =
|
||||||
|
## Registers selector BSD/MacOSX specific vnode events for file
|
||||||
|
## descriptor ``fd`` and events ``events``.
|
||||||
|
## ``data`` application-defined data, which to be passed, when
|
||||||
|
## vnode event happens.
|
||||||
|
##
|
||||||
|
## This function is supported only by BSD and MacOSX.
|
||||||
|
|
||||||
proc newSelectEvent*(): SelectEvent =
|
proc newSelectEvent*(): SelectEvent =
|
||||||
## Creates new event ``SelectEvent``.
|
## Creates new event ``SelectEvent``.
|
||||||
|
|
||||||
|
|
@ -194,7 +210,9 @@ else:
|
||||||
deallocShared(cast[pointer](sa))
|
deallocShared(cast[pointer](sa))
|
||||||
type
|
type
|
||||||
Event* {.pure.} = enum
|
Event* {.pure.} = enum
|
||||||
Read, Write, Timer, Signal, Process, Vnode, User, Error, Oneshot
|
Read, Write, Timer, Signal, Process, Vnode, User, Error, Oneshot,
|
||||||
|
VnodeWrite, VnodeDelete, VnodeExtend, VnodeAttrib, VnodeLink,
|
||||||
|
VnodeRename, VnodeRevoke
|
||||||
|
|
||||||
ReadyKey*[T] = object
|
ReadyKey*[T] = object
|
||||||
fd* : int
|
fd* : int
|
||||||
|
|
|
||||||
|
|
@ -262,6 +262,30 @@ proc registerEvent*[T](s: Selector[T], ev: SelectEvent, data: T) =
|
||||||
modifyKQueue(s, fdi.uint, EVFILT_READ, EV_ADD, 0, 0, nil)
|
modifyKQueue(s, fdi.uint, EVFILT_READ, EV_ADD, 0, 0, nil)
|
||||||
inc(s.count)
|
inc(s.count)
|
||||||
|
|
||||||
|
template processVnodeEvents(events: set[Event]): cuint =
|
||||||
|
var rfflags = 0.cuint
|
||||||
|
if events == {Event.VnodeWrite, Event.VnodeDelete, Event.VnodeExtend,
|
||||||
|
Event.VnodeAttrib, Event.VnodeLink, Event.VnodeRename,
|
||||||
|
Event.VnodeRevoke}:
|
||||||
|
rfflags = NOTE_DELETE or NOTE_WRITE or NOTE_EXTEND or NOTE_ATTRIB or
|
||||||
|
NOTE_LINK or NOTE_RENAME or NOTE_REVOKE
|
||||||
|
else:
|
||||||
|
if Event.VnodeDelete in events: rfflags = rfflags or NOTE_DELETE
|
||||||
|
if Event.VnodeWrite in events: rfflags = rfflags or NOTE_WRITE
|
||||||
|
if Event.VnodeExtend in events: rfflags = rfflags or NOTE_EXTEND
|
||||||
|
if Event.VnodeAttrib in events: rfflags = rfflags or NOTE_ATTRIB
|
||||||
|
if Event.VnodeLink in events: rfflags = rfflags or NOTE_LINK
|
||||||
|
if Event.VnodeRename in events: rfflags = rfflags or NOTE_RENAME
|
||||||
|
if Event.VnodeRevoke in events: rfflags = rfflags or NOTE_REVOKE
|
||||||
|
rfflags
|
||||||
|
|
||||||
|
proc registerVnode*[T](s: Selector[T], fd: cint, events: set[Event], data: T) =
|
||||||
|
let fdi = fd.int
|
||||||
|
setKey(s, fdi, fdi, {Event.Vnode} + events, 0, data)
|
||||||
|
var fflags = processVnodeEvents(events)
|
||||||
|
modifyKQueue(s, fdi.uint, EVFILT_VNODE, EV_ADD or EV_CLEAR, fflags, 0, nil)
|
||||||
|
inc(s.count)
|
||||||
|
|
||||||
proc unregister*[T](s: Selector[T], fd: int|SocketHandle) =
|
proc unregister*[T](s: Selector[T], fd: int|SocketHandle) =
|
||||||
let fdi = int(fd)
|
let fdi = int(fd)
|
||||||
s.checkFd(fdi)
|
s.checkFd(fdi)
|
||||||
|
|
@ -295,6 +319,9 @@ proc unregister*[T](s: Selector[T], fd: int|SocketHandle) =
|
||||||
discard posix.close(cint(pkey.key.fd))
|
discard posix.close(cint(pkey.key.fd))
|
||||||
modifyKQueue(s, fdi.uint, EVFILT_PROC, EV_DELETE, 0, 0, nil)
|
modifyKQueue(s, fdi.uint, EVFILT_PROC, EV_DELETE, 0, 0, nil)
|
||||||
dec(s.count)
|
dec(s.count)
|
||||||
|
elif Event.Vnode in pkey.events:
|
||||||
|
modifyKQueue(s, fdi.uint, EVFILT_VNODE, EV_DELETE, 0, 0, nil)
|
||||||
|
dec(s.count)
|
||||||
elif Event.User in pkey.events:
|
elif Event.User in pkey.events:
|
||||||
modifyKQueue(s, fdi.uint, EVFILT_READ, EV_DELETE, 0, 0, nil)
|
modifyKQueue(s, fdi.uint, EVFILT_READ, EV_DELETE, 0, 0, nil)
|
||||||
dec(s.count)
|
dec(s.count)
|
||||||
|
|
@ -392,6 +419,20 @@ proc selectInto*[T](s: Selector[T], timeout: int,
|
||||||
of EVFILT_VNODE:
|
of EVFILT_VNODE:
|
||||||
pkey = addr(s.fds[kevent.ident.int])
|
pkey = addr(s.fds[kevent.ident.int])
|
||||||
pkey.key.events = {Event.Vnode}
|
pkey.key.events = {Event.Vnode}
|
||||||
|
if (kevent.fflags and NOTE_DELETE) != 0:
|
||||||
|
pkey.key.events.incl(Event.VnodeDelete)
|
||||||
|
if (kevent.fflags and NOTE_WRITE) != 0:
|
||||||
|
pkey.key.events.incl(Event.VnodeWrite)
|
||||||
|
if (kevent.fflags and NOTE_EXTEND) != 0:
|
||||||
|
pkey.key.events.incl(Event.VnodeExtend)
|
||||||
|
if (kevent.fflags and NOTE_ATTRIB) != 0:
|
||||||
|
pkey.key.events.incl(Event.VnodeAttrib)
|
||||||
|
if (kevent.fflags and NOTE_LINK) != 0:
|
||||||
|
pkey.key.events.incl(Event.VnodeLink)
|
||||||
|
if (kevent.fflags and NOTE_RENAME) != 0:
|
||||||
|
pkey.key.events.incl(Event.VnodeRename)
|
||||||
|
if (kevent.fflags and NOTE_REVOKE) != 0:
|
||||||
|
pkey.key.events.incl(Event.VnodeRevoke)
|
||||||
of EVFILT_SIGNAL:
|
of EVFILT_SIGNAL:
|
||||||
pkey = addr(s.fds[cast[int](kevent.udata)])
|
pkey = addr(s.fds[cast[int](kevent.udata)])
|
||||||
pkey.key.events = {Event.Signal}
|
pkey.key.events = {Event.Signal}
|
||||||
|
|
|
||||||
|
|
@ -101,8 +101,8 @@ type
|
||||||
|
|
||||||
# shared:
|
# shared:
|
||||||
var
|
var
|
||||||
bottomData: AvlNode
|
bottomData {.threadvar.}: AvlNode
|
||||||
bottom: PAvlNode
|
bottom {.threadvar.}: PAvlNode
|
||||||
|
|
||||||
{.push stack_trace: off.}
|
{.push stack_trace: off.}
|
||||||
proc initAllocator() =
|
proc initAllocator() =
|
||||||
|
|
|
||||||
|
|
@ -9,7 +9,7 @@
|
||||||
|
|
||||||
# not really an AVL tree anymore, but still balanced ...
|
# not really an AVL tree anymore, but still balanced ...
|
||||||
|
|
||||||
template isBottom(n: PAvlNode): bool = n == bottom
|
template isBottom(n: PAvlNode): bool = n.link[0] == n
|
||||||
|
|
||||||
proc lowGauge(n: PAvlNode): int =
|
proc lowGauge(n: PAvlNode): int =
|
||||||
var it = n
|
var it = n
|
||||||
|
|
@ -52,7 +52,7 @@ proc split(t: var PAvlNode) =
|
||||||
inc t.level
|
inc t.level
|
||||||
|
|
||||||
proc add(a: var MemRegion, t: var PAvlNode, key, upperBound: int) {.benign.} =
|
proc add(a: var MemRegion, t: var PAvlNode, key, upperBound: int) {.benign.} =
|
||||||
if t == bottom:
|
if t.isBottom:
|
||||||
t = allocAvlNode(a, key, upperBound)
|
t = allocAvlNode(a, key, upperBound)
|
||||||
else:
|
else:
|
||||||
if key <% t.key:
|
if key <% t.key:
|
||||||
|
|
@ -65,14 +65,14 @@ proc add(a: var MemRegion, t: var PAvlNode, key, upperBound: int) {.benign.} =
|
||||||
split(t)
|
split(t)
|
||||||
|
|
||||||
proc del(a: var MemRegion, t: var PAvlNode, x: int) {.benign.} =
|
proc del(a: var MemRegion, t: var PAvlNode, x: int) {.benign.} =
|
||||||
if t == bottom: return
|
if isBottom(t): return
|
||||||
a.last = t
|
a.last = t
|
||||||
if x <% t.key:
|
if x <% t.key:
|
||||||
del(a, t.link[0], x)
|
del(a, t.link[0], x)
|
||||||
else:
|
else:
|
||||||
a.deleted = t
|
a.deleted = t
|
||||||
del(a, t.link[1], x)
|
del(a, t.link[1], x)
|
||||||
if t == a.last and a.deleted != bottom and x == a.deleted.key:
|
if t == a.last and not isBottom(a.deleted) and x == a.deleted.key:
|
||||||
a.deleted.key = t.key
|
a.deleted.key = t.key
|
||||||
a.deleted.upperBound = t.upperBound
|
a.deleted.upperBound = t.upperBound
|
||||||
a.deleted = bottom
|
a.deleted = bottom
|
||||||
|
|
|
||||||
|
|
@ -52,6 +52,7 @@ proc deinitRawChannel(p: pointer) =
|
||||||
|
|
||||||
proc storeAux(dest, src: pointer, mt: PNimType, t: PRawChannel,
|
proc storeAux(dest, src: pointer, mt: PNimType, t: PRawChannel,
|
||||||
mode: LoadStoreMode) {.benign.}
|
mode: LoadStoreMode) {.benign.}
|
||||||
|
|
||||||
proc storeAux(dest, src: pointer, n: ptr TNimNode, t: PRawChannel,
|
proc storeAux(dest, src: pointer, n: ptr TNimNode, t: PRawChannel,
|
||||||
mode: LoadStoreMode) {.benign.} =
|
mode: LoadStoreMode) {.benign.} =
|
||||||
var
|
var
|
||||||
|
|
@ -71,6 +72,9 @@ proc storeAux(dest, src: pointer, n: ptr TNimNode, t: PRawChannel,
|
||||||
|
|
||||||
proc storeAux(dest, src: pointer, mt: PNimType, t: PRawChannel,
|
proc storeAux(dest, src: pointer, mt: PNimType, t: PRawChannel,
|
||||||
mode: LoadStoreMode) =
|
mode: LoadStoreMode) =
|
||||||
|
template `+!`(p: pointer; x: int): pointer =
|
||||||
|
cast[pointer](cast[int](p) +% x)
|
||||||
|
|
||||||
var
|
var
|
||||||
d = cast[ByteAddress](dest)
|
d = cast[ByteAddress](dest)
|
||||||
s = cast[ByteAddress](src)
|
s = cast[ByteAddress](src)
|
||||||
|
|
@ -93,7 +97,9 @@ proc storeAux(dest, src: pointer, mt: PNimType, t: PRawChannel,
|
||||||
if s2 == nil:
|
if s2 == nil:
|
||||||
unsureAsgnRef(x, s2)
|
unsureAsgnRef(x, s2)
|
||||||
else:
|
else:
|
||||||
unsureAsgnRef(x, copyString(cast[NimString](s2)))
|
let y = copyDeepString(cast[NimString](s2))
|
||||||
|
#echo "loaded ", cast[int](y), " ", cast[string](y)
|
||||||
|
unsureAsgnRef(x, y)
|
||||||
dealloc(t.region, s2)
|
dealloc(t.region, s2)
|
||||||
of tySequence:
|
of tySequence:
|
||||||
var s2 = cast[PPointer](src)[]
|
var s2 = cast[PPointer](src)[]
|
||||||
|
|
@ -107,26 +113,27 @@ proc storeAux(dest, src: pointer, mt: PNimType, t: PRawChannel,
|
||||||
else:
|
else:
|
||||||
sysAssert(dest != nil, "dest == nil")
|
sysAssert(dest != nil, "dest == nil")
|
||||||
if mode == mStore:
|
if mode == mStore:
|
||||||
x[] = alloc(t.region, seq.len *% mt.base.size +% GenericSeqSize)
|
x[] = alloc0(t.region, seq.len *% mt.base.size +% GenericSeqSize)
|
||||||
else:
|
else:
|
||||||
unsureAsgnRef(x, newObj(mt, seq.len * mt.base.size + GenericSeqSize))
|
unsureAsgnRef(x, newObj(mt, seq.len * mt.base.size + GenericSeqSize))
|
||||||
var dst = cast[ByteAddress](cast[PPointer](dest)[])
|
var dst = cast[ByteAddress](cast[PPointer](dest)[])
|
||||||
|
var dstseq = cast[PGenericSeq](dst)
|
||||||
|
dstseq.len = seq.len
|
||||||
|
dstseq.reserved = seq.len
|
||||||
for i in 0..seq.len-1:
|
for i in 0..seq.len-1:
|
||||||
storeAux(
|
storeAux(
|
||||||
cast[pointer](dst +% i*% mt.base.size +% GenericSeqSize),
|
cast[pointer](dst +% i*% mt.base.size +% GenericSeqSize),
|
||||||
cast[pointer](cast[ByteAddress](s2) +% i *% mt.base.size +%
|
cast[pointer](cast[ByteAddress](s2) +% i *% mt.base.size +%
|
||||||
GenericSeqSize),
|
GenericSeqSize),
|
||||||
mt.base, t, mode)
|
mt.base, t, mode)
|
||||||
var dstseq = cast[PGenericSeq](dst)
|
|
||||||
dstseq.len = seq.len
|
|
||||||
dstseq.reserved = seq.len
|
|
||||||
if mode != mStore: dealloc(t.region, s2)
|
if mode != mStore: dealloc(t.region, s2)
|
||||||
of tyObject:
|
of tyObject:
|
||||||
# copy type field:
|
|
||||||
var pint = cast[ptr PNimType](dest)
|
|
||||||
pint[] = cast[ptr PNimType](src)[]
|
|
||||||
if mt.base != nil:
|
if mt.base != nil:
|
||||||
storeAux(dest, src, mt.base, t, mode)
|
storeAux(dest, src, mt.base, t, mode)
|
||||||
|
else:
|
||||||
|
# copy type field:
|
||||||
|
var pint = cast[ptr PNimType](dest)
|
||||||
|
pint[] = cast[ptr PNimType](src)[]
|
||||||
storeAux(dest, src, mt.node, t, mode)
|
storeAux(dest, src, mt.node, t, mode)
|
||||||
of tyTuple:
|
of tyTuple:
|
||||||
storeAux(dest, src, mt.node, t, mode)
|
storeAux(dest, src, mt.node, t, mode)
|
||||||
|
|
@ -143,15 +150,24 @@ proc storeAux(dest, src: pointer, mt: PNimType, t: PRawChannel,
|
||||||
else:
|
else:
|
||||||
unsureAsgnRef(x, nil)
|
unsureAsgnRef(x, nil)
|
||||||
else:
|
else:
|
||||||
let size = if mt.base.kind == tyObject: cast[ptr PNimType](s)[].size
|
#let size = if mt.base.kind == tyObject: cast[ptr PNimType](s)[].size
|
||||||
else: mt.base.size
|
# else: mt.base.size
|
||||||
if mode == mStore:
|
if mode == mStore:
|
||||||
x[] = alloc(t.region, size)
|
let dyntype = when declared(usrToCell): usrToCell(s).typ
|
||||||
|
else: mt
|
||||||
|
let size = dyntype.base.size
|
||||||
|
# we store the real dynamic 'ref type' at offset 0, so that
|
||||||
|
# no information is lost
|
||||||
|
let a = alloc0(t.region, size+sizeof(pointer))
|
||||||
|
x[] = a
|
||||||
|
cast[PPointer](a)[] = dyntype
|
||||||
|
storeAux(a +! sizeof(pointer), s, dyntype.base, t, mode)
|
||||||
else:
|
else:
|
||||||
var obj = newObj(mt, size)
|
let dyntype = cast[ptr PNimType](s)[]
|
||||||
|
var obj = newObj(dyntype, dyntype.base.size)
|
||||||
unsureAsgnRef(x, obj)
|
unsureAsgnRef(x, obj)
|
||||||
storeAux(x[], s, mt.base, t, mode)
|
storeAux(x[], s +! sizeof(pointer), dyntype.base, t, mode)
|
||||||
if mode != mStore: dealloc(t.region, s)
|
dealloc(t.region, s)
|
||||||
else:
|
else:
|
||||||
copyMem(dest, src, mt.size) # copy raw bits
|
copyMem(dest, src, mt.size) # copy raw bits
|
||||||
|
|
||||||
|
|
@ -194,10 +210,8 @@ template sendImpl(q: expr) {.immediate.} =
|
||||||
if q.mask == ChannelDeadMask:
|
if q.mask == ChannelDeadMask:
|
||||||
sysFatal(DeadThreadError, "cannot send message; thread died")
|
sysFatal(DeadThreadError, "cannot send message; thread died")
|
||||||
acquireSys(q.lock)
|
acquireSys(q.lock)
|
||||||
var m: TMsg
|
|
||||||
shallowCopy(m, msg)
|
|
||||||
var typ = cast[PNimType](getTypeInfo(msg))
|
var typ = cast[PNimType](getTypeInfo(msg))
|
||||||
rawSend(q, addr(m), typ)
|
rawSend(q, unsafeAddr(msg), typ)
|
||||||
q.elemType = typ
|
q.elemType = typ
|
||||||
releaseSys(q.lock)
|
releaseSys(q.lock)
|
||||||
signalSysCond(q.cond)
|
signalSysCond(q.cond)
|
||||||
|
|
@ -228,8 +242,10 @@ proc recv*[TMsg](c: var Channel[TMsg]): TMsg =
|
||||||
|
|
||||||
proc tryRecv*[TMsg](c: var Channel[TMsg]): tuple[dataAvailable: bool,
|
proc tryRecv*[TMsg](c: var Channel[TMsg]): tuple[dataAvailable: bool,
|
||||||
msg: TMsg] =
|
msg: TMsg] =
|
||||||
## try to receives a message from the channel `c` if available. Otherwise
|
## Tries to receive a message from the channel `c`, but this can fail
|
||||||
## it returns ``(false, default(msg))``.
|
## for all sort of reasons, including contention. If it fails,
|
||||||
|
## it returns ``(false, default(msg))`` otherwise it
|
||||||
|
## returns ``(true, msg)``.
|
||||||
var q = cast[PRawChannel](addr(c))
|
var q = cast[PRawChannel](addr(c))
|
||||||
if q.mask != ChannelDeadMask:
|
if q.mask != ChannelDeadMask:
|
||||||
if tryAcquireSys(q.lock):
|
if tryAcquireSys(q.lock):
|
||||||
|
|
|
||||||
|
|
@ -32,12 +32,6 @@ proc genericDeepCopyAux(dest, src: pointer, n: ptr TNimNode) {.benign.} =
|
||||||
genericDeepCopyAux(dest, src, m)
|
genericDeepCopyAux(dest, src, m)
|
||||||
of nkNone: sysAssert(false, "genericDeepCopyAux")
|
of nkNone: sysAssert(false, "genericDeepCopyAux")
|
||||||
|
|
||||||
proc copyDeepString(src: NimString): NimString {.inline.} =
|
|
||||||
if src != nil:
|
|
||||||
result = rawNewStringNoInit(src.len)
|
|
||||||
result.len = src.len
|
|
||||||
copyMem(addr(result.data), addr(src.data), src.len + 1)
|
|
||||||
|
|
||||||
proc genericDeepCopyAux(dest, src: pointer, mt: PNimType) =
|
proc genericDeepCopyAux(dest, src: pointer, mt: PNimType) =
|
||||||
var
|
var
|
||||||
d = cast[ByteAddress](dest)
|
d = cast[ByteAddress](dest)
|
||||||
|
|
@ -70,10 +64,11 @@ proc genericDeepCopyAux(dest, src: pointer, mt: PNimType) =
|
||||||
of tyObject:
|
of tyObject:
|
||||||
# we need to copy m_type field for tyObject, as it could be empty for
|
# we need to copy m_type field for tyObject, as it could be empty for
|
||||||
# sequence reallocations:
|
# sequence reallocations:
|
||||||
var pint = cast[ptr PNimType](dest)
|
|
||||||
pint[] = cast[ptr PNimType](src)[]
|
|
||||||
if mt.base != nil:
|
if mt.base != nil:
|
||||||
genericDeepCopyAux(dest, src, mt.base)
|
genericDeepCopyAux(dest, src, mt.base)
|
||||||
|
else:
|
||||||
|
var pint = cast[ptr PNimType](dest)
|
||||||
|
pint[] = cast[ptr PNimType](src)[]
|
||||||
genericDeepCopyAux(dest, src, mt.node)
|
genericDeepCopyAux(dest, src, mt.node)
|
||||||
of tyTuple:
|
of tyTuple:
|
||||||
genericDeepCopyAux(dest, src, mt.node)
|
genericDeepCopyAux(dest, src, mt.node)
|
||||||
|
|
@ -103,16 +98,16 @@ proc genericDeepCopyAux(dest, src: pointer, mt: PNimType) =
|
||||||
else:
|
else:
|
||||||
let realType = x.typ
|
let realType = x.typ
|
||||||
let z = newObj(realType, realType.base.size)
|
let z = newObj(realType, realType.base.size)
|
||||||
|
|
||||||
unsureAsgnRef(cast[PPointer](dest), z)
|
unsureAsgnRef(cast[PPointer](dest), z)
|
||||||
x.typ = cast[PNimType](cast[int](z) or 1)
|
x.typ = cast[PNimType](cast[int](z) or 1)
|
||||||
genericDeepCopyAux(z, s2, realType.base)
|
genericDeepCopyAux(z, s2, realType.base)
|
||||||
x.typ = realType
|
x.typ = realType
|
||||||
else:
|
else:
|
||||||
let realType = mt
|
let size = if mt.base.kind == tyObject: cast[ptr PNimType](s2)[].size
|
||||||
let z = newObj(realType, realType.base.size)
|
else: mt.base.size
|
||||||
|
let z = newObj(mt, size)
|
||||||
unsureAsgnRef(cast[PPointer](dest), z)
|
unsureAsgnRef(cast[PPointer](dest), z)
|
||||||
genericDeepCopyAux(z, s2, realType.base)
|
genericDeepCopyAux(z, s2, mt.base)
|
||||||
of tyPtr:
|
of tyPtr:
|
||||||
# no cycle check here, but also not really required
|
# no cycle check here, but also not really required
|
||||||
let s2 = cast[PPointer](src)[]
|
let s2 = cast[PPointer](src)[]
|
||||||
|
|
|
||||||
|
|
@ -110,6 +110,11 @@ proc copyStringRC1(src: NimString): NimString {.compilerRtl.} =
|
||||||
result.len = src.len
|
result.len = src.len
|
||||||
copyMem(addr(result.data), addr(src.data), src.len + 1)
|
copyMem(addr(result.data), addr(src.data), src.len + 1)
|
||||||
|
|
||||||
|
proc copyDeepString(src: NimString): NimString {.inline.} =
|
||||||
|
if src != nil:
|
||||||
|
result = rawNewStringNoInit(src.len)
|
||||||
|
result.len = src.len
|
||||||
|
copyMem(addr(result.data), addr(src.data), src.len + 1)
|
||||||
|
|
||||||
proc hashString(s: string): int {.compilerproc.} =
|
proc hashString(s: string): int {.compilerproc.} =
|
||||||
# the compiler needs exactly the same hash function!
|
# the compiler needs exactly the same hash function!
|
||||||
|
|
|
||||||
|
|
@ -356,6 +356,8 @@ proc threadProcWrapStackFrame[TArg](thrd: ptr Thread[TArg]) =
|
||||||
|
|
||||||
template threadProcWrapperBody(closure: expr) {.immediate.} =
|
template threadProcWrapperBody(closure: expr) {.immediate.} =
|
||||||
when declared(globalsSlot): threadVarSetValue(globalsSlot, closure)
|
when declared(globalsSlot): threadVarSetValue(globalsSlot, closure)
|
||||||
|
when declared(initAllocator):
|
||||||
|
initAllocator()
|
||||||
var thrd = cast[ptr Thread[TArg]](closure)
|
var thrd = cast[ptr Thread[TArg]](closure)
|
||||||
threadProcWrapStackFrame(thrd)
|
threadProcWrapStackFrame(thrd)
|
||||||
# Since an unhandled exception terminates the whole process (!), there is
|
# Since an unhandled exception terminates the whole process (!), there is
|
||||||
|
|
|
||||||
|
|
@ -13,10 +13,10 @@
|
||||||
when defined(Unix):
|
when defined(Unix):
|
||||||
when defined(macosx):
|
when defined(macosx):
|
||||||
const
|
const
|
||||||
lib = "libmysqlclient.(15|16|17|18).dylib"
|
lib = "libmysqlclient.(15|16|17|18|19|20).dylib"
|
||||||
else:
|
else:
|
||||||
const
|
const
|
||||||
lib = "libmysqlclient.so.(15|16|17|18)"
|
lib = "libmysqlclient.so.(15|16|17|18|19|20)"
|
||||||
when defined(Windows):
|
when defined(Windows):
|
||||||
const
|
const
|
||||||
lib = "libmysql.dll"
|
lib = "libmysql.dll"
|
||||||
|
|
|
||||||
|
|
@ -217,6 +217,216 @@ when not defined(windows):
|
||||||
assert(selector.isEmpty())
|
assert(selector.isEmpty())
|
||||||
result = true
|
result = true
|
||||||
|
|
||||||
|
when defined(macosx) or defined(freebsd) or defined(openbsd) or
|
||||||
|
defined(netbsd):
|
||||||
|
|
||||||
|
proc rename(frompath: cstring, topath: cstring): cint
|
||||||
|
{.importc: "rename", header: "<stdio.h>".}
|
||||||
|
|
||||||
|
proc createFile(name: string): cint =
|
||||||
|
result = posix.open(cstring(name), posix.O_CREAT or posix.O_RDWR)
|
||||||
|
if result == -1:
|
||||||
|
raiseOsError(osLastError())
|
||||||
|
|
||||||
|
proc writeFile(name: string, data: string) =
|
||||||
|
let fd = posix.open(cstring(name), posix.O_APPEND or posix.O_RDWR)
|
||||||
|
if fd == -1:
|
||||||
|
raiseOsError(osLastError())
|
||||||
|
let length = len(data).cint
|
||||||
|
if posix.write(fd, cast[pointer](unsafeAddr data[0]),
|
||||||
|
len(data).cint) != length:
|
||||||
|
raiseOsError(osLastError())
|
||||||
|
if posix.close(fd) == -1:
|
||||||
|
raiseOsError(osLastError())
|
||||||
|
|
||||||
|
proc closeFile(fd: cint) =
|
||||||
|
if posix.close(fd) == -1:
|
||||||
|
raiseOsError(osLastError())
|
||||||
|
|
||||||
|
proc removeFile(name: string) =
|
||||||
|
let err = posix.unlink(cstring(name))
|
||||||
|
if err == -1:
|
||||||
|
raiseOsError(osLastError())
|
||||||
|
|
||||||
|
proc createDir(name: string) =
|
||||||
|
let err = posix.mkdir(cstring(name), 0x1FF)
|
||||||
|
if err == -1:
|
||||||
|
raiseOsError(osLastError())
|
||||||
|
|
||||||
|
proc removeDir(name: string) =
|
||||||
|
let err = posix.rmdir(cstring(name))
|
||||||
|
if err == -1:
|
||||||
|
raiseOsError(osLastError())
|
||||||
|
|
||||||
|
proc chmodPath(name: string, mode: cint) =
|
||||||
|
let err = posix.chmod(cstring(name), Mode(mode))
|
||||||
|
if err == -1:
|
||||||
|
raiseOsError(osLastError())
|
||||||
|
|
||||||
|
proc renameFile(names: string, named: string) =
|
||||||
|
let err = rename(cstring(names), cstring(named))
|
||||||
|
if err == -1:
|
||||||
|
raiseOsError(osLastError())
|
||||||
|
|
||||||
|
proc symlink(names: string, named: string) =
|
||||||
|
let err = posix.symlink(cstring(names), cstring(named))
|
||||||
|
if err == -1:
|
||||||
|
raiseOsError(osLastError())
|
||||||
|
|
||||||
|
proc openWatch(name: string): cint =
|
||||||
|
result = posix.open(cstring(name), posix.O_RDONLY)
|
||||||
|
if result == -1:
|
||||||
|
raiseOsError(osLastError())
|
||||||
|
|
||||||
|
const
|
||||||
|
testDirectory = "/tmp/kqtest"
|
||||||
|
|
||||||
|
type
|
||||||
|
valType = object
|
||||||
|
fd: cint
|
||||||
|
events: set[Event]
|
||||||
|
|
||||||
|
proc vnode_test(): bool =
|
||||||
|
proc validate[T](test: openarray[ReadyKey[T]],
|
||||||
|
check: openarray[valType]): bool =
|
||||||
|
result = false
|
||||||
|
if len(test) == len(check):
|
||||||
|
for checkItem in check:
|
||||||
|
result = false
|
||||||
|
for testItem in test:
|
||||||
|
if testItem.fd == checkItem.fd and
|
||||||
|
checkItem.events <= testItem.events:
|
||||||
|
result = true
|
||||||
|
break
|
||||||
|
if not result:
|
||||||
|
break
|
||||||
|
|
||||||
|
var res: seq[ReadyKey[int]]
|
||||||
|
var selector = newSelector[int]()
|
||||||
|
var events = {Event.VnodeWrite, Event.VnodeDelete, Event.VnodeExtend,
|
||||||
|
Event.VnodeAttrib, Event.VnodeLink, Event.VnodeRename,
|
||||||
|
Event.VnodeRevoke}
|
||||||
|
|
||||||
|
result = true
|
||||||
|
discard posix.unlink(testDirectory)
|
||||||
|
|
||||||
|
createDir(testDirectory)
|
||||||
|
var dirfd = posix.open(cstring(testDirectory), posix.O_RDONLY)
|
||||||
|
if dirfd == -1:
|
||||||
|
raiseOsError(osLastError())
|
||||||
|
|
||||||
|
selector.registerVnode(dirfd, events, 1)
|
||||||
|
selector.flush()
|
||||||
|
|
||||||
|
# chmod testDirectory to 0777
|
||||||
|
chmodPath(testDirectory, 0x1FF)
|
||||||
|
res = selector.select(0)
|
||||||
|
doAssert(len(res) == 1)
|
||||||
|
doAssert(len(selector.select(0)) == 0)
|
||||||
|
doAssert(res[0].fd == dirfd and
|
||||||
|
{Event.Vnode, Event.VnodeAttrib} <= res[0].events)
|
||||||
|
|
||||||
|
# create subdirectory
|
||||||
|
createDir(testDirectory & "/test")
|
||||||
|
res = selector.select(0)
|
||||||
|
doAssert(len(res) == 1)
|
||||||
|
doAssert(len(selector.select(0)) == 0)
|
||||||
|
doAssert(res[0].fd == dirfd and
|
||||||
|
{Event.Vnode, Event.VnodeWrite,
|
||||||
|
Event.VnodeLink} <= res[0].events)
|
||||||
|
|
||||||
|
# open test directory for watching
|
||||||
|
var testfd = openWatch(testDirectory & "/test")
|
||||||
|
selector.registerVnode(testfd, events, 2)
|
||||||
|
selector.flush()
|
||||||
|
doAssert(len(selector.select(0)) == 0)
|
||||||
|
|
||||||
|
# rename test directory
|
||||||
|
renameFile(testDirectory & "/test", testDirectory & "/renamed")
|
||||||
|
res = selector.select(0)
|
||||||
|
doAssert(len(res) == 2)
|
||||||
|
doAssert(len(selector.select(0)) == 0)
|
||||||
|
doAssert(validate(res,
|
||||||
|
[valType(fd: dirfd, events: {Event.Vnode, Event.VnodeWrite}),
|
||||||
|
valType(fd: testfd,
|
||||||
|
events: {Event.Vnode, Event.VnodeRename})])
|
||||||
|
)
|
||||||
|
|
||||||
|
# remove test directory
|
||||||
|
removeDir(testDirectory & "/renamed")
|
||||||
|
res = selector.select(0)
|
||||||
|
doAssert(len(res) == 2)
|
||||||
|
doAssert(len(selector.select(0)) == 0)
|
||||||
|
doAssert(validate(res,
|
||||||
|
[valType(fd: dirfd, events: {Event.Vnode, Event.VnodeWrite,
|
||||||
|
Event.VnodeLink}),
|
||||||
|
valType(fd: testfd,
|
||||||
|
events: {Event.Vnode, Event.VnodeDelete})])
|
||||||
|
)
|
||||||
|
# create file new test file
|
||||||
|
testfd = createFile(testDirectory & "/testfile")
|
||||||
|
res = selector.select(0)
|
||||||
|
doAssert(len(res) == 1)
|
||||||
|
doAssert(len(selector.select(0)) == 0)
|
||||||
|
doAssert(res[0].fd == dirfd and
|
||||||
|
{Event.Vnode, Event.VnodeWrite} <= res[0].events)
|
||||||
|
|
||||||
|
# close new test file
|
||||||
|
closeFile(testfd)
|
||||||
|
doAssert(len(selector.select(0)) == 0)
|
||||||
|
doAssert(len(selector.select(0)) == 0)
|
||||||
|
|
||||||
|
# chmod test file with 0666
|
||||||
|
chmodPath(testDirectory & "/testfile", 0x1B6)
|
||||||
|
doAssert(len(selector.select(0)) == 0)
|
||||||
|
|
||||||
|
testfd = openWatch(testDirectory & "/testfile")
|
||||||
|
selector.registerVnode(testfd, events, 1)
|
||||||
|
selector.flush()
|
||||||
|
|
||||||
|
# write data to test file
|
||||||
|
writeFile(testDirectory & "/testfile", "TESTDATA")
|
||||||
|
res = selector.select(0)
|
||||||
|
doAssert(len(res) == 1)
|
||||||
|
doAssert(len(selector.select(0)) == 0)
|
||||||
|
doAssert(res[0].fd == testfd and
|
||||||
|
{Event.Vnode, Event.VnodeWrite,
|
||||||
|
Event.VnodeExtend} <= res[0].events)
|
||||||
|
|
||||||
|
# symlink test file
|
||||||
|
symlink(testDirectory & "/testfile", testDirectory & "/testlink")
|
||||||
|
res = selector.select(0)
|
||||||
|
doAssert(len(res) == 1)
|
||||||
|
doAssert(len(selector.select(0)) == 0)
|
||||||
|
doAssert(res[0].fd == dirfd and
|
||||||
|
{Event.Vnode, Event.VnodeWrite} <= res[0].events)
|
||||||
|
|
||||||
|
# remove test file
|
||||||
|
removeFile(testDirectory & "/testfile")
|
||||||
|
res = selector.select(0)
|
||||||
|
doAssert(len(res) == 2)
|
||||||
|
doAssert(len(selector.select(0)) == 0)
|
||||||
|
doAssert(validate(res,
|
||||||
|
[valType(fd: testfd, events: {Event.Vnode, Event.VnodeDelete}),
|
||||||
|
valType(fd: dirfd, events: {Event.Vnode, Event.VnodeWrite})])
|
||||||
|
)
|
||||||
|
|
||||||
|
# remove symlink
|
||||||
|
removeFile(testDirectory & "/testlink")
|
||||||
|
res = selector.select(0)
|
||||||
|
doAssert(len(res) == 1)
|
||||||
|
doAssert(len(selector.select(0)) == 0)
|
||||||
|
doAssert(res[0].fd == dirfd and
|
||||||
|
{Event.Vnode, Event.VnodeWrite} <= res[0].events)
|
||||||
|
|
||||||
|
# remove testDirectory
|
||||||
|
removeDir(testDirectory)
|
||||||
|
res = selector.select(0)
|
||||||
|
doAssert(len(res) == 1)
|
||||||
|
doAssert(len(selector.select(0)) == 0)
|
||||||
|
doAssert(res[0].fd == dirfd and
|
||||||
|
{Event.Vnode, Event.VnodeDelete} <= res[0].events)
|
||||||
|
|
||||||
when hasThreadSupport:
|
when hasThreadSupport:
|
||||||
|
|
||||||
var counter = 0
|
var counter = 0
|
||||||
|
|
@ -256,6 +466,9 @@ when not defined(windows):
|
||||||
processTest("Timer notification test...", timer_notification_test())
|
processTest("Timer notification test...", timer_notification_test())
|
||||||
processTest("Process notification test...", process_notification_test())
|
processTest("Process notification test...", process_notification_test())
|
||||||
processTest("Signal notification test...", signal_notification_test())
|
processTest("Signal notification test...", signal_notification_test())
|
||||||
|
when defined(macosx) or defined(freebsd) or defined(openbsd) or
|
||||||
|
defined(netbsd):
|
||||||
|
processTest("File notification test...", vnode_test())
|
||||||
echo("All tests passed!")
|
echo("All tests passed!")
|
||||||
else:
|
else:
|
||||||
import nativesockets, winlean, os, osproc
|
import nativesockets, winlean, os, osproc
|
||||||
|
|
|
||||||
71
tests/parallel/tsendtwice.nim
Normal file
71
tests/parallel/tsendtwice.nim
Normal file
|
|
@ -0,0 +1,71 @@
|
||||||
|
discard """
|
||||||
|
output: '''obj2 nil
|
||||||
|
obj nil
|
||||||
|
obj3 nil
|
||||||
|
3
|
||||||
|
obj2 nil
|
||||||
|
obj nil
|
||||||
|
obj3 nil'''
|
||||||
|
cmd: "nim c -r --threads:on $file"
|
||||||
|
"""
|
||||||
|
|
||||||
|
# bug #4776
|
||||||
|
|
||||||
|
import tables
|
||||||
|
|
||||||
|
type
|
||||||
|
Base* = ref object of RootObj
|
||||||
|
someSeq: seq[int]
|
||||||
|
baseData: array[400000, byte]
|
||||||
|
Derived* = ref object of Base
|
||||||
|
data: array[400000, byte]
|
||||||
|
|
||||||
|
type
|
||||||
|
ThreadPool = ref object
|
||||||
|
threads: seq[ptr Thread[ThreadArg]]
|
||||||
|
channels: seq[ThreadArg]
|
||||||
|
TableChannel = Channel[TableRef[string, Base]]
|
||||||
|
ThreadArg = ptr TableChannel
|
||||||
|
|
||||||
|
var globalTable {.threadvar.}: TableRef[string, Base]
|
||||||
|
globalTable = newTable[string, Base]()
|
||||||
|
let d = new(Derived)
|
||||||
|
globalTable.add("obj", d)
|
||||||
|
globalTable.add("obj2", d)
|
||||||
|
globalTable.add("obj3", d)
|
||||||
|
|
||||||
|
proc testThread(channel: ptr TableChannel) {.thread.} =
|
||||||
|
globalTable = channel[].recv()
|
||||||
|
for k, v in pairs globaltable:
|
||||||
|
echo k, " ", v.someSeq
|
||||||
|
var myObj: Base
|
||||||
|
deepCopy(myObj, globalTable["obj"])
|
||||||
|
myObj.someSeq = newSeq[int](100)
|
||||||
|
let table = channel[].recv() # same table
|
||||||
|
echo table.len
|
||||||
|
for k, v in mpairs table:
|
||||||
|
echo k, " ", v.someSeq
|
||||||
|
assert(table.contains("obj")) # fails!
|
||||||
|
assert(table.contains("obj2")) # fails!
|
||||||
|
assert(table.contains("obj3")) # fails!
|
||||||
|
|
||||||
|
var channel: TableChannel
|
||||||
|
|
||||||
|
proc newThreadPool(threadCount: int) = #: ThreadPool =
|
||||||
|
#new(result)
|
||||||
|
#result.threads = newSeq[ptr Thread[ThreadArg]](threadCount)
|
||||||
|
#var channel = cast[ptr TableChannel](allocShared0(sizeof(TableChannel)))
|
||||||
|
channel.open()
|
||||||
|
channel.send(globalTable)
|
||||||
|
channel.send(globalTable)
|
||||||
|
#createThread(threadPtr[], testThread, addr channel)
|
||||||
|
testThread(addr channel)
|
||||||
|
#result.threads[i] = threadPtr
|
||||||
|
|
||||||
|
proc stop(p: ThreadPool) =
|
||||||
|
for t in p.threads:
|
||||||
|
joinThread(t[])
|
||||||
|
dealloc(t)
|
||||||
|
|
||||||
|
|
||||||
|
newThreadPool(1)#.stop()
|
||||||
Loading…
Add table
Add a link
Reference in a new issue