logos-storage/apatheia
1
0
Fork 0
mirror of https://github.com/logos-storage/apatheia.git synced 2026-01-02 13:03:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

cleanup

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-20 16:14:24 -07:00
parent b270d986c6
commit 9f984b21d1
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/apatheia/queues.nim
View File

@ -10,14 +10,9 @@ export options
export threadsync
export chronos
type ChanPtr[T] = ptr Channel[T]
proc allocPtr[T](): ptr T =
cast[ptr T](allocShared0(sizeof(T)))
type SignalQueue*[T] = object
signal: ThreadSignalPtr
chan*: ChanPtr[T]
chan*: ptr Channel[T]
proc dispose*[T](val: SignalQueue[T]) =
## Call to properly dispose of a SignalQueue.
@ -32,7 +27,7 @@ proc newSignalQueue*[T](
if res.isErr():
raise newException(ApatheiaSignalErr, res.error())
result.signal = res.get()
result.chan = allocPtr[Channel[T]]()
result.chan = cast[ptr Channel[T]](allocShared0(sizeof(Channel[T])))
result.chan[].open(maxItems)
proc send*[T](c: SignalQueue[T], msg: sink T): Result[void, string] {.raises: [].} =