logos-storage/logos-storage-nim
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim.git synced 2026-02-25 07:53:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

adding log stmts

Browse Source
This commit is contained in:
munna0908 2025-07-02 19:55:19 +05:30
parent 48600dd398
commit 00a0381ba2
No known key found for this signature in database
GPG Key ID: 2FFCD637E937D3E6
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
codex/erasure/erasure.nim
View File

@ -319,12 +319,11 @@ proc asyncEncode*(
self: ErasureRef, blockSize, parityLen: int, blocks: seq[seq[byte]] self: ErasureRef, blockSize, parityLen: int, blocks: seq[seq[byte]]
): Future[?!seq[seq[byte]]] {.async: (raises: [CancelledError]).} = ): Future[?!seq[seq[byte]]] {.async: (raises: [CancelledError]).} =
var threadPtr = ?ThreadSignalPtr.new().mapFailure() var threadPtr = ?ThreadSignalPtr.new().mapFailure()
echo "In Async Encode"
defer: defer:
if threadPtr != nil: if threadPtr != nil:
?threadPtr.close().mapFailure() ?threadPtr.close().mapFailure()
threadPtr = nil threadPtr = nil
echo "Out Async Encode"
## Create an ecode task with block data ## Create an ecode task with block data
var task = EncodeTask( var task = EncodeTask(
@ -484,12 +483,10 @@ proc asyncDecode*(
): Future[?!seq[seq[byte]]] {.async: (raises: [CancelledError]).} = ): Future[?!seq[seq[byte]]] {.async: (raises: [CancelledError]).} =
var threadPtr = ?ThreadSignalPtr.new().mapFailure() var threadPtr = ?ThreadSignalPtr.new().mapFailure()
echo "In Async Decode"
defer: defer:
if threadPtr != nil: if threadPtr != nil:
?threadPtr.close().mapFailure() ?threadPtr.close().mapFailure()
threadPtr = nil threadPtr = nil
echo "Out Async Decode"
## Create an decode task with block data ## Create an decode task with block data
var task = DecodeTask( var task = DecodeTask(

5
tests/codex/testerasure.nim
View File

@ -179,6 +179,7 @@ suite "Erasure encode/decode":
decoded = (await erasure.decode(encoded)).tryGet() decoded = (await erasure.decode(encoded)).tryGet()
test "Should tolerate losing M (a.k.a row) contiguous data blocks": test "Should tolerate losing M (a.k.a row) contiguous data blocks":
echo "Testing tolerance for losing M contiguous data blocks"
const const
buffers = 20 buffers = 20
parity = 10 parity = 10
@ -197,6 +198,7 @@ suite "Erasure encode/decode":
check present.tryGet() check present.tryGet()
test "Should tolerate losing M (a.k.a row) contiguous parity blocks": test "Should tolerate losing M (a.k.a row) contiguous parity blocks":
echo "Testing tolerance for losing M contiguous parity blocks"
const const
buffers = 20 buffers = 20
parity = 10 parity = 10
@ -219,6 +221,7 @@ suite "Erasure encode/decode":
check present.tryGet() check present.tryGet()
test "Handles edge case of 0 parity blocks": test "Handles edge case of 0 parity blocks":
echo "Testing edge case of 0 parity blocks"
const const
buffers = 20 buffers = 20
parity = 0 parity = 0
@ -228,6 +231,7 @@ suite "Erasure encode/decode":
discard (await erasure.decode(encoded)).tryGet() discard (await erasure.decode(encoded)).tryGet()
test "Should concurrently encode/decode multiple datasets": test "Should concurrently encode/decode multiple datasets":
echo "Testing concurrent encode/decode with multiple datasets"
const iterations = 5 const iterations = 5
let let
@ -265,6 +269,7 @@ suite "Erasure encode/decode":
decoded.blocksCount == encoded.originalBlocksCount decoded.blocksCount == encoded.originalBlocksCount
test "Should handle verifiable manifests": test "Should handle verifiable manifests":
echo "Testing verifiable manifests"
const const
buffers = 20 buffers = 20
parity = 10 parity = 10