logger.info("Cpu Load {}% is greater than {}%. {} waiting thread(s). {} thread is timed out.", current, percent, L627: waitingThreadNames.size(), threadName); L628: } L629: return false; L630: } L631: if (logger.isInfoEnabled()) { L632: logger.info("Cpu Load {}% is greater than {}%. {} waiting thread(s).", current, percent, waitingThreadNames.size()); L633: ...

logger.debug("Failed to copy {}", filename, e); L104: throwValidationError(messages -> messages.addErrorsFailedToInstallPlugin(GLOBAL, filename), this::asListHtml); L105: } L106: new Thread(() -> { L107: try { L108: final PluginHelper pluginHelper = ComponentUtil.getPluginHelper(); L109: final Artifact artifact = L110: pluginHelper.getArt...

GenericExternalContext()); L117: SingletonLaContainerFactory.setExternalContextComponentDefRegister(new GenericExternalContextComponentDefRegister()); L118: SingletonLaContainerFactory.init(); L119: L120: final Thread shutdownCallback = new Thread("ShutdownHook") { L121: @Override L122: public void run() { L123: if (logger.isDebugEnabled()) { L124: logger.debug("Destroying LaContainer.."); L125: ...

end('}'); L101: return b.toString(); L102: }).collect(Collectors.joining(","))); L103: buf.append("},"); L104: final Threads threads = jvmStats.getThreads(); L105: buf.append("\"threads\":{"); L106: append(buf, "count", () -> threads.getCount()).append(','); L107: append(buf, "peak", () -> threads.getPeakCount()); L108: buf.append("},"); L109: final Classes classes = jvmStats.getClasses(); L110: buf.append("\"classes\":{");...

"delete_old_docs"; L45: L46: private static final String KEEP_EXPIRES_DOCS = "keep_expires_docs"; L47: L48: protected long crawlingExecutionInterval = Constants.DEFAULT_CRAWLING_EXECUTION_INTERVAL; L49: L50: protected int crawlerPriority = Thread.NORM_PRIORITY; L51: L52: protected final List<DataCrawlingThread> dataCrawlingThreadList = Collections.synchronizedList(new ArrayList<>()); L53: L54: public void crawl(final String sessionId) { L55: final List<DataConfig> configList =...

L154: L155: failureUrl.setErrorName(errorName); L156: failureUrl.setErrorLog(getStackTrace(e)); L157: failureUrl.setLastAccessTime(ComponentUtil.getSystemHelper().getCurrentTimeAsLong()); L158: failureUrl.setThreadName(Thread.currentThread().getName()); L159: L160: bhv.insertOrUpdate(failureUrl, op -> { L161: op.setRefreshPolicy(Constants.TRUE); L162: }); L163: return failureUrl; L164: } L165: L166: private String getStackTrace(final...

c.getCollectionTime().getMillis(); L111: return jvmGcObj; L112: }).toArray(n -> new JvmGcObj[n]); L113: final Threads threads = jvmStats.getThreads(); L114: final JvmThreadsObj jvmThreadsObj = new JvmThreadsObj(); L115: jvmObj.threads = jvmThreadsObj; L116: jvmThreadsObj.count = threads.getCount(); L117: jvmThreadsObj.peak = threads.getPeakCount(); L118: final Classes classes = jvmStats.getClasses(); L119: final JvmClassesObj jvmClassesObj =...

ignoreIdleThreads = Constants.TRUE.equalsIgnoreCase(fessConfig.getCrawlerHotthreadIgnoreIdleThreads()); L44: final TimeValue interval = TimeValue.parseTimeValue(fessConfig.getCrawlerHotthreadInterval(), "crawler.hotthread.interval"); L45: final int threads = fessConfig.getCrawlerHotthreadThreadsAsInteger(); L46: final String timeout = fessConfig.getCrawlerHotthreadTimeout(); L47: final String type = fessConfig.getCrawlerHotthreadType(); L48: try { L49: final SearchEngineClient...

org.opensearch.index.query.QueryBuilders; L58:import org.opensearch.search.sort.SortOrder; L59: L60:import jakarta.annotation.PostConstruct; L61:import jakarta.annotation.PreDestroy; L62:import jakarta.annotation.Resource; L63: L64:public class IndexUpdater extends Thread { L65: private static final Logger logger = LogManager.getLogger(IndexUpdater.class); L66: L67: protected List<String> sessionIdList; L68: L69: @Resource L70: protected SearchEngineClient searchEngineClient; L71: L72: @Resource L73:...

maxRedirectCount = fessConfig.getIndexerDataMaxRedirectCountAsInteger(); L88: } L89: L90: protected ExecutorService newFixedThreadPool(final int nThreads) { L91: if (logger.isDebugEnabled()) { L92: logger.debug("Executor Thread Pool: {}", nThreads); L93: } L94: return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(nThreads), L95: new ThreadPoolExecutor.CallerRunsPolicy()); L96: } L97: L98: ...