Module org.elasticsearch.server

Package org.elasticsearch.index.engine

Class ElasticsearchReaderManager

java.lang.Object

org.apache.lucene.search.ReferenceManager<ElasticsearchDirectoryReader>

org.elasticsearch.index.engine.ElasticsearchReaderManager

All Implemented Interfaces:

Closeable, AutoCloseable

public class ElasticsearchReaderManager
extends org.apache.lucene.search.ReferenceManager<ElasticsearchDirectoryReader>

Utility class to safely share ElasticsearchDirectoryReader instances across multiple threads, while periodically reopening. This class ensures each reader is closed only once all threads have finished using it.

See Also:

• SearcherManager

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.lucene.search.ReferenceManager

org.apache.lucene.search.ReferenceManager.RefreshListener

Field Summary

Fields inherited from class org.apache.lucene.search.ReferenceManager

current

Constructor Summary

Constructors

Constructor	Description
ElasticsearchReaderManager(ElasticsearchDirectoryReader reader)	Creates and returns a new ElasticsearchReaderManager from the given already-opened ElasticsearchDirectoryReader, stealing the incoming reference.

Method Summary

Modifier and Type	Method	Description
protected void	decRef(ElasticsearchDirectoryReader reference)
protected int	getRefCount(ElasticsearchDirectoryReader reference)
protected ElasticsearchDirectoryReader	refreshIfNeeded(ElasticsearchDirectoryReader referenceToRefresh)
protected boolean	tryIncRef(ElasticsearchDirectoryReader reference)

Methods inherited from class org.apache.lucene.search.ReferenceManager

acquire, addListener, afterClose, afterMaybeRefresh, close, maybeRefresh, maybeRefreshBlocking, release, removeListener

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ElasticsearchReaderManager

public ElasticsearchReaderManager(ElasticsearchDirectoryReader reader)

Creates and returns a new ElasticsearchReaderManager from the given already-opened ElasticsearchDirectoryReader, stealing the incoming reference.

Parameters:

reader - the directoryReader to use for future reopens

Method Details

decRef

protected void decRef(ElasticsearchDirectoryReader reference)
               throws IOException

Specified by:

decRef in class org.apache.lucene.search.ReferenceManager<ElasticsearchDirectoryReader>

Throws:

IOException

refreshIfNeeded

protected ElasticsearchDirectoryReader refreshIfNeeded(ElasticsearchDirectoryReader referenceToRefresh)
                                                throws IOException

Specified by:

refreshIfNeeded in class org.apache.lucene.search.ReferenceManager<ElasticsearchDirectoryReader>

Throws:

IOException

tryIncRef

protected boolean tryIncRef(ElasticsearchDirectoryReader reference)

Specified by:

tryIncRef in class org.apache.lucene.search.ReferenceManager<ElasticsearchDirectoryReader>

getRefCount

protected int getRefCount(ElasticsearchDirectoryReader reference)

Specified by:

getRefCount in class org.apache.lucene.search.ReferenceManager<ElasticsearchDirectoryReader>