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

code cleanup

Browse Source
This commit is contained in:
munna0908 2025-07-10 18:02:26 +05:30
parent 34f4eedce2
commit e1ab1127eb
No known key found for this signature in database
GPG Key ID: 2FFCD637E937D3E6
2 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
codex/erasure/erasure.nim
View File

@ -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*(

6
codex/utils/uniqueptr.nim
View File

@ -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: