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

Fix log message

Browse Source
This commit is contained in:
Arnaud 2025-10-02 08:47:38 +02:00
parent b70a4ef2a7
commit 07b442cea9
No known key found for this signature in database
GPG Key ID: B8FBC178F10CA7AE
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
library/codex_context.nim
View File

@ -130,7 +130,7 @@ proc runCodex(ctx: ptr CodexContext) {.async: (raises: []).} =
# Wait until a request is available # Wait until a request is available
await ctx.reqSignal.wait() await ctx.reqSignal.wait()
except Exception as e: except Exception as e:
error "Failed to run codex thread while waiting for reqSignal.", error = e.msg error "Failure in run codex thread while waiting for reqSignal.", error = e.msg
continue continue
# If codex_destroy was called, exit the loop # If codex_destroy was called, exit the loop
@ -142,7 +142,7 @@ proc runCodex(ctx: ptr CodexContext) {.async: (raises: []).} =
# Pop a request from the channel # Pop a request from the channel
let recvOk = ctx.reqChannel.tryRecv(request) let recvOk = ctx.reqChannel.tryRecv(request)
if not recvOk: if not recvOk:
error "Failed to run codex: unable to receive request in codex thread." error "Failure in run codex: unable to receive request in codex thread."
continue continue
# yield immediately to the event loop # yield immediately to the event loop
@ -157,7 +157,7 @@ proc runCodex(ctx: ptr CodexContext) {.async: (raises: []).} =
# Notify the main thread that we picked up the request # Notify the main thread that we picked up the request
let fireRes = ctx.reqReceivedSignal.fireSync() let fireRes = ctx.reqReceivedSignal.fireSync()
if fireRes.isErr(): if fireRes.isErr():
error "Failed to run codex: unable to fire back to requester thread.", error "Failure in run codex: unable to fire back to requester thread.",
error = fireRes.error error = fireRes.error
proc run(ctx: ptr CodexContext) {.thread.} = proc run(ctx: ptr CodexContext) {.thread.} =