honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 02:14:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

[TEST] First decrement in-flight requests before releasing the latch

Browse Source
This commit is contained in:
Simon Willnauer 2016-07-12 22:58:03 +02:00
parent c493774093
commit eba69ffade
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
test/framework/src/main/java/org/elasticsearch/transport/AbstractSimpleTransportTestCase.java
View File

@ -563,9 +563,9 @@ public abstract class AbstractSimpleTransportTestCase extends ESTestCase {
new TransportRequestHandler<StringMessageRequest>() {
@Override
public void messageReceived(StringMessageRequest request, TransportChannel channel) throws InterruptedException {
String message = request.message;
inFlight.incrementAndGet();
try {
String message = request.message;
if ("forever".equals(message)) {
waitForever.await();
} else {
@ -577,13 +577,12 @@ public abstract class AbstractSimpleTransportTestCase extends ESTestCase {
} catch (IOException e) {
logger.error("Unexpected failure", e);
fail(e.getMessage());
} finally {
if ("forever".equals(message)) {
doneWaitingForever.countDown();
}
}
} finally {
inFlight.decrementAndGet();
if ("forever".equals(message)) {
doneWaitingForever.countDown();
}
}
}
});