Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for thead (0.01 sec)

  1. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java

                        }
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                    } finally {
                        endLatch.countDown();
                    }
                }
            });
    
            Thread thread2 = new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 25.6K bytes
    - Viewed (0)
  2. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/smb1/SmbClientTest.java

            SmbClient client = new SmbClient() {
                @Override
                protected ResponseData getResponseData(final String uri, final boolean includeContent) {
                    try {
                        Thread.sleep(2000);
                    } catch (InterruptedException e) {
                        throw new CrawlingAccessException(e);
                    }
                    return null;
                }
            };
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  3. fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                while (crawler.crawlerContext.getStatus() != CrawlerStatus.RUNNING && System.currentTimeMillis() - startTime < 5000) {
                    try {
                        Thread.sleep(50);
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                        break;
                    }
                }
                assertEquals(CrawlerStatus.RUNNING, crawler.crawlerContext.getStatus());
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  4. cmd/object-api-interface.go

    	DeleteMarker            bool // Is only set in DELETE operations for delete marker replication
    	CheckDMReplicationReady bool // Is delete marker ready to be replicated - set only during HEAD
    	Tagging                 bool // Is only in GET/HEAD operations to return tagging metadata along with regular metadata and body.
    
    	UserDefined         map[string]string   // only set in case of POST/PUT operations
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/http/HcHttpClientTest.java

            HcHttpClient client = new HcHttpClient() {
                @Override
                protected ResponseData processHttpMethod(final String url, final HttpUriRequest httpRequest) {
                    try {
                        Thread.sleep(2000);
                    } catch (InterruptedException e) {
                        throw new CrawlingAccessException(e);
                    }
                    return null;
                }
            };
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  6. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                        break;
                    }
                    Thread.sleep(50);
                }
                assertEquals(CrawlerStatus.RUNNING, crawler1.crawlerContext.getStatus());
                for (int i = 0; i < 100; i++) {
                    if (crawler2.crawlerContext.getStatus() == CrawlerStatus.RUNNING) {
                        break;
                    }
                    Thread.sleep(50);
                }
    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/test/java/org/codelibs/fess/crawler/rule/RuleManagerTest.java

            public void clearRules() {
                rules.clear();
            }
    
            public List<Rule> getRules() {
                return new ArrayList<>(rules);
            }
        }
    
        /**
         * Thread-safe implementation of RuleManager
         */
        public static class ThreadSafeRuleManager implements RuleManager {
            private final List<Rule> rules = new CopyOnWriteArrayList<>();
    
            @Override
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 23.8K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/AbstractCrawlerClient.java

            throw new CrawlerSystemException("GET method is not supported.");
        }
    
        /**
         * Performs a HEAD request.
         * @param url The URL to request.
         * @return The ResponseData.
         */
        protected ResponseData doHead(final String url) {
            throw new CrawlerSystemException("HEAD method is not supported.");
        }
    
        /**
         * Performs a POST request.
         * @param url The URL to request.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  9. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                while (crawler.crawlerContext.getStatus() != CrawlerStatus.RUNNING && System.currentTimeMillis() - startTime < 5000) {
                    try {
                        Thread.sleep(50);
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                        break;
                    }
                }
                assertEquals(CrawlerStatus.RUNNING, crawler.crawlerContext.getStatus());
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  10. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/fs/FileSystemClientTest.java

            FileSystemClient client = new FileSystemClient() {
                @Override
                protected ResponseData getResponseData(final String uri, final boolean includeContent) {
                    try {
                        Thread.sleep(2000);
                    } catch (InterruptedException e) {
                        throw new CrawlingAccessException(e);
                    }
                    return null;
                }
            };
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 8K bytes
    - Viewed (0)
Back to top