honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Be paranoid about double release.

This commit is contained in:
Adrien Grand 2014-02-06 20:58:57 +01:00
parent fa094a46fd
commit aab2c7a444
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/elasticsearch/index/engine/internal/InternalEngine.java
View File

@ -32,7 +32,6 @@ import org.apache.lucene.util.BytesRef;
import org.apache.lucene.util.IOUtils;
import org.elasticsearch.ElasticsearchException;
import org.elasticsearch.ElasticsearchIllegalStateException;
import org.elasticsearch.Version;
import org.elasticsearch.cluster.routing.operation.hash.djb.DjbHashFunction;
import org.elasticsearch.common.Nullable;
import org.elasticsearch.common.Preconditions;
@ -1468,11 +1467,13 @@ public class InternalEngine extends AbstractIndexShardComponent implements Engin
private final String source;
private final IndexSearcher searcher;
private final SearcherManager manager;
private final AtomicBoolean released;
private EngineSearcher(String source, IndexSearcher searcher, SearcherManager manager) {
this.source = source;
this.searcher = searcher;
this.manager = manager;
this.released = new AtomicBoolean(false);
}
@Override
@ -1492,6 +1493,9 @@ public class InternalEngine extends AbstractIndexShardComponent implements Engin
@Override
public boolean release() throws ElasticsearchException {
if (!released.compareAndSet(false, true)) {
throw new ElasticsearchIllegalStateException("Double release");
}
try {
manager.release(searcher);
return true;