codex-storage
/
nim-codex
mirror of https://github.com/codex-storage/nim-codex.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

work around windows

This commit is contained in:
Jaremy Creechley 2024-05-20 20:23:43 +03:00
parent b4fbe25284
commit ce12d0f3f9
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
codex/utils/asyncthreads.nim
View File

@ -31,10 +31,10 @@ proc release*[T](queue: SignalQueuePtr[T]): ?!void =
proc newSignalQueue*[T](maxItems: int = 0): ?!SignalQueuePtr[T] = proc newSignalQueue*[T](maxItems: int = 0): ?!SignalQueuePtr[T] =
## Create a signal queue compatible with Chronos async. ## Create a signal queue compatible with Chronos async.
result = success cast[ptr SignalQueue[T]](allocShared0(sizeof(SignalQueue[T]))) result = success cast[ptr SignalQueue[T]](allocShared0(sizeof(SignalQueue[T])))
let signalRes = ThreadSignalPtr.new().mapFailure let sigRes = ThreadSignalPtr.new()
without signal =? signalRes, err: if sigRes.isErr():
return failure(err) return failure(sigRes.error())
result[].signal = signal result[].signal = sigRes.get()
result[].chan.open(maxItems) result[].chan.open(maxItems)
proc send*[T](queue: SignalQueuePtr[T], msg: T): ?!void {.raises: [].} = proc send*[T](queue: SignalQueuePtr[T], msg: T): ?!void {.raises: [].} =