From e1ab1127eb3f5b40af089f01370b71a996189121 Mon Sep 17 00:00:00 2001 From: munna0908 Date: Thu, 10 Jul 2025 18:02:26 +0530 Subject: [PATCH] code cleanup --- codex/erasure/erasure.nim | 12 ++++++------ codex/utils/uniqueptr.nim | 6 +++--- 2 files changed, 9 insertions(+), 9 deletions(-) diff --git a/codex/erasure/erasure.nim b/codex/erasure/erasure.nim index 82a05a4e..2f5d342a 100644 --- a/codex/erasure/erasure.nim +++ b/codex/erasure/erasure.nim @@ -312,12 +312,12 @@ proc leopardEncodeTask(tp: Taskpool, task: ptr EncodeTask) {.gcsafe.} = task[].success.store(false) else: - var isolatedSeq = newSeq[seq[byte]](task[].parityLen) + var paritySeq = newSeq[seq[byte]](task[].parityLen) for i in 0 ..< task[].parityLen: var innerSeq = isolate(parity[i]) - isolatedSeq[i] = extract(innerSeq) + paritySeq[i] = extract(innerSeq) - task[].parity = newUniquePtr(isolatedSeq) + task[].parity = newUniquePtr(paritySeq) task[].success.store(true) proc asyncEncode*( @@ -474,12 +474,12 @@ proc leopardDecodeTask(tp: Taskpool, task: ptr DecodeTask) {.gcsafe.} = warn "Error from leopard decoder backend!", error = $res.error task[].success.store(false) else: - var isolatedSeq = newSeq[seq[byte]](task[].blocks.len) + var recoveredSeq = newSeq[seq[byte]](task[].blocks.len) for i in 0 ..< task[].blocks.len: var innerSeq = isolate(recovered[i]) - isolatedSeq[i] = extract(innerSeq) + recoveredSeq[i] = extract(innerSeq) - task[].recovered = newUniquePtr(isolatedSeq) + task[].recovered = newUniquePtr(recoveredSeq) task[].success.store(true) proc asyncDecode*( diff --git a/codex/utils/uniqueptr.nim b/codex/utils/uniqueptr.nim index be77ffd1..43eeeea6 100644 --- a/codex/utils/uniqueptr.nim +++ b/codex/utils/uniqueptr.nim @@ -4,9 +4,6 @@ type UniquePtr*[T] = object ## Can only be moved, not copied data: ptr T -template newUniquePtr*[T](data: T): UniquePtr[T] = - newUniquePtr(isolate(data)) - proc newUniquePtr*[T](data: sink Isolated[T]): UniquePtr[T] = ## Creates a new unique sequence in shared memory ## The memory is automatically freed when the object is destroyed @@ -14,6 +11,9 @@ proc newUniquePtr*[T](data: sink Isolated[T]): UniquePtr[T] = result.data[] = extract(data) +template newUniquePtr*[T](data: T): UniquePtr[T] = + newUniquePtr(isolate(data)) + proc `=destroy`*[T](p: var UniquePtr[T]) = ## Destructor for UniquePtr if p.data != nil: