Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 757 for contention (0.06 sec)

  1. okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt

          object : EventListener() {
            var socket: SSLSocket? = null
            var closed = false
    
            override fun connectionAcquired(
              call: Call,
              connection: Connection,
            ) {
              socket = connection.socket() as SSLSocket
            }
    
            override fun requestHeadersStart(call: Call) {
              if (closed) {
                throw IOException("fake socket failure")
              }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/ReusePlan.kt

     */
    package okhttp3.internal.connection
    
    /** Reuse a connection from the pool. */
    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
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1K bytes
    - Viewed (0)
  3. compat/maven-model-builder/src/test/resources/poms/inheritance/no-append-urls2-expected.xml

      <version>11-SNAPSHOT</version>
      <name>Model urls inheritance test child</name>
    
      <scm child.scm.connection.inherit.append.path="false"
           child.scm.developerConnection.inherit.append.path="false"
           child.scm.url.inherit.append.path="false">
        <connection>scm:my-scm:http://domain.org/base</connection>
        <developerConnection>scm:my-scm:https://domain.org/base/</developerConnection>
        <url>https://domain.org/override</url>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  4. compat/maven-model-builder/src/test/resources/poms/inheritance/no-append-urls3-parent.xml

      <scm child.scm.connection.inherit.append.path="false"
           child.scm.developerConnection.inherit.append.path="false"
           child.scm.url.inherit.append.path="false">
        <connection>scm:my-scm:http://domain.org/base</connection>
        <developerConnection>scm:my-scm:https://domain.org/base/</developerConnection>
        <url>https://domain.org/base</url>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt

      override fun connectionConnectEnd(
        connection: Connection,
        route: Route,
      ) {
        poolConnectionListener.connectEnd(connection, route, call)
      }
    
      override fun connectionAcquired(connection: Connection) {
        eventListener.connectionAcquired(call, connection)
      }
    
      override fun acquireConnectionNoEvents(connection: RealConnection) {
        call.acquireConnectionNoEvents(connection)
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Mar 06 17:33:38 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  6. docs/changelogs/changelog_3x.md

    stuck on the old version.
    
     *  **There is no longer a global singleton connection pool.** In OkHttp 2.x,
        all `OkHttpClient` instances shared a common connection pool by default.
        In OkHttp 3.x, each new `OkHttpClient` gets its own private connection pool.
        Applications should avoid creating many connection pools as doing so
        prevents connection reuse. Each connection pool holds its own set of
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  7. docs/features/interceptors.md

    Content-Type: text/html
    Content-Length: 193
    Connection: keep-alive
    Location: https://publicobject.com/helloworld.txt
    
    INFO: Sending request https://publicobject.com/helloworld.txt on Connection{publicobject.com:443, proxy=DIRECT hostAddress=54.187.32.157 cipherSuite=TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA protocol=http/1.1}
    User-Agent: OkHttp Example
    Host: publicobject.com
    Connection: Keep-Alive
    Accept-Encoding: gzip
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 8.1K bytes
    - Viewed (0)
  8. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

                clientTestRule.wrap(
                  object : EventListener() {
                    override fun connectionAcquired(
                      call: Call,
                      connection: Connection,
                    ) {
                      socketClass = connection.socket().javaClass.name
                    }
                  },
                ),
              )
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 27K bytes
    - Viewed (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

      )
    
      override fun connectEnd(
        connection: Connection,
        route: Route,
        call: Call,
      ) {
        logEvent(ConnectionEvent.ConnectEnd(System.nanoTime(), connection, route, call))
      }
    
      override fun connectionClosed(connection: Connection) = logEvent(ConnectionEvent.ConnectionClosed(System.nanoTime(), connection))
    
      override fun connectionAcquired(
        connection: Connection,
        call: Call,
      ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  10. internal/grid/benchmark_test.go

    						if src == dst {
    							dst = (dst + 1) % len(managers)
    						}
    						local := managers[src]
    						conn := local.Connection(hosts[dst])
    						if conn == nil {
    							b.Fatal("No connection")
    						}
    						// Send the payload.
    						t := time.Now()
    						resp, err := conn.Request(ctx, handlerTest, payload)
    						latency += time.Since(t).Nanoseconds()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
Back to top