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:...

@Override L83: public boolean generate(final String thumbnailId, final File outputFile) { L84: if (logger.isDebugEnabled()) { L85: logger.debug("Generate Thumbnail: {}", thumbnailId); L86: } L87: L88: if (outputFile.exists()) { L89: if (logger.isDebugEnabled()) { L90: logger.debug("The thumbnail file exists: {}", outputFile.getAbsolutePath()); L91: } L92: return true; L93: } L94: L95: final File parentFile...

if (logger.isDebugEnabled()) { L329: logger.debug("Indexing {}", accessResult.getUrl()); L330: } L331: accessResult.setStatus(Constants.DONE_STATUS); L332: accessResultList.add(accessResult); L333: L334: if (accessResult.getHttpStatusCode() != 200) { L335: // invalid page L336: if (logger.isDebugEnabled()) { L337: logger.debug("Skipped. The response code is {}.", accessResult.getHttpStatusCode());...

ath).matches()) { L289: if (logger.isDebugEnabled()) { L290: logger.debug("Path {} matches the exclude path expression {} on {} of label.", path, excludedPaths, value); L291: } L292: return false; L293: } L294: if (logger.isDebugEnabled()) { L295: logger.debug("Path {} does not match the exclude path expression {} on {} of label.", path, excludedPaths, value); L296: ...

ComponentUtil.getFessConfig(); L54: final SystemHelper systemHelper = ComponentUtil.getSystemHelper(); L55: final long execTime = systemHelper.getCurrentTimeAsLong(); L56: if (logger.isDebugEnabled()) { L57: logger.debug("Sending {} documents to a server.", docList.size()); L58: } L59: try { L60: if (fessConfig.isThumbnailCrawlerEnabled()) { L61: final ThumbnailManager thumbnailManager = ComponentUtil.getThumbnailManager(); L62:...

out); L160: } catch (final ClientAbortException e) { L161: logger.debug("Client aborts this request.", e); L162: } L163: } catch (final Exception e) { L164: if (!(e.getCause() instanceof ClientAbortException)) { L165: throw new WebApiException(HttpServletResponse.SC_INTERNAL_SERVER_ERROR, e); L166: } L167: logger.debug("Client aborts this request.", e); L168: } L169: } L170: L171: protected void...

Constants.FESEN_TYPE_AWS: L727: if (logger.isDebugEnabled()) { L728: logger.debug("Skipped configsync flush: {}", fesenType); L729: } L730: callback.run(); L731: break; L732: default: L733: ComponentUtil.getCurlHelper().post("/_configsync/flush").execute(response -> { L734: if (logger.isDebugEnabled()) { L735: logger.debug("Flushed config files: {} => {}", fesenType, response.getContentAsString()); L736: ...

L43: public QueryBuilder execute(final QueryContext context, final Query query, final float boost) { L44: if (query instanceof final TermRangeQuery termRangeQuery) { L45: if (logger.isDebugEnabled()) { L46: logger.debug("{}:{}", query, boost); L47: } L48: return convertTermRangeQuery(context, termRangeQuery, boost); L49: } L50: throw new InvalidQueryException(messages -> messages.addErrorsInvalidQueryUnknown(UserMessages.GLOBAL_PROPERTY_KEY),...

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:...

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())...