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

ignore load failures on a closed reader

This commit is contained in:
Shay Banon 2011-08-31 00:19:04 +03:00
parent b3ef0a3d7f
commit 2d1a645231
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
modules/elasticsearch/src/main/java/org/elasticsearch/index/cache/bloom/simple/SimpleBloomCache.java vendored
View File

@ -41,7 +41,6 @@ import org.elasticsearch.index.cache.bloom.BloomCache;
import org.elasticsearch.index.settings.IndexSettings; import org.elasticsearch.index.settings.IndexSettings;
import org.elasticsearch.threadpool.ThreadPool; import org.elasticsearch.threadpool.ThreadPool;
import java.io.IOException;
import java.nio.channels.ClosedChannelException; import java.nio.channels.ClosedChannelException;
import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicBoolean;
@ -206,20 +205,23 @@ public class SimpleBloomCache extends AbstractIndexComponent implements BloomCac
} catch (ClosedChannelException e) { } catch (ClosedChannelException e) {
// ignore, we are getting closed // ignore, we are getting closed
} catch (Exception e) { } catch (Exception e) {
// ignore failures that result from a closed reader...
if (reader.getRefCount() > 0) {
logger.warn("failed to load bloom filter for [{}]", e, field); logger.warn("failed to load bloom filter for [{}]", e, field);
}
} finally { } finally {
try { try {
if (termDocs != null) { if (termDocs != null) {
termDocs.close(); termDocs.close();
} }
} catch (IOException e) { } catch (Exception e) {
// ignore // ignore
} }
try { try {
if (termEnum != null) { if (termEnum != null) {
termEnum.close(); termEnum.close();
} }
} catch (IOException e) { } catch (Exception e) {
// ignore // ignore
} }
} }