Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for ConnectionAcquired (0.12 sec)

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

    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue May 14 17:48:07 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

            }
            addAll(listOf("ConnectionAcquired", "ConnectionReleased", "CallEnd"))
          }
    
        assertThat(events2).isEqualTo(expectedEvents2)
      }
    
      private fun isConnectionEvent(it: CallEvent?) =
        it is CallStart ||
          it is CallEnd ||
          it is ConnectStart ||
          it is ConnectEnd ||
          it is ConnectionAcquired ||
          it is ConnectionReleased ||
          it is Canceled ||
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/EventListener.kt

       * to the [Call.request] is a redirect to a different address.
       */
      open fun connectionAcquired(
        call: Call,
        connection: Connection,
      ) {
      }
    
      /**
       * Invoked after a connection has been released for the `call`.
       *
       * This method is always invoked after [connectionAcquired].
       *
       * This can be invoked more than 1 time for a single [Call]. For example, if the response to the
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  4. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

          client =
            OkHttpClient.Builder()
              .eventListenerFactory(
                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)
  5. okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt

          .assertLogMatch(Regex("""connectStart: ${url.host}/.+ DIRECT"""))
          .assertLogMatch(Regex("""connectEnd: http/1.1"""))
          .assertLogMatch(
            Regex(
              """connectionAcquired: Connection\{${url.host}:\d+, proxy=DIRECT hostAddress=${url.host}/.+ cipherSuite=none protocol=http/1\.1\}""",
            ),
          )
          .assertLogMatch(Regex("""requestHeadersStart"""))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/DuplexTest.kt

    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

                connectionUser.releaseConnectionNoEvents()
              }
              else -> null
            }
          }
    
        // If the call's connection wasn't released, reuse it. We don't call connectionAcquired() here
        // because we already acquired it.
        if (connectionUser.candidateConnection() != null) {
          check(toClose == null)
          return ReusePlan(candidate)
        }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 12K bytes
    - Viewed (0)
  8. samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt

          logger.removeHandler(loggerHandler)
        }
    
        override fun callEnd(call: Call) {
          // Cleanup log handler if failed.
          logger.removeHandler(loggerHandler)
        }
    
        override fun connectionAcquired(
          call: Call,
          connection: Connection,
        ) {
          if (random != null) {
            val sslSocket = connection.socket() as SSLSocket
            val session = sslSocket.session
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt

                latch1.await()
              } catch (e: InterruptedException) {
                throw AssertionError(e)
              }
            }
    
            override fun connectionAcquired(
              call: Call,
              connection: Connection,
            ) {
              // We have the connection and it's in the pool. Let request2 proceed to make a connection.
              latch2.countDown()
            }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/tls/ClientAuthTest.kt

        }
    
        // Observed Events are variable
        // JDK 14
        // CallStart, ProxySelectStart, ProxySelectEnd, DnsStart, DnsEnd, ConnectStart, SecureConnectStart,
        // SecureConnectEnd, ConnectEnd, ConnectionAcquired, RequestHeadersStart, RequestHeadersEnd,
        // ResponseFailed, ConnectionReleased, CallFailed
        // JDK 8
        // CallStart, ProxySelectStart, ProxySelectEnd, DnsStart, DnsEnd, ConnectStart, SecureConnectStart,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 12.5K bytes
    - Viewed (0)
Back to top