- Sort Score
- Num 10 results
- Language All
Results 231 - 240 of 398 for timedOut (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/admin-heal-ops.go
) const ( // a heal sequence with this many un-consumed heal result // items blocks until heal-status consumption resumes or is // aborted due to timeout. maxUnconsumedHealResultItems = 1000 // if no heal-results are consumed (via the heal-status API) // for this timeout duration, the heal sequence is aborted. healUnconsumedTimeout = 24 * time.Hour // time-duration to keep heal sequence state after it // completes.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 25.4K bytes - Click Count (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/ftp/FtpClientTest.java
// Simulate quick completion before timeout ResponseData responseData = new ResponseData(); responseData.setHttpStatusCode(200); return responseData; } }; // Test with timeout set client.setAccessTimeout(10); try {Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 21.5K bytes - Click Count (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
this.index = index; } /** * Gets the scroll timeout in milliseconds. * * @return The scroll timeout. */ public int getScrollTimeout() { return scrollTimeout; } /** * Sets the scroll timeout. * @param scrollTimeout The scroll timeout. */ public void setScrollTimeout(final int scrollTimeout) {Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Nov 20 08:40:57 GMT 2025 - 34.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
assertTrue(thread.isAlive()); } } /** Checks that future.get times out, with the default timeout of {@code timeoutMillis()}. */ void assertFutureTimesOut(Future<?> future) { assertFutureTimesOut(future, timeoutMillis()); } /** Checks that future.get times out, with the given millisecond timeout. */ void assertFutureTimesOut(Future<?> future, long timeoutMillis) { long startTime = System.nanoTime();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:07:52 GMT 2025 - 37.8K bytes - Click Count (0) -
src/main/java/jcifs/internal/witness/WitnessClient.java
* Checks for expired registrations based on heartbeat timeouts. */ private void checkHeartbeats() { long timeout = context.getConfig().getWitnessHeartbeatTimeout(); for (WitnessRegistration registration : registrations.values()) { if (registration.isExpired(timeout)) { log.warn("Witness registration expired: {}", registration.getRegistrationId());Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 20.8K bytes - Click Count (0) -
guava-tests/test/com/google/common/base/SuppliersTest.java
AtomicInteger count = new AtomicInteger(0); AtomicReference<Throwable> thrown = new AtomicReference<>(null); int numThreads = 3; Thread[] threads = new Thread[numThreads]; long timeout = SECONDS.toNanos(60); Supplier<Boolean> supplier = new Supplier<Boolean>() { boolean isWaiting(Thread thread) { switch (thread.getState()) { case BLOCKED:
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 16:03:47 GMT 2025 - 17.9K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/base/SuppliersTest.java
AtomicInteger count = new AtomicInteger(0); AtomicReference<Throwable> thrown = new AtomicReference<>(null); int numThreads = 3; Thread[] threads = new Thread[numThreads]; long timeout = SECONDS.toNanos(60); Supplier<Boolean> supplier = new Supplier<Boolean>() { boolean isWaiting(Thread thread) { switch (thread.getState()) { case BLOCKED:
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 16:03:47 GMT 2025 - 17.9K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
private final AbstractFuture<?> future; private final long timeout; private final TimeUnit unit; private Exception exception; private volatile long startTime; private long timeSpentBlocked; TimedWaiterThread(AbstractFuture<?> future, long timeout, TimeUnit unit) { this.future = future; this.timeout = timeout; this.unit = unit; } @Override
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:45:32 GMT 2025 - 46.8K bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/NetServerEnum2.java
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 07:14:38 GMT 2025 - 3.6K bytes - Click Count (0) -
internal/http/dial_dnscache.go
if lookupHost == nil { lookupHost = net.DefaultResolver.LookupHost } if baseDialCtx == nil { // This is same as which `http.DefaultTransport` uses. baseDialCtx = (&net.Dialer{ Timeout: 30 * time.Second, KeepAlive: 30 * time.Second, }).DialContext } return func(ctx context.Context, network, addr string) (conn net.Conn, err error) { host, port, err := net.SplitHostPort(addr)Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 2.6K bytes - Click Count (0)