Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for LOOP (0.17 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/-CacheControlCommon.kt

      var maxStaleSeconds = -1
      var minFreshSeconds = -1
      var onlyIfCached = false
      var noTransform = false
      var immutable = false
    
      var canUseHeaderValue = true
      var headerValue: String? = null
    
      loop@ for (i in 0 until headers.size) {
        val name = headers.name(i)
        val value = headers.value(i)
    
        when {
          name.equals("Cache-Control", ignoreCase = true) -> {
            if (headerValue != null) {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 15 13:41:01 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

          }
    
          val now = backend.nanoTime()
          var minDelayNanos = Long.MAX_VALUE
          var readyTask: Task? = null
          var multipleReadyTasks = false
    
          // Decide what to run. This loop's goal wants to:
          //  * Find out what this thread should do (either run a task or sleep)
          //  * Find out if there's enough work to start another thread.
          eachQueue@ for (queue in readyQueues) {
    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/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

       * simultaneously adopted and removed.
       */
      private val connections = ConcurrentLinkedQueue<RealConnection>()
    
      init {
        // Put a floor on the keep alive duration, otherwise cleanup will spin loop.
        require(keepAliveDuration > 0L) { "keepAliveDuration <= 0: $keepAliveDuration" }
      }
    
      fun idleConnectionCount(): Int {
        return connections.count {
          it.withLock { it.calls.isEmpty() }
        }
      }
    
    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)
  4. okhttp/src/test/java/okhttp3/CallTest.kt

                bodyRef.set(response.body.string())
              } catch (e: IOException) {
                // It is ok if this broke the stream.
                bodyRef.set("A")
                throw e // We expect to not loop into onFailure in this case.
              } finally {
                latch.countDown()
              }
            }
          },
        )
        latch.await()
        assertThat(bodyRef.get()).isEqualTo("A")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 142.5K bytes
    - Viewed (0)
  5. CHANGELOG.md

     *  Fix: Don't crash after a web socket fails its connection upgrade. We incorrectly released
        the web socket's connections back to the pool before their resources were cleaned up.
    
     *  Fix: Don't infinite loop when a received web socket message has self-terminating compressed
        data.
    
     *  Fix: Don't fail the call when the response code is ‘HTTP 102 Processing’ or ‘HTTP 103 Early
        Hints’.
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 18 01:31:39 GMT 2024
    - 21.4K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt

        filesystem.deleteRecursively(cacheDir)
        assertThat(cache["a"]).isNull()
      }
    
      /**
       * We had a long-lived bug where [DiskLruCache.trimToSize] could infinite loop if entries
       * being edited required deletion for the operation to complete.
       */
      @ParameterizedTest
      @ArgumentsSource(FileSystemParamProvider::class)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 15 14:55:09 GMT 2024
    - 75.8K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/Protocol.kt

         *
         * @throws IOException if `protocol` is unknown.
         */
        @JvmStatic
        @Throws(IOException::class)
        fun get(protocol: String): Protocol {
          // Unroll the loop over values() to save an allocation.
          @Suppress("DEPRECATION")
          return when (protocol) {
            HTTP_1_0.protocol -> HTTP_1_0
            HTTP_1_1.protocol -> HTTP_1_1
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 06 04:17:33 GMT 2024
    - 4.4K bytes
    - Viewed (1)
Back to top