Change log levels
This commit is contained in:
parent
87d000968a
commit
3a7b1498ff
|
@ -108,20 +108,20 @@ public class CachedIndexSearcherManager implements IndexSearcherManager {
|
||||||
})
|
})
|
||||||
.then(refresherClosed.asMono())
|
.then(refresherClosed.asMono())
|
||||||
.then(Mono.<Void>fromRunnable(() -> {
|
.then(Mono.<Void>fromRunnable(() -> {
|
||||||
logger.info("Closed IndexSearcherManager");
|
logger.debug("Closed IndexSearcherManager");
|
||||||
logger.info("Closing refreshes...");
|
logger.debug("Closing refreshes...");
|
||||||
long initTime = System.nanoTime();
|
long initTime = System.nanoTime();
|
||||||
while (activeRefreshes.get() > 0 && (System.nanoTime() - initTime) <= 15000000000L) {
|
while (activeRefreshes.get() > 0 && (System.nanoTime() - initTime) <= 15000000000L) {
|
||||||
LockSupport.parkNanos(50000000);
|
LockSupport.parkNanos(50000000);
|
||||||
}
|
}
|
||||||
logger.info("Closed refreshes...");
|
logger.debug("Closed refreshes...");
|
||||||
logger.info("Closing active searchers...");
|
logger.debug("Closing active searchers...");
|
||||||
initTime = System.nanoTime();
|
initTime = System.nanoTime();
|
||||||
while (activeSearchers.get() > 0 && (System.nanoTime() - initTime) <= 15000000000L) {
|
while (activeSearchers.get() > 0 && (System.nanoTime() - initTime) <= 15000000000L) {
|
||||||
LockSupport.parkNanos(50000000);
|
LockSupport.parkNanos(50000000);
|
||||||
}
|
}
|
||||||
logger.info("Closed active searchers");
|
logger.debug("Closed active searchers");
|
||||||
logger.info("Stopping searcher executor...");
|
logger.debug("Stopping searcher executor...");
|
||||||
cachedSnapshotSearchers.invalidateAll();
|
cachedSnapshotSearchers.invalidateAll();
|
||||||
cachedSnapshotSearchers.cleanUp();
|
cachedSnapshotSearchers.cleanUp();
|
||||||
searchExecutor.shutdown();
|
searchExecutor.shutdown();
|
||||||
|
@ -133,7 +133,7 @@ public class CachedIndexSearcherManager implements IndexSearcherManager {
|
||||||
} catch (InterruptedException e) {
|
} catch (InterruptedException e) {
|
||||||
logger.error("Failed to stop executor", e);
|
logger.error("Failed to stop executor", e);
|
||||||
}
|
}
|
||||||
logger.info("Stopped searcher executor...");
|
logger.debug("Stopped searcher executor");
|
||||||
}).subscribeOn(uninterruptibleScheduler(Schedulers.boundedElastic())))
|
}).subscribeOn(uninterruptibleScheduler(Schedulers.boundedElastic())))
|
||||||
.publishOn(Schedulers.parallel())
|
.publishOn(Schedulers.parallel())
|
||||||
.cache();
|
.cache();
|
||||||
|
|
|
@ -493,10 +493,10 @@ public class LLLocalLuceneIndex implements LLLuceneIndex {
|
||||||
.then(Mono.<Void>fromCallable(() -> {
|
.then(Mono.<Void>fromCallable(() -> {
|
||||||
shutdownLock.lock();
|
shutdownLock.lock();
|
||||||
try {
|
try {
|
||||||
logger.info("Closing IndexWriter...");
|
logger.debug("Closing IndexWriter...");
|
||||||
indexWriter.close();
|
indexWriter.close();
|
||||||
directory.close();
|
directory.close();
|
||||||
logger.info("IndexWriter closed");
|
logger.debug("IndexWriter closed");
|
||||||
} finally {
|
} finally {
|
||||||
shutdownLock.unlock();
|
shutdownLock.unlock();
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user