- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for reserve (0.04 sec)
-
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/smb/SmbClientTest.java
Path dir1 = usersDir.resolve("dir1"); Files.createDirectory(dir1); Files.writeString(dir1.resolve("file2.txt"), "file2"); Path dir2 = dir1.resolve("dir2"); Files.createDirectory(dir2); Files.writeString(dir2.resolve("file3.txt"), "file3"); Path dir3 = usersDir.resolve("dir3"); Files.createDirectory(dir3);Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 13.7K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java
Thread th = new Thread(() -> { try { Thread.sleep(1000); } catch (InterruptedException ignore) {} deferred.resolve(new SuggestResponse("", 0, Collections.emptyList(), 0, null)); }); th.start(); final CountDownLatch latch = new CountDownLatch(1); deferred.promise().then(response -> latch.countDown());Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Sat Mar 15 06:51:20 UTC 2025 - 4.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/conn/IdnDnsResolver.java
* The host name is first converted to ASCII using IDN before resolution. * * @param host the host name to resolve * @return an array of IP addresses for the host * @throws UnknownHostException if the host name cannot be resolved */ @Override public InetAddress[] resolve(final String host) throws UnknownHostException { return InetAddress.getAllByName(toAscii(host)); } /**Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 3.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java
* It is similar to a Promise in JavaScript. * It allows you to register callbacks that will be executed when the computation is complete, * either successfully (resolve) or with an error (reject). * </p> * * <p> * The Deferred class has a Promise inner class that allows you to register callbacks * to be executed when the computation is complete.
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Fri Jul 04 14:00:23 UTC 2025 - 7.8K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/NumberConcatenationFilterFactory.java
super(indexSettings, name, settings); final String suffixWordsPath = settings.get("suffix_words_path"); if (suffixWordsPath != null) { final File suffixWordsFile = environment.configDir().resolve(suffixWordsPath).toFile(); try (Reader reader = IOUtils.getDecodingReader(new FileInputStream(suffixWordsFile), StandardCharsets.UTF_8)) { suffixWords = WordlistLoader.getWordSet(reader);
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Sun May 18 02:59:16 UTC 2025 - 2.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/request/Request.java
} return deferred.promise(); } /** * Processes the request. * @param client The OpenSearch client. * @param deferred The Deferred object to resolve or reject the response. */ protected abstract void processRequest(Client client, Deferred<T> deferred); /** * Returns a validation error message, or null if there are no errors.Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Fri Jul 04 14:00:23 UTC 2025 - 2.2K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/SynonymLoader.java
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Sun May 18 02:59:16 UTC 2025 - 6.7K bytes - Viewed (1) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java
} } })); } /** The charset used for encoding and decoding. */ protected String charset = Constants.UTF_8; /** Whether to resolve SIDs. */ protected boolean resolveSids = true; /** The content length helper. */ @Resource protected ContentLengthHelper contentLengthHelper; /** The SMB authentication holder. */Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Sep 18 09:30:45 UTC 2025 - 23K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/ReloadableKeywordMarkerFilterFactory.java
final Settings settings) { super(indexSettings, name, settings); final String path = settings.get("keywords_path"); if (path != null) { keywordPath = environment.configDir().resolve(path); } else { keywordPath = null; } reloadInterval = settings.getAsTime("reload_interval", TimeValue.timeValueMinutes(1)).getMillis(); } @OverrideRegistered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Sun May 18 02:59:16 UTC 2025 - 2K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/ReloadableStopFilterFactory.java
final Settings settings) { super(indexSettings, name, settings); final String path = settings.get("stopwords_path"); if (path != null) { stopwordPath = environment.configDir().resolve(path); } else { stopwordPath = null; } ignoreCase = settings.getAsBoolean("ignore_case", false);Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Sun May 18 02:59:16 UTC 2025 - 2.1K bytes - Viewed (0)