- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 512 for Connection (0.18 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
* automatically send ping frames until either the connection fails or it is closed. This keeps * the connection alive and may detect connectivity failures. * * If the server does not respond to each ping with a pong within `interval`, this client will * assume that connectivity has been lost. When this happens on a web socket the connection isRegistered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 51.7K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
_2016-01-01_ * Fix: Don't do a health check on newly-created connections. This is unnecessary work that could put the client in an inconsistent state if the health check fails. ## Version 2.7.0 _2015-12-13_ * **Rewritten connection management.** Previously OkHttp's connection pool managed both idle and active connections for HTTP/2, but only idle connections for HTTP/1.x. With this update the connection pool manages both
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 26.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallKotlinTest.kt
} @Test fun staleConnectionNotReusedForNonIdempotentRequest() { // Capture the connection so that we can later make it stale. var connection: RealConnection? = null client = client .newBuilder() .addNetworkInterceptor( Interceptor { chain -> connection = chain.connection() as RealConnection chain.proceed(chain.request()) }, ).build()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 8.4K bytes - Viewed (0) -
android-test/src/androidTest/java/okhttp/android/test/alpn/AlpnOverrideTest.kt
), ).eventListener( object : EventListener() { override fun connectionAcquired( call: Call, connection: Connection, ) { val sslSocket = connection.socket() as SSLSocket println("Requested " + sslSocket.sslParameters.applicationProtocols.joinToString()) println("Negotiated " + sslSocket.applicationProtocol)Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 2.8K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaTransport.java
log.info("RDMA connection established to {}", delegate.getRemoteAddress()); } catch (IOException e) { log.warn("Failed to establish RDMA connection: {}", e.getMessage()); throw e; } } } /** * Checks if RDMA connection is available. * * @return true if RDMA connection is active */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 8.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaConnection.java
socket.setKeepAlive(true); state = RdmaConnectionState.CONNECTED; log.debug("TCP RDMA connection established to {}", remoteAddress); } catch (IOException e) { state = RdmaConnectionState.ERROR; throw new IOException("TCP RDMA connection failed", e); } } @Override public void send(ByteBuffer data, RdmaMemoryRegion region) throws IOException {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 8.8K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelFailoverTest.java
when(mockChannelManager.getLoadBalancer()).thenReturn(mockLoadBalancer); } @Test void testHandleFailure() { IOException error = new IOException("Connection failed"); failover.handleFailure(failedChannel, error); assertEquals(ChannelState.FAILED, failedChannel.getState()); verify(mockChannelManager).removeChannel(failedChannel); }Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 7.7K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaProviderTest.java
InetSocketAddress remote = new InetSocketAddress("localhost", 445); InetSocketAddress local = null; RdmaConnection connection = provider.createConnection(remote, local); assertNotNull(connection, "Connection should not be null"); assertEquals(remote, connection.getRemoteAddress(), "Remote address should match"); } @Test public void testRegisterMemory() throws Exception {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 4.2K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionReuseTest.kt
.Builder() .url(server.url("/")) .header("Connection", "close") .build() val requestB = Request(server.url("/")) assertConnectionNotReused(requestA, requestB) } @Test fun connectionsAreNotReusedWithResponseConnectionClose() { server.enqueue( MockResponse( headers = headersOf("Connection", "close"), body = "a", ), )
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 12.2K bytes - Viewed (1) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/ConnectionSpec.kt
import okhttp3.internal.indexOf import okhttp3.internal.intersect /** * Specifies configuration for the socket connection that HTTP traffic travels through. For `https:` * URLs, this includes the TLS version and cipher suites to use when negotiating a secure * connection. * * The TLS versions configured in a connection spec are only be used if they are also enabled in the
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 13.4K bytes - Viewed (0)