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

Merge pull request #14909 from jasontedor/release-after-successful-acquire

Browse Source 
Do not release unacquired semaphore
This commit is contained in:
Jason Tedor 2015-11-20 18:20:22 -05:00
commit 22187113b6
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/main/java/org/elasticsearch/action/bulk/BulkProcessor.java
View File

@ -324,9 +324,11 @@ public class BulkProcessor implements Closeable {
}
} else {
boolean success = false;
boolean acquired = false;
try {
listener.beforeBulk(executionId, bulkRequest);
semaphore.acquire();
acquired = true;
client.bulk(bulkRequest, new ActionListener<BulkResponse>() {
@Override
public void onResponse(BulkResponse response) {
@ -353,7 +355,7 @@ public class BulkProcessor implements Closeable {
} catch (Throwable t) {
listener.afterBulk(executionId, bulkRequest, t);
} finally {
if (!success) { // if we fail on client.bulk() release the semaphore
if (!success && acquired) { // if we fail on client.bulk() release the semaphore
semaphore.release();
}
}