Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Hoon (0.21 sec)

  1. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

        outFrames.add(OutFrame(frameCount++, bytesOut.size, false))
        return writer
      }
    
      /**
       * Shortens the last frame from its original length to `length`. This will cause the peer to
       * close the socket as soon as this frame has been written; otherwise the peer stays open until
       * explicitly closed.
       */
      fun truncateLastFrame(length: Int): Http2Writer {
        val lastFrame = outFrames.removeAt(outFrames.size - 1)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 8.7K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

                startAnotherThread()
              }
    
              return readyTask
            }
    
            // Notify the coordinator of a task that's coming up soon.
            coordinatorWaiting -> {
              if (minDelayNanos < coordinatorWakeUpAt - now) {
                backend.coordinatorNotify(this@TaskRunner)
              }
              return null
            }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

        if (strategy == ResumePriority.AfterOtherTasks && otherTasksStarted) {
          return yieldUntil(strategy, condition)
        }
      }
    
      private enum class ResumePriority {
        /** Resumes as soon as the condition is satisfied. */
        BeforeOtherTasks,
    
        /** Resumes after the already-enqueued tasks. */
        AfterEnqueuedTasks,
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 12.6K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

        routePlanner.autoGeneratePlans = true
        routePlanner.defaultConnectionIdleAtNanos = expireTime
        val address = routePlanner.address
        val pool = routePlanner.pool
    
        // Connections are created as soon as a policy is set
        setPolicy(pool, address, ConnectionPool.AddressPolicy(2))
        assertThat(pool.connectionCount()).isEqualTo(2)
    
        // Connections are replaced if they idle out or are evicted from the pool
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

          responseDequeuedLatches[responseIndex].countDown()
          requestCanceledLatches[responseIndex].await()
          responseIndex++
          return response
        }
      }
    
      /** Make a call and canceling it as soon as it's accepted by the server.  */
      private fun callAndCancel(
        expectedSequenceNumber: Int,
        responseDequeuedLatch: CountDownLatch?,
        requestCanceledLatch: CountDownLatch?,
      ) {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

            // Clean up again immediately.
            return 0L
          }
    
          earliestEvictableConnection != null -> {
            // A connection will be ready to evict soon.
            return earliestEvictableIdleAtNs + keepAliveDurationNs - now
          }
    
          inUseConnectionCount > 0 -> {
            // All connections are in use. It'll be at least the keep alive duration 'til we run again.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 16.2K bytes
    - Viewed (0)
Back to top