fix: allow GC to run

storacha · Aug 15, 2023 · 132d946 · 132d946
1 parent a771b3f
commit 132d946
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/lib/blockstore.js b/src/lib/blockstore.js
@@ -130,6 +130,7 @@ export class BatchingR2Blockstore extends R2Blockstore {
         }
       })())
 
+      let resolvedBlocks = 0
       while (true) {
         try {
           const blockHeader = await readBlockHead(bytesReader)
@@ -139,6 +140,7 @@ export class BatchingR2Blockstore extends R2Blockstore {
           const key = mhToKey(blockHeader.cid.multihash.bytes)
           const blocks = pendingBlocks.get(key)
           if (blocks) {
+            resolvedBlocks++
             // console.log(`got wanted block for ${blockHeader.cid}`)
             const block = {
               cid: blockHeader.cid,
@@ -185,6 +187,11 @@ export class BatchingR2Blockstore extends R2Blockstore {
       // bytesReader throws for bad data _before_ the end then we need to
       // cancel the reader - we don't need the rest.
       reader.cancel()
+
+      // Yield to allow GC to run - DO NOT REMOVE!
+      await new Promise(resolve => setTimeout(resolve))
+
+      console.log(`batcher efficiency ${resolvedBlocks}:1`)
     }
 
     // resolve `undefined` for any remaining blocks