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

cleanup

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-16 15:02:20 -07:00
parent 903152b0b2
commit 7f019c135d
2 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/apatheia/jobs.nim
View File

@ -43,11 +43,11 @@ template toOpenArray*[T](arr: OpenArrayHolder[T]): auto =
func jobId*[T](fut: Future[T]): JobId =
JobId fut.id()
proc processJobs*[T](jobs: JobQueue[T]) {.async, raises: [].} =
proc processJobs*[T](jobs: JobQueue[T]) {.async.} =
## Starts a "detached" async processor for a given job queue.
##
## This processor waits for events from the queue in the JobQueue
## and complete the associated futures.
## and completes the associated future.
const tn: string = $(JobQueue[T])
info "Processing jobs in job queue for type ", type = tn
@ -55,8 +55,7 @@ proc processJobs*[T](jobs: JobQueue[T]) {.async, raises: [].} =
let (id, ret) = await(jobs.queue.wait()).get()
trace "got job result", jobId = id
releaseMemory(id) # always release any retained memory
var fut: Future[T]
if jobs.futures.pop(id, fut):
if (var fut: Future[T]; jobs.futures.pop(id, fut)):
if not fut.finished():
fut.complete(ret)
else:

1
src/apatheia/memretainers.nim
View File

@ -12,7 +12,6 @@ type
StrRetainer*[T] = ref object of Retainer
data*: string
var memoryRetainerTable = newTable[uint, seq[Retainer]]()
proc retainMemory*(id: JobId, mem: Retainer) {.gcsafe, raises: [].} =