chore: add comment on cancel

src/handler.js

@@ -184,15 +184,20 @@ async function batchResponse ({ blocks, context, logger }) {
 
   try {
     let message = new Message()
+    logger.info({ keyList: context.canceled.keyList }, 'check keyList')
     for (let i = 0; i < blocks.length; i++) {
       const block = blocks[i]
       const canceledItem = context.canceled.get(block.key)
 
+      logger.info({ key: block.key, type: block.type, wantType: block.wantType }, 'check')
+      logger.info({ canceled: canceledItem }, 'canceled')
+
       if (canceledItem === block.wantType) {
         const size = messageSize[block.type](block)
         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)
       } else {
         const size = messageSize[block.type](block)

src/service.js

@@ -83,6 +83,7 @@ async function startService ({ peerId, port, peerAnnounceAddr, awsClient, connec
       }
     })
 
+    const cancelsPerPeer = new Map()
     const handlerOptions = {
       maxInboundStreams: connectionConfig.handler.maxInboundStreams,
       maxOutboundStreams: connectionConfig.handler.maxOutboundStreams
@@ -180,6 +181,10 @@ async function startService ({ peerId, port, peerAnnounceAddr, awsClient, connec
       cancelsPerPeer.delete(
         connection.detail.remotePeer.toString()
       )
+<<<<<<< Updated upstream
+=======
+
+>>>>>>> Stashed changes
       try {
         telemetry.decreaseGauge('bitswap-active-connections')
       } catch (err) {