@@ -242,12 +242,8 @@ private void sendNextRequest(AsyncResponseTransformer<GetObjectResponse, GetObje
242242 if (completedParts .get () >= totalParts ) {
243243 // todo remove log
244244 log .info (() -> "================= ALL PARTS COMPLETED ==================" );
245- log .info (() -> "remaining in flight (should be empty): " + inFlightRequests .keySet ().toString ());
246- log .info (() -> "calling cancel" );
247245 subscription .cancel ();
248- log .info (() -> "completing future" );
249246 resultFuture .complete (getObjectResponse );
250- log .info (() -> "all done in NonLinearMultipartDownloaderSubscriber" );
251247 } else {
252248 processPendingTransformers ();
253249 requestMoreIfNeeded ();
@@ -335,8 +331,8 @@ private void requestMoreIfNeeded() {
335331 int totalWorkInProgress = inFlightRequests .size () + completedParts .get ();
336332 if (totalWorkInProgress >= totalParts ) {
337333 // todo change trace log
338- log .info (() -> "Not requesting more. Total work in progress (" + totalWorkInProgress
339- + ") >= totalParts (" + totalParts + ")" );
334+ // log.info(() -> "Not requesting more. Total work in progress (" + totalWorkInProgress
335+ // + ") >= totalParts (" + totalParts + ")");
340336 return ;
341337 }
342338
@@ -360,9 +356,9 @@ private void requestMoreIfNeeded() {
360356 maxInFlight - inFlightRequests .size ());
361357 if (partsNeeded > 0 ) {
362358 // todo change trace log
363- log .info (() -> "Requesting " + partsNeeded + " more transformers. Total requested will be: "
364- + (currentRequested + partsNeeded ) + ". Remaining parts: " + remainingParts
365- + ". InFlight: " + inFlightRequests .size ());
359+ // log.info(() -> "Requesting " + partsNeeded + " more transformers. Total requested will be: "
360+ // + (currentRequested + partsNeeded) + ". Remaining parts: " + remainingParts
361+ // + ". InFlight: " + inFlightRequests.size());
366362 request (partsNeeded );
367363 }
368364
0 commit comments