Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for Sait (0.01 sec)

  1. fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java

            } catch (final ExecutionException e) {
                // no thing to do
            }
    
            long elapsed = (System.nanoTime() - time) / 1000000;
            long wait = waittime * (numTasks - 1);
            assertTrue(elapsed + " >= " + wait, elapsed + 1L >= wait);
        }
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java

     *   for successful and unsuccessful computations, respectively.
     * </p>
     *
     * <p>
     *   The Deferred class uses a CountDownLatch to allow you to wait for the computation to complete.
     *   The resolve and reject methods decrement the CountDownLatch, allowing the getResponse method
     *   to return the result of the computation.
     * </p>
     *
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Fri Jul 04 14:00:23 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  3. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java

                settingsBuilder.put("http.cors.enabled", true);
                settingsBuilder.put("discovery.type", "single-node");
            }).build(newConfigs().clusterName(clusterName).numOfNode(1));
    
            // wait for yellow status
            runner.ensureYellow();
    
            System.setProperty(FesenClient.HTTP_ADDRESS, "localhost:" + runner.node().settings().get("http.port", "9201"));
    
            super.setUp();
        }
    
        @Override
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataServiceTest.java

                settingsBuilder.put("http.cors.enabled", true);
                settingsBuilder.put("discovery.type", "single-node");
            }).build(newConfigs().clusterName(clusterName).numOfNode(1));
    
            // wait for yellow status
            runner.ensureYellow();
    
            System.setProperty(FesenClient.HTTP_ADDRESS, "localhost:" + runner.node().settings().get("http.port", "9201"));
    
            super.setUp();
        }
    
        @Override
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/HostIntervalController.java

                        if (delayTime <= 0) {
                            lastTime.set(currentTime);
                            break;
                        }
                        lastTime.wait(delayTime);
                    }
                }
            } catch (final InterruptedException e) {
                throw new InterruptedRuntimeException(e);
            } catch (final Exception e) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  6. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                settingsBuilder.put("http.cors.allow-origin", "*");
                settingsBuilder.put("discovery.type", "single-node");
            }).build(newConfigs().clusterName(clusterName).numOfNode(1));
    
            // wait for yellow status
            runner.ensureYellow();
    
            System.setProperty(FesenClient.HTTP_ADDRESS, "localhost:" + runner.node().settings().get("http.port", "9201"));
    
            super.setUp();
    
            // logging
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/FaultTolerantClient.java

     *   <li>Exception tracking and aggregation</li>
     *   <li>Request lifecycle monitoring through listener</li>
     * </ul>
     *
     * <p>By default, it will:</p>
     * <ul>
     *   <li>Retry up to 5 times</li>
     *   <li>Wait 500ms between retries</li>
     * </ul>
     *
     */
    public class FaultTolerantClient implements CrawlerClient {
    
        /** Logger instance for this class */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 7.8K bytes
    - Viewed (0)
Back to top