- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 97 for Connected (0.18 sec)
-
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
assertEvents( "plan 1 TCP connected", "plan 0 cancel", "plan 1 TLS connecting...", "plan 1 TLS connected", "plan 2 TCP connecting...", ) taskFaker.advanceUntil(270.ms) assertEvents( "plan 0 TCP connect canceled", ) taskFaker.advanceUntil(280.ms) assertEvents( "plan 2 TCP connected", "plan 2 TLS connecting...",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 20.9K bytes - Viewed (0) -
internal/rest/client.go
func (c *Client) Close() { atomic.StoreInt32(&c.connected, closed) } // NewClient - returns new REST client. func NewClient(uu *url.URL, tr http.RoundTripper, newAuthToken func(aud string) string) *Client { connected := int32(online) urlStr := uu.String() u, err := url.Parse(urlStr) if err != nil { // Mark offline, with no reconnection attempts. connected = int32(offline) err = &url.Error{URL: urlStr, Err: err}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
} else -> { events += "plan $id TCP connected" connectState = ConnectState.TCP_CONNECTED ConnectResult(this) } } } override fun connectTlsEtc(): ConnectResult { check(connectState == ConnectState.TCP_CONNECTED) events += "plan $id TLS connecting..." taskFaker.sleep(tlsConnectDelayNanos)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ReusePlan.kt
internal class ReusePlan( val connection: RealConnection, ) : RoutePlanner.Plan { override val isReady = true override fun connectTcp() = error("already connected") override fun connectTlsEtc() = error("already connected") override fun handleSuccess() = connection override fun cancel() = error("unexpected cancel") override fun retry() = error("unexpected retry")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/platform/android/AndroidSocketAdapterTest.kt
val sslSocket = socketFactory.createSocket() as SSLSocket assertTrue(adapter.matchesSocket(sslSocket)) adapter.configureTlsExtensions(sslSocket, null, listOf(HTTP_2, HTTP_1_1)) // not connected assertNull(adapter.getSelectedProtocol(sslSocket)) } @ParameterizedTest @MethodSource("data") fun testMatchesSupportedAndroidSocketFactory(adapter: SocketAdapter) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/RangeTest.java
// TODO(kevinb): convert the rest of this file to Truth someday assertThat(expected).hasMessageThat().contains("connected"); } try { range.intersection(Range.closed(0, 2)); fail(); } catch (IllegalArgumentException expected) { assertThat(expected).hasMessageThat().contains("connected"); } } public void testIntersection_deFactoEmpty() { Range<Integer> range = Range.open(3, 4);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 10:16:44 GMT 2024 - 24.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/RangeTest.java
// TODO(kevinb): convert the rest of this file to Truth someday assertThat(expected).hasMessageThat().contains("connected"); } try { range.intersection(Range.closed(0, 2)); fail(); } catch (IllegalArgumentException expected) { assertThat(expected).hasMessageThat().contains("connected"); } } public void testIntersection_deFactoEmpty() { Range<Integer> range = Range.open(3, 4);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Feb 21 10:16:44 GMT 2024 - 24.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/RangeMap.java
* connect to the given range and value. * * <p>Even if the input range is empty, if it is connected on both sides by ranges mapped to the * same value those two ranges will be coalesced. * * <p><b>Note:</b> coalescing requires calling {@code .equals()} on any connected values, which * may be expensive depending on the value type. Using this method on range maps with large values
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 21:19:52 GMT 2024 - 6.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
private val taskRunner: TaskRunner, ) : ExchangeFinder { private val connectDelayNanos = TimeUnit.MILLISECONDS.toNanos(250L) private var nextTcpConnectAtNanos = Long.MIN_VALUE /** * Plans currently being connected, and that will later be added to [connectResults]. This is * mutated by the call thread only. If is accessed by background connect threads. */ private val tcpConnectsInFlight = CopyOnWriteArrayList<Plan>() /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Range.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 21:19:52 GMT 2024 - 27.8K bytes - Viewed (0)