Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for callStart (0.12 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

        timeout.enter()
        callStart()
        try {
          client.dispatcher.executed(this)
          return getResponseWithInterceptorChain()
        } finally {
          client.dispatcher.finished(this)
        }
      }
    
      override fun enqueue(responseCallback: Callback) {
        check(executed.compareAndSet(false, true)) { "Already Executed" }
    
        callStart()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/EventListenerTest.kt

    import mockwebserver3.SocketPolicy.DisconnectDuringResponseBody
    import mockwebserver3.SocketPolicy.FailHandshake
    import okhttp3.CallEvent.CallEnd
    import okhttp3.CallEvent.CallFailed
    import okhttp3.CallEvent.CallStart
    import okhttp3.CallEvent.ConnectStart
    import okhttp3.CallEvent.ConnectionAcquired
    import okhttp3.CallEvent.DnsEnd
    import okhttp3.CallEvent.DnsStart
    import okhttp3.CallEvent.RequestBodyEnd
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (2)
  3. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/LoggingEventListener.kt

     */
    class LoggingEventListener private constructor(
      private val logger: HttpLoggingInterceptor.Logger,
    ) : EventListener() {
      private var startNs: Long = 0
    
      override fun callStart(call: Call) {
        startNs = System.nanoTime()
    
        logWithTime("callStart: ${call.request()}")
      }
    
      override fun proxySelectStart(
        call: Call,
        url: HttpUrl,
      ) {
        logWithTime("proxySelectStart: $url")
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 11:07:32 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  4. docs/features/events.md

        long nowNanos = System.nanoTime();
        if (name.equals("callStart")) {
          callStartNanos = nowNanos;
        }
        long elapsedNanos = nowNanos - callStartNanos;
        System.out.printf("%.3f %s%n", elapsedNanos / 1000000000d, name);
      }
    
      @Override public void callStart(Call call) {
        printEvent("callStart");
      }
    
      @Override public void callEnd(Call call) {
        printEvent("callEnd");
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 7.7K bytes
    - Viewed (0)
  5. docs/features/caching.md

    containing a query.
    
     - CallStart
     - **CacheHit**
     - CallEnd
     
    ### Cache Miss
    
    Under a cache miss the normal request events are seen but an additional event shows the presence of the cache.
    Cache Miss will be typical if the item has not been read from the network, is uncacheable, or is past it's 
    lifetime based on Response cache headers.
    
     - CallStart 
     - **CacheMiss**
     - ProxySelectStart
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 3.1K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/DispatcherTest.kt

        dispatcher.maxRequests = 2 // Trigger promotion.
        callback.await(request2.url).assertFailure(InterruptedIOException::class.java)
        assertThat(listener.recordedEventTypes())
          .containsExactly("CallStart", "CallStart", "CallFailed")
      }
    
      @Test
      fun executionRejectedAfterMaxRequestsPerHostChange() {
        val request1 = newRequest("http://a/1")
        val request2 = newRequest("http://a/2")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Apr 05 03:30:42 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  7. okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt

            .build(),
        )
        val response = client.newCall(request().build()).execute()
        assertThat(response.body).isNotNull()
        response.body.bytes()
        logRecorder
          .assertLogMatch(Regex("""callStart: Request\{method=GET, url=$url\}"""))
          .assertLogMatch(Regex("""proxySelectStart: $url"""))
          .assertLogMatch(Regex("""proxySelectEnd: \[DIRECT]"""))
          .assertLogMatch(Regex("""dnsStart: ${url.host}"""))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  8. samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java

          long nowNanos = System.nanoTime();
          if (name.equals("callStart")) {
            callStartNanos = nowNanos;
          }
          long elapsedNanos = nowNanos - callStartNanos;
          System.out.printf("%.3f %s%n", elapsedNanos / 1000000000d, name);
        }
    
        @Override public void callStart(Call call) {
          printEvent("callStart");
        }
    
        @Override public void proxySelectStart(Call call, HttpUrl url) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 16 23:20:49 UTC 2020
    - 5.3K bytes
    - Viewed (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/ClientRuleEventListener.kt

      EventListener.Factory {
      private var startNs: Long? = null
    
      override fun create(call: Call): EventListener = this
    
      override fun callStart(call: Call) {
        startNs = System.nanoTime()
    
        logWithTime("callStart: ${call.request()}")
    
        delegate.callStart(call)
      }
    
      override fun proxySelectStart(
        call: Call,
        url: HttpUrl,
      ) {
        logWithTime("proxySelectStart: $url")
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

          mutableListOf<String>().apply {
            add("CallStart")
            if (connectionType != H2) {
              addAll(listOf("ConnectStart", "ConnectEnd"))
            }
            addAll(listOf("ConnectionAcquired", "ConnectionReleased", "CallEnd"))
          }
    
        assertThat(events2).isEqualTo(expectedEvents2)
      }
    
      private fun isConnectionEvent(it: CallEvent?) =
        it is CallStart ||
          it is CallEnd ||
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
Back to top