@@ -183,10 +183,14 @@ async function batchResponse ({ blocks, context, logger }) {
183
183
}
184
184
185
185
try {
186
+ logger . info ( { key : context . canceled } , 'batch response' )
186
187
let message = new Message ( )
187
188
for ( let i = 0 ; i < blocks . length ; i ++ ) {
188
189
const block = blocks [ i ]
190
+ console . log ( 'block key' , block . key )
189
191
const canceledItem = context . canceled . get ( block . key )
192
+ logger . info ( { key : block . key } , 'check' )
193
+ logger . info ( { canceled : canceledItem } , 'check' )
190
194
if ( ! canceledItem || canceledItem !== block . type ) {
191
195
const size = messageSize [ block . type ] ( block )
192
196
@@ -203,6 +207,7 @@ async function batchResponse ({ blocks, context, logger }) {
203
207
telemetry . increaseLabelCount ( 'bitswap-block-success-cancel' , [ block . type ] )
204
208
telemetry . increaseLabelCount ( 'bitswap-cancel-size' , [ block . type ] , size )
205
209
210
+ logger . info ( { key : block . key } , 'delete' )
206
211
context . canceled . delete ( block . key )
207
212
}
208
213
}
@@ -222,15 +227,18 @@ function updateCanceledState (wantList, context) {
222
227
223
228
// Removed previous canceled blocks
224
229
wantedBlocks . forEach ( block => {
230
+ console . log ( 'remove block from canceled' , block . key )
225
231
context . canceled . delete ( block . key )
226
232
} )
227
233
228
234
wantedHave . forEach ( block => {
235
+ console . log ( 'remove wanted block from canceled' , block . key )
229
236
context . canceled . delete ( block . key )
230
237
} )
231
238
232
239
// Add new canceled blocks
233
240
canceled . forEach ( block => {
241
+ console . log ( 'add block to canceled' , block . key )
234
242
context . canceled . set ( block . key , block . wantType )
235
243
} )
236
244
}
0 commit comments