chore: add comment on cancel

Author: vasco-santos

src/handler.js

@@ -56,7 +56,7 @@ function handle ({ context, logger, batchSize = config.blocksBatchSize }) {
         const normalizedWantlist = getNormalizedWantlist(wantlist, context, logger)
 
         // Set state of processing blocks in canceled state
-        updateCanceledState(normalizedWantlist, context)
+        updateCanceledState(normalizedWantlist, context, logger)
 
         process.nextTick(async () => {
           // catch async error in libp2p connection
@@ -186,7 +186,11 @@ async function batchResponse ({ blocks, context, logger }) {
     let message = new Message()
     for (let i = 0; i < blocks.length; i++) {
       const block = blocks[i]
+      // console.log('block key', block.key)
       const canceledItem = context.canceled.get(block.key)
+      logger.info({ keyList: context.canceled.keyList }, 'check keyList')
+      logger.info({ key: block.key }, 'check')
+      logger.info({ canceled: canceledItem }, 'canceled')
       if (!canceledItem || canceledItem !== block.type) {
         const size = messageSize[block.type](block)
 
@@ -203,6 +207,7 @@ async function batchResponse ({ blocks, context, logger }) {
         telemetry.increaseLabelCount('bitswap-block-success-cancel', [block.type])
         telemetry.increaseLabelCount('bitswap-cancel-size', [block.type], size)
 
+        logger.info({ key: block.key }, 'delete')
         context.canceled.delete(block.key)
       }
     }
@@ -217,22 +222,27 @@ async function batchResponse ({ blocks, context, logger }) {
   }
 }
 
-function updateCanceledState (wantList, context) {
+function updateCanceledState (wantList, context, logger) {
   const { wantedBlocks, wantedHave, canceled } = wantList
 
   // Removed previous canceled blocks
   wantedBlocks.forEach(block => {
+    logger.info({ key: block.key }, 'remove block from canceled')
     context.canceled.delete(block.key)
   })
 
   wantedHave.forEach(block => {
+    logger.info({ key: block.key }, 'remove wanted block from canceled')
     context.canceled.delete(block.key)
   })
 
   // Add new canceled blocks
   canceled.forEach(block => {
+    logger.info({ key: block.key }, 'add block to canceled')
     context.canceled.set(block.key, block.wantType)
   })
+
+  logger.info({ keyList: context.canceled.keyList }, 'check keyList')
 }
 
 // end response, close connection

src/service.js

@@ -146,12 +146,14 @@ async function startService ({ peerId, port, peerAnnounceAddr, awsClient, connec
           // another multiplexed stream.
           connection.on('end:receive', () => {
             // GC canceled LRU on finish
-            canceled.clear()
+            // canceled.clear()
+            logger.info({}, 'end:receive')
             connection.close()
           })
 
           connection.on('error', err => {
             // GC canceled LRU on error
+            logger.info({}, 'error')
             canceled.clear()
             logger.error({ err, dial, stream, protocol }, 'Connection error')
           })