diff --git a/server/src/test/java/org/elasticsearch/cluster/coordination/LeaderCheckerTests.java b/server/src/test/java/org/elasticsearch/cluster/coordination/LeaderCheckerTests.java index f7af9e9ddbe17..37f598830a98e 100644 --- a/server/src/test/java/org/elasticsearch/cluster/coordination/LeaderCheckerTests.java +++ b/server/src/test/java/org/elasticsearch/cluster/coordination/LeaderCheckerTests.java @@ -115,10 +115,14 @@ protected void onSendRequest(long requestId, String action, TransportRequest req super.onSendRequest(requestId, action, request, node); final boolean mustSucceed = leaderCheckRetryCount - 1 <= consecutiveFailedRequestsCount; - final long responseDelay = randomLongBetween(0, leaderCheckTimeoutMillis + (mustSucceed ? -1 : 60000)); + final long responseDelay = randomValueOtherThan( + leaderCheckTimeoutMillis, + () -> randomLongBetween(0, leaderCheckTimeoutMillis + (mustSucceed ? -1 : 60000)) + ); final boolean successResponse = allResponsesFail.get() == false && (mustSucceed || randomBoolean()); - if (responseDelay >= leaderCheckTimeoutMillis) { + assert responseDelay != leaderCheckTimeoutMillis; + if (responseDelay > leaderCheckTimeoutMillis) { timeoutCount.incrementAndGet(); consecutiveFailedRequestsCount += 1; } else if (successResponse == false) {