- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 55 for Carrier (0.07 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
*/ class Http1ExchangeCodec( /** The client that configures this stream. May be null for HTTPS proxy tunnels. */ private val client: OkHttpClient?, override val carrier: ExchangeCodec.Carrier, override val socket: BufferedSocket, ) : ExchangeCodec { private var state = STATE_IDLE private val headersReader = HeadersReader(socket.source) private val Response.isChunked: Boolean
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 17.6K bytes - Click Count (7) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
private val attempt: Int, private val tunnelRequest: Request?, internal val connectionSpecIndex: Int, internal val isTlsFallback: Boolean, ) : RoutePlanner.Plan, ExchangeCodec.Carrier { /** True if this connect was canceled; typically because it lost a race. */ @Volatile private var canceled = false // These properties are initialized by connect() and never reassigned.Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 19.3K bytes - Click Count (2) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/Exchange.kt
internal var hasFailure: Boolean = false private set internal val connection: RealConnection get() = codec.carrier as? RealConnection ?: error("no connection for CONNECT tunnels") internal val isCoalescedConnection: Boolean get() = finder.routePlanner.address.url.host != codec.carrier.route.address.url.host @Throws(IOException::class) fun writeRequestHeaders(request: Request) { try {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 10.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
private var refusedStreamCount = 0 /** * The maximum number of concurrent streams that can be carried by this connection. If * `allocations.size() < allocationLimit` then new streams can be created on this connection. */ internal var allocationLimit = 1 private set /** Current calls carried by this connection. */ val calls = mutableListOf<Reference<RealCall>>()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 14.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
} CyclicBarrier barrier = new CyclicBarrier( 6 // for the setter threads + 50 // for the listeners + 50 // for the blocking get threads, + 1); // for the main thread ExecutorService executor = newFixedThreadPool(barrier.getParties());Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 45.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
barrier.await(1, SECONDS); executor.execute(barrierTask); // timeout means the second task wasn't even tried barrier.await(1, SECONDS); } finally { service.shutdown(); } } public void testRejectedExecutionThrownWithMultipleCalls() throws Exception { CountDownLatch latch = new CountDownLatch(1); SettableFuture<?> future = SettableFuture.create();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 10.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
barrier.await(1, SECONDS); executor.execute(barrierTask); // timeout means the second task wasn't even tried barrier.await(1, SECONDS); } finally { service.shutdown(); } } public void testRejectedExecutionThrownWithMultipleCalls() throws Exception { CountDownLatch latch = new CountDownLatch(1); SettableFuture<?> future = SettableFuture.create();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 10.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
ExecutorService executor = newDirectExecutorService(); CyclicBarrier barrier = new CyclicBarrier(2); FutureTask<@Nullable Void> otherTask = new FutureTask<>( () -> { Future<?> future = executor.submit( () -> { // WAIT #1 barrier.await(1, SECONDS); // WAIT #2
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
ExecutorService executor = newDirectExecutorService(); CyclicBarrier barrier = new CyclicBarrier(2); FutureTask<@Nullable Void> otherTask = new FutureTask<>( () -> { Future<?> future = executor.submit( () -> { // WAIT #1 barrier.await(1, SECONDS); // WAIT #2
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.1K bytes - Click Count (0) -
cmd/storage-datatypes.go
FSType string RootDisk bool Healing bool Scanning bool Endpoint string MountPath string ID string Rotational bool Metrics DiskMetrics Error string // carries the error over the network } // DiskMetrics has the information about XL Storage APIs // the number of calls of each API and the moving average of // the duration of each API. type DiskMetrics struct {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 17.4K bytes - Click Count (0)