- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for Sait (0.01 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)