- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 250 for blocking (0.1 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
val pooled1 = planReusePooledConnection() if (pooled1 != null) return pooled1 // Attempt a deferred plan before new routes. if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst() // Do blocking calls to plan a route for a new connection. val connect = planConnect() // Now that we have a set of IP addresses, make another attempt at getting a connection from
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Oct 08 03:50:05 UTC 2025 - 12K bytes - Viewed (0) -
README.md
configured to fall back for broad connectivity. Using OkHttp is easy. Its request/response API is designed with fluent builders and immutability. It supports both synchronous blocking calls and async calls with callbacks. A well behaved user agent ------------------------- OkHttp follows modern HTTP specifications such as
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Oct 30 21:39:59 UTC 2025 - 9.5K bytes - Viewed (0) -
guava/src/com/google/common/cache/AbstractCache.java
/** * Records cache misses. This should be called when a cache request returns a value that was not * found in the cache. This method should be called by the loading thread, as well as by threads * blocking on the load. Multiple concurrent calls to {@link Cache} lookup methods with the same * key on an absent value should result in a single call to either {@code recordLoadSuccess} orRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 9.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt
* call this without consuming the complete response body, any remaining bytes in the response * body will be discarded before trailers are returned. * * If [Call.cancel] is called while this is blocking, this call will immediately throw. * * @throws IllegalStateException if the response is closed. * @throws IOException if the trailers cannot be loaded, such as if the network connection is * dropped.
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Jul 28 14:39:28 UTC 2025 - 18.1K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Ascii.java
*/ public static final byte SYN = 22; /** * End of Transmission Block: A communication control character used to indicate the end of a * block of data for communication purposes. ETB is used for blocking data where the block * structure is not necessarily related to the processing format. * * @since 8.0 */ public static final byte ETB = 23; /**
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 21.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
* * @author Anthony Zana * @since 10.0 */ @GwtCompatible public final class Uninterruptibles { // Implementation Note: As of 3-7-11, the logic for each blocking/timeout // methods is identical, save for method being invoked. /** Invokes {@code latch.}{@link CountDownLatch#await() await()} uninterruptibly. */ @J2ktIncompatible @GwtIncompatible // concurrencyRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java
} curr = succ; } break; } } // A heuristic for timed gets. If the remaining timeout is less than this, spin instead of // blocking. This value is what AbstractQueuedSynchronizer uses. private static final long SPIN_THRESHOLD_NANOS = 1000L; @VisibleForTesting static String atomicHelperTypeForTest() {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 33.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractFutureState.java
} curr = succ; } break; } } // A heuristic for timed gets. If the remaining timeout is less than this, spin instead of // blocking. This value is what AbstractQueuedSynchronizer uses. private static final long SPIN_THRESHOLD_NANOS = 1000L; @VisibleForTesting static String atomicHelperTypeForTest() {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 34.8K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
requests, responses, headers, and calls. It uses modern Java patterns like immutability and chained builders. The API now offers asynchronous callbacks in addition to synchronous blocking calls. #### API Changes * **New Request and Response types,** each with their own builder. There's also a `RequestBody` class to write the request body to the network and a
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 26.6K bytes - Viewed (0) -
src/main/java/jcifs/util/SmbCircuitBreaker.java
import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.CIFSException; /** * Circuit breaker pattern implementation for SMB operations. * Prevents cascading failures by temporarily blocking requests to a failing service. * * The circuit breaker has three states: * - CLOSED: Normal operation, requests pass through * - OPEN: Service is failing, requests are blocked
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 33.4K bytes - Viewed (0)