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

fix decrement and free in channel

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-09 21:11:49 -07:00
parent 6fba03afa5
commit a2b74aeb33
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/apatheia/queues.nim
View File

@ -1,4 +1,3 @@
import std/channels
import ./types
@ -9,15 +8,21 @@ import chronos/threadsync
export types
type
ChanPtr[T] = ptr Channel[T]
proc allocSharedChannel[T](): ChanPtr[T] =
cast[ChanPtr[T]](allocShared0(sizeof(Channel[T])))
type
AsyncQueue*[T] = object
signal: ThreadSignalPtr
chan*: T
chan*: ChanPtr[T]
proc new*[T](tp: typedesc[AsyncQueue[T]]): AsyncQueue[T] {.raises: [ApatheiaSignalErr].} =
let res = ThreadSignalPtr.new()
if res.isErr():
raise newException(ApatheiaSignalErr, msg: res.err())
else:
result.signal = res.get()
result.signal = res.get()
result.chan = allocSharedChannel()