- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for AtomicBoolean (0.23 sec)
-
src/test/java/org/codelibs/fess/query/QueryProcessorTest.java
import org.opensearch.index.query.QueryBuilders; public class QueryProcessorTest extends UnitFessTestCase { public void test_executeWithFilter() { final AtomicBoolean called = new AtomicBoolean(false); QueryProcessor queryProcessor = new QueryProcessor() { protected FilterChain createDefaultFilterChain() { return (context, query, boost) -> {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 3.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
private static final String WEB_FS_CRAWLING_PROCESS = "WebFsCrawler"; private static final String DATA_CRAWLING_PROCESS = "DataStoreCrawler"; private static AtomicBoolean running = new AtomicBoolean(false); private static Queue<String> errors = new ConcurrentLinkedQueue<>(); @Resource protected SearchEngineClient searchEngineClient; @Resource
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 24.1K bytes - Viewed (2) -
src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 22.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java
} }); } private void importBulk(final String fileName, final File tempFile) { final ObjectMapper mapper = new ObjectMapper(); final AtomicBoolean resetJobs = new AtomicBoolean(false); try (CurlResponse response = ComponentUtil.getCurlHelper().post("/_bulk").onConnect((req, con) -> { con.setDoOutput(true);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 25.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
private static final Logger logger = LogManager.getLogger(SystemHelper.class); protected final Map<String, String> designJspFileNameMap = new LinkedHashMap<>(); protected final AtomicBoolean forceStop = new AtomicBoolean(false); protected LoadingCache<String, List<Map<String, String>>> langItemsCache; protected String filterPathEncoding; protected String[] supportedLanguages;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Sat Apr 13 11:43:03 GMT 2024 - 26.5K bytes - Viewed (2) -
src/test/java/org/codelibs/fess/ldap/LdapManagerTest.java
assertEquals("a_a", ldapManager.replaceWithUnderscores("a/a")); } public void test_allowEmptyGroupAndRole() { final AtomicBoolean allowEmptyPermission = new AtomicBoolean(); ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() { public boolean isLdapAllowEmptyPermission() { return allowEmptyPermission.get(); }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
} } protected static class ProcessDestroyer extends TimerTask { private final Process p; private final InputStreamThread ist; private final AtomicBoolean executed = new AtomicBoolean(false); private final long timeout; public ProcessDestroyer(final Process p, final InputStreamThread ist, final long timeout) { this.p = p; this.ist = ist;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.6K bytes - Viewed (0)