if (logger.isDebugEnabled()) { L192: logger.debug("process authentication: url: {}, params: {}", urlBuf, params); L193: } L194: L195: // validate that state in response equals to state in request L196: final StateData stateData = validateState(request.getSession(), params.containsKey(STATE) ? params.get(STATE).get(0) : null); L197: if (logger.isDebugEnabled()) { L198: logger.debug("load {}", stateData); L199: } L200: L201: final...

OptionalThing.empty()); L257: response.flushBuffer(); L258: if (logger.isDebugEnabled()) { L259: logger.debug("Loaded {} docs", count); L260: } L261: } catch (final InvalidQueryException | ResultOffsetExceededException e) { L262: if (logger.isDebugEnabled()) { L263: logger.debug("Failed to process a scroll request.", e); L264: } L265: writeJsonResponse(HttpServletResponse.SC_BAD_REQUEST, e); L266:...

ManagementFactory.getRuntimeMXBean().getInputArguments().stream().forEach(s -> logger.debug("Parameter: {}", s)); L99: System.getProperties().entrySet().stream().forEach(e -> logger.debug("Property: {}={}", e.getKey(), e.getValue())); L100: System.getenv().entrySet().forEach(e -> logger.debug("Env: {}={}", e.getKey(), e.getValue())); L101: logger.debug("Option: {}", options); L102: } catch (final Exception e) { L103: //...

) { L71: cachedPathMappingList.forEach(e -> { L72: logger.debug("path mapping: {}: {} -> {}", e.getId(), e.getRegex(), e.getReplacement()); L73: }); L74: } L75: return cachedPathMappingList.size(); L76: } catch (final ComponentNotFoundException e) { L77: if (logger.isDebugEnabled()) { L78: logger.debug("Failed to load path mappings.", e); L79: } L80: cachedPathMappingList...

protected String[] supportedLanguages; L40: L41: protected LanguageDetector detector; L42: L43: protected int maxTextLength; L44: L45: @PostConstruct L46: public void init() { L47: if (logger.isDebugEnabled()) { L48: logger.debug("Initialize {}", this.getClass().getSimpleName()); L49: } L50: final FessConfig fessConfig = ComponentUtil.getFessConfig(); L51: langFields = fessConfig.getIndexerLanguageFieldsAsArray(); L52: supportedLanguages = fessC...

add(final ThumbnailGenerator generator) { L328: if (generator.isAvailable()) { L329: if (logger.isDebugEnabled()) { L330: logger.debug("{} is available.", generator.getName()); L331: } L332: generatorList.add(generator); L333: } else if (logger.isDebugEnabled()) { L334: logger.debug("{} is not available.", generator.getName()); L335: } L336: } L337: L338: public long purge(final long expiry) { L339: if (!baseDir.exists())...

task = new Tuple3<>(getName(), thumbnailId, path); L53: if (logger.isDebugEnabled()) { L54: logger.debug("Create thumbnail task: {}", task); L55: } L56: return task; L57: } L58: L59: @Override L60: public boolean generate(final String thumbnailId, final File outputFile) { L61: if (logger.isDebugEnabled()) { L62: logger.debug("Generate Thumbnail: {}", thumbnailId); L63: } L64: L65: if (outputFile.exists()) { L66: if...

StreamUtil.split(value, ",") L100: .get(stream -> stream.map(String::trim).filter(StringUtil::isNotBlank).collect(Collectors.toUnmodifiableSet())); L101: } L102: if (logger.isDebugEnabled()) { L103: logger.debug("availableSearcherNameSet={}", availableSearcherNameSet); L104: } L105: } L106: L107: @Override L108: @PreDestroy L109: public void close() throws Exception { L110: if (executorService != null) { L111: try { L112:...

throw new ScheduledJobException("No jobExecutor: " + scriptType); L79: } L80: L81: if (!jobManager.findJobByUniqueOf(LaJobUnique.of(id)).isPresent()) { L82: if (logger.isDebugEnabled()) { L83: logger.debug("Job {} is running.", id); L84: } L85: return; L86: } L87: L88: TimeoutTask task = null; L89: try { L90: if (scheduledJob.isLoggingEnabled()) { L91: jobHelper.store(jobLog); L92:...

maxDocumentRequestSize; L53: L54: protected int maxDocumentCacheSize; L55: L56: private IngestFactory ingestFactory = null; L57: L58: @PostConstruct L59: public void init() { L60: if (logger.isDebugEnabled()) { L61: logger.debug("Initialize {}", this.getClass().getSimpleName()); L62: } L63: maxDocumentRequestSize = Long.parseLong(ComponentUtil.getFessConfig().getIndexerDataMaxDocumentRequestSize()); L64: maxDocumentCacheSize = ComponentUtil.getFessCon...