deleteMethod("/api/admin/joblog/log/" + elem.get("id")).then().body("response.status", equalTo(0)); L195: } L196: L197: final List<Map<String, Object>> afterList = readJobLog(NAME_PREFIX); L198: assertEquals(0, afterList.size()); // check if logs are successfully deleted L199: } L200: L201: /** L202: * Test for CrawlingInfo L203: * */ L204: private void testReadCrawlingInfo() { L205: final List<Map<String, Object>> logList = readCrawlingInfo(webConfigId); L206:...

(!clazz.getName().contains(webPackageKeyword) || L51: // exclude app.web.api.admin packages L52: clazz.getName().contains(".app.web.api.admin.")) { L53: return; L54: } L55: check(srcFile, clazz, webPackageKeyword); L56: } L57: }); L58: } L59:}...

} L36: L37: @Override L38: public boolean isValid(final String value, final ConstraintValidatorContext context) { L39: if (StringUtil.isNotBlank(value)) { L40: return check(protocols, value); L41: } L42: return true; L43: } L44: L45: protected static boolean check(final String[] protocols, final String value) { L46: final String[] paths = value.split("[\r\n]"); L47: for (final String path : paths) { L48: if (StringUtil.isNotBlank(path)...

L132: final FessConfig fessConfig = ComponentUtil.getFessConfig(); L133: final CrawlerStatsHelper crawlerStatsHelper = ComponentUtil.getCrawlerStatsHelper(); L134: synchronized (indexUpdateCallback) { L135: // required check L136: if (!dataMap.containsKey(fessConfig.getIndexFieldUrl()) || dataMap.get(fessConfig.getIndexFieldUrl()) == null) { L137: logger.warn("Could not add a doc. Invalid data: {}", dataMap); L138: return; L139:...

g(); L80: final SearchEngineClient searchEngineClient = ComponentUtil.getSearchEngineClient(); L81: L82: if (logger.isDebugEnabled()) { L83: logger.debug("Adding {}", dataMap); L84: } L85: L86: // required check L87: final Object urlObj = dataMap.get(fessConfig.getIndexFieldUrl()); L88: if (urlObj == null) { L89: throw new DataStoreException("url is null. dataMap=" + dataMap); L90: } L91: L92: final IndexingHelper indexingHelper...

, Constants.RUNNING); L126: startedCrawlerNum++; L127: activeCrawlerNum++; L128: ThreadUtil.sleep(crawlingExecutionInterval); L129: continue; L130: } L131: L132: // check status L133: for (int i = 0; i < startedCrawlerNum; i++) { L134: if (!dataCrawlingThreadList.get(i).isRunning() && Constants.RUNNING.equals(dataCrawlingThreadStatusList.get(i))) { L135: dataCrawlingThre...

Select L100: // ====== L101: @Override L102: protected int delegateSelectCountUniquely(final ConditionBean cb) { L103: // #pending check response and cast problem L104: final SearchRequestBuilder builder = client.prepareSearch(asEsIndex()); L105: final EsAbstractConditionBean esCb = (EsAbstractConditionBean) cb; L106: if (esCb.getPreference() != null) { L107: ...

L155: } L156: L157: // #for_now jflute to suppress CVE-2014-0050 even if commons-fileupload is older than safety version (2024/09/08) L158: // but if you use safety version, this extension is basically unneeded (or you can use it as double check) L159: protected void checkBoundarySize(final String contentType, final byte[] boundary) { L160: final int boundarySize = boundary.length; L161: final int limitSize = getBoundaryLimitSize(); L162: if (boundarySize > getBoundaryLimitSize())...

client.admin().indices().prepareExists(indexName).execute().actionGet(fessConfig.getIndexSearchTimeout()); L411: exists = response.isExists(); L412: } catch (final Exception e) { L413: logger.debug("Failed to check {} index status.", indexName, e); L414: } L415: return exists; L416: } L417: L418: public boolean copyDocIndex(final String fromIndex, final String toIndex, final boolean waitForCompletion) { L419: final FessConfig fessConfig...

LABELS_DEFAULT_LABEL_VALUE = "{labels.defaultLabelValue}"; L181: L182: /** The key of the message: File Name */ L183: public static final String LABELS_DESIGN_FILE_NAME = "{labels.designFileName}"; L184: L185: /** The key of the message: Check Last Modified */ L186: public static final String LABELS_INCREMENTAL_CRAWLING = "{labels.incrementalCrawling}"; L187: L188: /** The key of the message: Error Count */ L189: public static final String LABELS_ERROR_COUNT = "{labels.errorCount}";...