Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 44 for ConnectionPool (0.11 sec)

  1. samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt

            Thread.sleep(1000)
            sendTestRequest(twitterRequest)
            Thread.sleep(1000)
            sendTestRequest(googleRequest)
            Thread.sleep(2000)
          }
        } finally {
          client.connectionPool.evictAll()
          client.dispatcher.executorService.shutdownNow()
    
          if (launch == CommandLine) {
            process?.destroyForcibly()
          }
        }
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/Connection.kt

     *
     * Typically instances of this class are created, connected and exercised automatically by the HTTP
     * client. Applications may use this class to monitor HTTP connections as members of a
     * [connection pool][ConnectionPool].
     *
     * Do not confuse this class with the misnamed `HttpURLConnection`, which isn't so much a connection
     * as a single request/response exchange.
     *
     * ## Modern TLS
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  3. okcurl/src/main/kotlin/okhttp3/curl/Main.kt

          builder.eventListenerFactory(LoggingEventListener.Factory(logger))
        }
        return builder.build()
      }
    
      fun close() {
        val okHttpClient = client as OkHttpClient
        okHttpClient.connectionPool.evictAll() // Close any persistent connections.
        okHttpClient.dispatcher.executorService.shutdownNow()
      }
    
      companion object {
        internal const val NAME = "okcurl"
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  4. okhttp/api/okhttp.api

    	public final fun connectionCount ()I
    	public final fun evictAll ()V
    	public final fun idleConnectionCount ()I
    	public final fun setPolicy (Lokhttp3/Address;Lokhttp3/ConnectionPool$AddressPolicy;)V
    }
    
    public final class okhttp3/ConnectionPool$AddressPolicy {
    	public final field backoffDelayMillis J
    	public final field backoffJitterMillis I
    	public final field minimumConcurrentCalls I
    	public fun <init> ()V
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:41:01 UTC 2024
    - 70.2K bytes
    - Viewed (0)
  5. docs/features/connections.md

    TCP socket connection. Sharing a connection has substantial performance benefits: lower latency, higher throughput (due to [TCP slow start](https://www.igvita.com/2011/10/20/faster-web-vs-tcp-slow-start/)) and conserved battery. OkHttp uses a [ConnectionPool](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-connection-pool/) that automatically reuses HTTP/1.x connections and multiplexes HTTP/2 connections.
    
    In OkHttp some fields of the address come from the URL (scheme, hostname, port)...
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Feb 21 03:33:59 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

        val hostnameVerifier = RecordingHostnameVerifier()
        val cookieJar: CookieJar = JavaNetCookieJar(CookieManager())
        val connectionPool = ConnectionPool()
        client =
          OkHttpClient.Builder()
            .cache(cache)
            .connectionPool(connectionPool)
            .cookieJar(cookieJar)
            .sslSocketFactory(clientSocketFactory, handshakeCertificates.trustManager)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 131.7K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

            writer.windowUpdate(0, (windowSize - DEFAULT_INITIAL_WINDOW_SIZE).toLong())
          }
        }
        // Thread doesn't use client Dispatcher, since it is scoped potentially across clients via
        // ConnectionPool.
        taskRunner.newQueue().execute(name = connectionName, block = readerRunnable)
      }
    
      /** Merges [settings] into this peer's settings and sends them to the remote peer. */
      @Throws(IOException::class)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/tls/CertificatePinnerChainValidationTest.kt

          )
        val response1 = call1.execute()
        assertThat(response1.body.string()).isEqualTo("abc")
        response1.close()
    
        // Force a fresh connection for the next request.
        client.connectionPool.evictAll()
    
        // Confirm that a second request also succeeds. This should detect caching problems.
        server.enqueue(
          MockResponse.Builder()
            .body("def")
            .socketPolicy(DisconnectAtEnd)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 23.8K bytes
    - Viewed (0)
  9. CHANGELOG.md

     *  New: `HttpLoggingInterceptor.redactQueryParams()` configures the query parameters to redact
        in logs. For best security, don't put sensitive information in query parameters.
    
     *  New: `ConnectionPool.setPolicy()` configures a minimum connection pool size for a target
        address. Use this to proactively open HTTP connections.
    
        Connections opened to fulfill this policy are subject to the connection pool's
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 18 01:31:39 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

        val call1 = client.newCall(Request(server.url("/")))
        val response = call1.execute()
        call1.cancel()
    
        // That connection is pooled, and it works.
        assertThat(client.connectionPool.connectionCount()).isEqualTo(1)
        val call2 = client.newCall(Request(server.url("/")))
        val response2 = call2.execute()
        assertThat(response2.body.string()).isEqualTo("def")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
Back to top