From b854053a5c4bd4412d767b11f4cbee7242673469 Mon Sep 17 00:00:00 2001
From: munna0908 <munnasitu0908@gmail.com>
Date: Wed, 2 Jul 2025 18:59:40 +0530
Subject: [PATCH] add logs

---
 codex/erasure/erasure.nim | 20 +++++++++++++-------
 1 file changed, 13 insertions(+), 7 deletions(-)

diff --git a/codex/erasure/erasure.nim b/codex/erasure/erasure.nim
index 0e38de3b..220ba23c 100644
--- a/codex/erasure/erasure.nim
+++ b/codex/erasure/erasure.nim
@@ -320,9 +320,12 @@ proc asyncEncode*(
 ): Future[?!seq[seq[byte]]] {.async: (raises: [CancelledError]).} =
   without threadPtr =? ThreadSignalPtr.new():
     return failure("Unable to create thread signal")
-
+  echo "In Async Encode"
   defer:
-    threadPtr.close().expect("closing once works")
+    if threadPtr != nil:
+      ?threadPtr.close().mapFailure()
+      threadPtr = nil
+    echo "Out Async Encode"
 
   ## Create an ecode task with block data
   var task = EncodeTask(
@@ -482,9 +485,12 @@ proc asyncDecode*(
 ): Future[?!seq[seq[byte]]] {.async: (raises: [CancelledError]).} =
   without threadPtr =? ThreadSignalPtr.new():
     return failure("Unable to create thread signal")
-
+  echo "In Async Decode"
   defer:
-    threadPtr.close().expect("closing once works")
+    if threadPtr != nil:
+      ?threadPtr.close().mapFailure()
+      threadPtr = nil
+    echo "Out Async Decode"
 
   ## Create an decode task with block data
   var task = DecodeTask(
@@ -507,12 +513,12 @@ proc asyncDecode*(
 
     return failure(err)
 
+  defer: 
+    task.recovered = default(Isolated[seq[seq[byte]]])
+
   if not task.success.load():
     return failure("Leopard decoding task failed")
 
-  defer:
-    task.recovered = default(Isolated[seq[seq[byte]]])
-
   var recovered = task.recovered.extract
 
   success(recovered)