Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 35 of 35 for TaskRunner (0.04 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskLogger.kt

      val loggingEnabled = isLoggable(Level.FINE)
      if (loggingEnabled) {
        startNs = queue.taskRunner.backend.nanoTime()
        log(task, queue, "starting")
      }
    
      var completedNormally = false
      try {
        val result = block()
        completedNormally = true
        return result
      } finally {
        if (loggingEnabled) {
          val elapsedNs = queue.taskRunner.backend.nanoTime() - startNs
          if (completedNormally) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        peer.acceptFrame() // SYN_STREAM.
        peer.play()
        val taskRunner = taskFaker.taskRunner
        val connection =
          Http2Connection
            .Builder(true, taskRunner)
            .socket(peer.openSocket().asBufferedSocket(), "peer")
            .pushObserver(IGNORE)
            .build()
        connection.start(sendConnectionPreface = false)
        val queues = taskRunner.activeQueues()
        assertThat(queues).hasSize(1)
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  3. okhttp/src/androidMain/baseline-prof.txt

    HSPLokhttp3/internal/concurrent/TaskRunner$RealBackend;->nanoTime()J
    HSPLokhttp3/internal/concurrent/TaskRunner$runnable$1;-><init>(Lokhttp3/internal/concurrent/TaskRunner;)V
    HSPLokhttp3/internal/concurrent/TaskRunner$runnable$1;->run()V
    HSPLokhttp3/internal/concurrent/TaskRunner;-><clinit>()V
    HSPLokhttp3/internal/concurrent/TaskRunner;-><init>(Lokhttp3/internal/concurrent/TaskRunner$Backend;Ljava/util/logging/Logger;I)V
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Dec 30 23:28:56 UTC 2024
    - 127.9K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

    import okhttp3.TestUtil.assumeNotWindows
    import okhttp3.TestUtil.repeat
    import okhttp3.WebSocket
    import okhttp3.WebSocketListener
    import okhttp3.internal.UnreadableResponseBody
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.ws.WebSocketProtocol.acceptHeader
    import okhttp3.testing.Flaky
    import okhttp3.testing.PlatformRule
    import okio.Buffer
    import okio.ByteString
    import okio.ByteString.Companion.decodeHex
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 35.5K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt

              .request(Request.Builder().url(url).build())
              .headers(responseHeaders!!)
              .protocol(Protocol.HTTP_1_1)
              .build()
          webSocket =
            RealWebSocket(
              taskFaker.taskRunner,
              response.request,
              listener,
              random!!,
              pingIntervalMillis.toLong(),
              parse(
                responseHeaders,
              ),
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.7K bytes
    - Viewed (0)
Back to top