Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ConnectionPool (0.08 sec)

  1. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

      internal val taskRunner: TaskRunner = builder.taskRunner ?: TaskRunner.INSTANCE
    
      @get:JvmName("connectionPool")
      val connectionPool: ConnectionPool =
        builder.connectionPool ?: ConnectionPool(
          readTimeoutMillis = readTimeoutMillis,
          writeTimeoutMillis = writeTimeoutMillis,
          socketConnectTimeoutMillis = connectTimeoutMillis,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:21:33 UTC 2024
    - 52K bytes
    - Viewed (0)
  2. istioctl/pkg/describe/describe.go

    				}
    				if sp := recordShortPolicies(
    					ps.LoadBalancer,
    					ps.ConnectionPool,
    					ps.OutlierDetection); sp != "" {
    					fmt.Fprintf(writer, "%s%s", printSpaces(initPrintNum+printLevel2), sp)
    				}
    			}
    		}
    	}
    }
    
    func recordShortPolicies(lb *v1alpha3.LoadBalancerSettings,
    	connectionPool *v1alpha3.ConnectionPoolSettings,
    	outlierDetection *v1alpha3.OutlierDetection,
    ) string {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. okhttp/src/test/java/okhttp3/EventListenerTest.kt

      private var cache: Cache? = null
    
      @BeforeEach
      fun setUp(server: MockWebServer) {
        this.server = server
        platform.assumeNotOpenJSSE()
        listener.forbidLock(get(client.connectionPool))
        listener.forbidLock(client.dispatcher)
      }
    
      @AfterEach
      fun tearDown() {
        if (socksProxy != null) {
          socksProxy!!.shutdown()
        }
        if (cache != null) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (2)
Back to top