- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for sleep (0.05 sec)
-
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
} Thread.sleep(500); } assertEquals(CrawlerStatus.RUNNING, crawler1.crawlerContext.getStatus()); for (int i = 0; i < 10; i++) { if (crawler2.crawlerContext.getStatus() == CrawlerStatus.RUNNING) { break; } Thread.sleep(500); }
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 7.7K bytes - Viewed (0) -
compat/maven-embedder/src/test/java/org/apache/maven/cli/transfer/SimplexTransferListenerTest.java
// for technical reasons we cannot throw here, even if delegate does cancel transfer listener.transferInitiated(event(session, resource, TransferEvent.EventType.INITIATED)); Thread.sleep(500); // to make sure queue is processed, cancellation applied // subsequent call will cancel assertThrows( TransferCancelledException.class,
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 4.9K bytes - Viewed (0) -
cmd/data-scanner.go
t := time.Now() return func() { doneAt := time.Now() d.Sleep(ctx, doneAt.Sub(t)) } } // Sleep sleeps the specified time multiplied by the sleep factor. // If the factor is updated the sleep will be done again with the new factor. func (d *dynamicSleeper) Sleep(ctx context.Context, base time.Duration) { for { // Grab current values d.mu.RLock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 21:10:34 UTC 2024 - 48.4K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/DefaultRepositoryMetadataManager.java
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 18.9K bytes - Viewed (0) -
docs/bucket/lifecycle/setup_ilm_transition.sh
export MC_HOST_siteb=http://minioadmin:minioadmin@127.0.0.1:9004 ./mc ready sitea ./mc ready siteb ./mc mb --ignore-existing sitea/bucket ./mc mb --ignore-existing siteb/bucket sleep 10s ## Add warm tier ./mc ilm tier add minio sitea WARM-TIER --endpoint http://localhost:9004 --access-key minioadmin --secret-key minioadmin --bucket bucket ## Add ILM rules
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 2.8K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/AbstractRepositoryMetadata.java
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 7K bytes - Viewed (0) -
compat/maven-compat/src/test/java/org/apache/maven/artifact/testutils/TestFileManager.java
public void markForDeletion(File toDelete) { filesToDelete.add(toDelete); warnAboutCleanup = true; } public synchronized File createTempDir() { try { Thread.sleep(20); } catch (InterruptedException e) { // ignore } File dir = new File(TEMP_DIR_PATH, baseFilename + System.currentTimeMillis()); dir.mkdirs();
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 4.7K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Oct 22 13:49:09 UTC 2024 - 6.5K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
} if (logger.isDebugEnabled()) { logger.debug("Failed to invoke actionGet. count:{}", retryCount, e); } ThreadUtil.sleep(RandomUtils.nextLong(retryInterval + retryCount * 1000L, retryInterval + retryCount * 1000L * 2L)); retryCount++; } } } @PreDestroy public void destroy() {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 19.9K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/crawler/transformer/FessXpathTransformerTest.java
setValueToObject(ComponentUtil.getLabelTypeHelper(), "labelTypePatternList", new ArrayList<LabelTypePattern>()); System.gc(); Thread.sleep(1000L); long current = MemoryUtil.getUsedMemory(); for (int i = 0; i < 10000; i++) { if (i % 1000 == 0) { logger.info("count:" + i + ", " + MemoryUtil.getMemoryUsageLog());
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Oct 24 13:01:38 UTC 2024 - 41.3K bytes - Viewed (0)