From 9b024327027ed1746fb83d09fd283e5ebdfe081a Mon Sep 17 00:00:00 2001 From: Dmitriy Ryajov Date: Wed, 28 May 2025 19:19:56 -0600 Subject: [PATCH] Avoid using pointer to task, use the actual task object. Add some checked exceptions --- codex/erasure/erasure.nim | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/codex/erasure/erasure.nim b/codex/erasure/erasure.nim index 95516500..85b0138a 100644 --- a/codex/erasure/erasure.nim +++ b/codex/erasure/erasure.nim @@ -362,7 +362,7 @@ proc asyncEncode*( proc encodeData( self: Erasure, manifest: Manifest, params: EncodingParams -): Future[?!Manifest] {.async.} = +): Future[?!Manifest] {.async: (raises: [CancelledError]).} = ## Encode blocks pointed to by the protected manifest ## ## `manifest` - the manifest to encode @@ -461,7 +461,7 @@ proc encode*( blocks: Natural, parity: Natural, strategy = SteppedStrategy, -): Future[?!Manifest] {.async.} = +): Future[?!Manifest] {.async: (raises: [CancelledError]).} = ## Encode a manifest into one that is erasure protected. ## ## `manifest` - the original manifest to be encoded @@ -554,7 +554,7 @@ proc asyncDecode*( proc decodeInternal( self: Erasure, encoded: Manifest -): Future[?!(ref seq[Cid], seq[Natural])] {.async.} = +): Future[?!(ref seq[Cid], seq[Natural])] {.async: (raises:[CancelledError]).} = logScope: steps = encoded.steps rounded_blocks = encoded.rounded @@ -638,7 +638,9 @@ proc decodeInternal( return (cids, recoveredIndices).success -proc decode*(self: Erasure, encoded: Manifest): Future[?!Manifest] {.async.} = +proc decode*( + self: Erasure, encoded: Manifest +): Future[?!Manifest] {.async: (raises: [CancelledError]).} = ## Decode a protected manifest into it's original ## manifest ##