File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed
Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -48,6 +48,8 @@ class TrailingChecksumTransform extends Transform {
4848 break ;
4949 }
5050 // chunk is bigger than the advertised size
51+ this . log . info ( 'concatenating chunk' , { first : this . outputBuffer . toString ( ) } ) ;
52+ this . log . info ( 'concatenating chunk' , { second : chunk . subarray ( 0 , this . bytesToRead ) . toString ( ) } ) ;
5153 this . outputBuffer = Buffer . concat ( [ this . outputBuffer , chunk . subarray ( 0 , this . bytesToRead ) ] ) ;
5254 chunk = chunk . subarray ( this . bytesToRead ) ;
5355 this . bytesToRead = 0 ;
@@ -81,10 +83,12 @@ class TrailingChecksumTransform extends Transform {
8183 break ;
8284 }
8385 this . bytesToRead = dataSize ;
86+ this . log . info ( 'chunk size' , { dataSize } ) ;
8487 }
8588
8689 this . toFlush = this . outputBuffer ;
8790 this . outputBuffer = Buffer . alloc ( 0 ) ;
91+ this . log . info ( 'toFlush' , { toFlush : this . toFlush . toString ( ) } ) ;
8892 return callback ( null , this . toFlush , encoding ) ;
8993 }
9094}
You can’t perform that action at this time.
0 commit comments