Skip to content

Commit bb2af54

Browse files
revert debug change
1 parent d30b2a5 commit bb2af54

File tree

1 file changed

+4
-9
lines changed

1 file changed

+4
-9
lines changed

server/src/main/java/org/elasticsearch/action/ActionListener.java

Lines changed: 4 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -388,19 +388,14 @@ static <Response> ActionListener<Response> assertOnce(ActionListener<Response> d
388388
// if complete, records the stack trace which first completed it
389389
private final AtomicReference<ElasticsearchException> firstCompletion = new AtomicReference<>();
390390

391-
private void assertFirstRun(Exception t) {
391+
private void assertFirstRun() {
392392
var previousRun = firstCompletion.compareAndExchange(null, new ElasticsearchException("executed already"));
393-
// reports the stack traces of both completions
394-
assert previousRun == null
395-
: new AssertionError(
396-
"[" + delegate + "] " + previousRun,
397-
t == null ? previousRun : ExceptionsHelper.useOrSuppress(previousRun, t)
398-
);
393+
assert previousRun == null : "[" + delegate + "] " + previousRun; // reports the stack traces of both completions
399394
}
400395

401396
@Override
402397
public void onResponse(Response response) {
403-
assertFirstRun(null);
398+
assertFirstRun();
404399
try {
405400
delegate.onResponse(response);
406401
} catch (Exception e) {
@@ -411,7 +406,7 @@ public void onResponse(Response response) {
411406

412407
@Override
413408
public void onFailure(Exception e) {
414-
assertFirstRun(e);
409+
assertFirstRun();
415410
safeOnFailure(delegate, e);
416411
}
417412

0 commit comments

Comments
 (0)