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

cleanup

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-20 16:10:39 -07:00
parent 00d6ff5c21
commit b270d986c6
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/apatheia/queues.nim
View File

@ -12,8 +12,8 @@ export chronos
type ChanPtr[T] = ptr Channel[T]
proc allocSharedChannel[T](): ChanPtr[T] =
cast[ChanPtr[T]](allocShared0(sizeof(Channel[T])))
proc allocPtr[T](): ptr T =
cast[ptr T](allocShared0(sizeof(T)))
type SignalQueue*[T] = object
signal: ThreadSignalPtr
@ -32,7 +32,7 @@ proc newSignalQueue*[T](
if res.isErr():
raise newException(ApatheiaSignalErr, res.error())
result.signal = res.get()
result.chan = allocSharedChannel[T]()
result.chan = allocPtr[Channel[T]]()
result.chan[].open(maxItems)
proc send*[T](c: SignalQueue[T], msg: sink T): Result[void, string] {.raises: [].} =