Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for reserve (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. src/test/java/org/codelibs/opensearch/extension/analysis/SynonymLoader.java

                    if (filePath == null) {
                        throw new IllegalArgumentException("synonyms_path is not found.");
                    }
    
                    final Path path = env.configDir().resolve(filePath);
    
                    try {
                        final File file = path.toFile();
                        if (file.exists()) {
                            reloadableFile = file;
                        }
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Sun May 18 02:59:16 UTC 2025
    - 6.7K bytes
    - Viewed (1)
  7. 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();
        }
    
        @Override
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Sun May 18 02:59:16 UTC 2025
    - 2K bytes
    - Viewed (0)
  8. 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)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/UrlConvertHelper.java

     * URLs using these rules.</p>
     *
     * <p>The conversion is performed by iterating through the conversion map and applying
     * each replacement rule sequentially. The order of the rules in the map is preserved
     * during the conversion process.</p>
     *
     * <p>Example usage:</p>
     *
     * <pre>{@code
     * UrlConvertHelper helper = new UrlConvertHelper();
     * helper.add("old-domain.com", "new-domain.com");
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/suggest/request/popularwords/PopularWordsRequest.java

                        deferred.reject(new SuggesterException("Search failure. Failed shards num:" + searchResponse.getFailedShards()));
                    } else {
                        deferred.resolve(createResponse(searchResponse));
                    }
                }
    
                @Override
                public void onFailure(final Exception e) {
                    deferred.reject(e);
                }
            });
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 9.2K bytes
    - Viewed (0)
Back to top