- Sort Score
- Result 10 results
- Languages All
Results 241 - 250 of 515 for Timers (0.04 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java
import org.codelibs.core.io.CloseableUtil; import org.codelibs.core.io.FileUtil; import org.codelibs.core.io.InputStreamUtil; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.crawler.Constants; import org.codelibs.fess.crawler.builder.RequestDataBuilder; import org.codelibs.fess.crawler.client.AbstractCrawlerClient;
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 08:38:29 UTC 2025 - 23.3K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbTransportImplTest.java
import static org.junit.jupiter.api.Assertions.assertThrows; import static org.junit.jupiter.api.Assertions.assertTrue; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.times; import static org.mockito.Mockito.verify; import static org.mockito.Mockito.when; import java.lang.reflect.Field; import java.net.Socket; import java.util.concurrent.atomic.AtomicLong;
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 17.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/failureurl/EditForm.java
/** * The detailed error log or stack trace for the failure. * This field contains the full error information for debugging purposes. */ public String errorLog; /** * The number of times this URL has failed. * This is a required field that tracks repeated failures for the same URL. */ @Required @ValidateTypeFailure public String errorCount; /**Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 4.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/crawler/interval/FessIntervalController.java
* Fess-specific interval control functionality for web crawling operations. * This controller manages delays and timing for various crawling states * including processing delays, queue waiting times, and new URL discovery. */ public class FessIntervalController extends DefaultIntervalController { private static final Logger logger = LogManager.getLogger(FessIntervalController.class); /**Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Wed Nov 19 07:09:17 UTC 2025 - 5.1K bytes - Viewed (0) -
docs/es/docs/tutorial/dependencies/sub-dependencies.md
query_or_cookie_extractor(["query_or_cookie_extractor"]) read_query["/items/"] query_extractor --> query_or_cookie_extractor --> read_query ``` ## Usando la misma dependencia múltiples veces { #using-the-same-dependency-multiple-times } Si una de tus dependencias se declara varias veces para la misma *path operation*, por ejemplo, múltiples dependencias tienen una sub-dependencia común, **FastAPI** sabrá llamar a esa sub-dependencia solo una vez por request.
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 3.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
import static java.util.concurrent.TimeUnit.NANOSECONDS; import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.times; import static org.mockito.Mockito.verify; import static org.mockito.Mockito.when; import com.google.common.base.Suppliers; import com.google.common.collect.ImmutableList;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Dec 12 00:25:21 UTC 2025 - 26.5K bytes - Viewed (0) -
samples/crawler/src/main/java/okhttp3/sample/Crawler.java
} finally { currentThread.setName(originalName); } } } public void fetch(HttpUrl url) throws IOException { // Skip hosts that we've visited many times. AtomicInteger hostnameCount = new AtomicInteger(); AtomicInteger previous = hostnames.putIfAbsent(url.host(), hostnameCount); if (previous != null) hostnameCount = previous;Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Jul 23 00:58:06 UTC 2025 - 5K bytes - Viewed (0) -
.teamcity/src/main/kotlin/model/FunctionalTestBucketGenerator.kt
// splitIntoBuckets() method expects us to split large element into N elements, // but we want to have a single bucket with N batches. // As a workaround, we repeat the bucket N times, and deduplicate the result at the end val resultIncludingDuplicates = splitIntoBuckets( LinkedList(subProjectTestClassTimes), SubprojectTestClassTime::totalTime,
Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Thu Apr 10 15:09:32 UTC 2025 - 7.3K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb/SmbClient.java
import org.codelibs.core.io.CloseableUtil; import org.codelibs.core.io.FileUtil; import org.codelibs.core.io.InputStreamUtil; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTask; import org.codelibs.fess.crawler.Constants; import org.codelibs.fess.crawler.builder.RequestDataBuilder; import org.codelibs.fess.crawler.client.AbstractCrawlerClient;
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 08:38:29 UTC 2025 - 23.4K bytes - Viewed (3) -
cmd/dynamic-timeouts.go
if timeout < dt.minimum { timeout = dt.minimum } atomic.StoreInt64(&dt.timeout, timeout) } else if failPct < dynamicTimeoutDecreaseThresholdPct { // We are hitting the timeout relatively few times, // so decrease the timeout towards 25 % of maximum time spent. maxDur = maxDur * 125 / 100 timeout := atomic.LoadInt64(&dt.timeout) if maxDur < time.Duration(timeout) { // Move 50% toward the max.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 4.5K bytes - Viewed (0)