Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 512 for Connection (0.18 sec)

  1. 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 is
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top