File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
server/src/test/java/org/elasticsearch/action/support/nodes Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -341,7 +341,7 @@ protected void newResponseAsync(
341341 ) {
342342 boolean waited = false ;
343343 // Process node responses in a loop and ensure no ConcurrentModificationException will be thrown due to
344- // concurrent cancellation comes after the loops has started, see also #128852
344+ // concurrent cancellation coming after the loop has started, see also #128852
345345 for (var response : testNodeResponses ) {
346346 if (waited == false ) {
347347 waited = true ;
@@ -364,8 +364,8 @@ protected void newResponseAsync(
364364 completeOneRequest (capturedRequest );
365365 }
366366
367- // Wait for the overall response starts to processing the node responses in a loop and then cancel the task.
368- // It should not interfere with the node response processing.
367+ // Wait for the overall response to start processing the node responses in a loop and then cancel the task.
368+ // The cancellation should not interfere with the node response processing.
369369 safeAwait (barrier );
370370 TaskCancelHelper .cancel (cancellableTask , "simulated" );
371371 safeGet (cancelledFuture );
You can’t perform that action at this time.
0 commit comments