Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for hofor (0.02 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Settings.kt

      operator fun get(id: Int): Int = values[id]
    
      /** Returns the number of settings that have values assigned. */
      fun size(): Int = Integer.bitCount(set)
    
      // TODO: honor this setting.
      fun getEnablePush(defaultValue: Boolean): Boolean {
        val bit = 1 shl ENABLE_PUSH
        return if (bit and set != 0) values[ENABLE_PUSH] == 1 else defaultValue
      }
    
      fun getMaxConcurrentStreams(): Int {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/HttpHeaders.kt

        responseCode != HTTP_NOT_MODIFIED
      ) {
        return true
      }
    
      // If the Content-Length or Transfer-Encoding headers disagree with the response code, the
      // response is malformed. For best compatibility, we honor the headers.
      if (headersContentLength() != -1L ||
        "chunked".equals(header("Transfer-Encoding"), ignoreCase = true)
      ) {
        return true
      }
    
      return false
    }
    
    @Deprecated(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

                while (true) {
                  OverflowAvoidingLockSupport.parkNanos(this, remainingNanos);
                  // Check interruption first, if we woke up due to interruption we need to honor that.
                  if (Thread.interrupted()) {
                    removeWaiter(node);
                    throw new InterruptedException();
                  }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  4. cmd/handler-api.go

    		return 0
    	}
    	return limit
    }
    
    func availableMemory() (available uint64) {
    	available = 2048 * blockSizeV2 * 2 // Default to 4 GiB when we can't find the limits.
    
    	if runtime.GOOS == "linux" {
    		// Honor cgroup limits if set.
    		limit := cgroupMemLimit()
    		if limit > 0 {
    			// A valid value is found, return its 90%
    			available = (limit * 9) / 10
    			return
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

                while (true) {
                  OverflowAvoidingLockSupport.parkNanos(this, remainingNanos);
                  // Check interruption first, if we woke up due to interruption we need to honor that.
                  if (Thread.interrupted()) {
                    removeWaiter(node);
                    throw new InterruptedException();
                  }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  6. docs/distributed/README.md

    **In our tests we also found ext4 does not honor POSIX O_DIRECT/Fdatasync semantics, ext4 trades performance for consistency guarantees. Please avoid ext4 in your setup.**
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  7. CHANGELOG.md

     *  New: `OkHttpClient.webSocketCloseTimeout` configures how long a web socket connection will wait
        for a graceful shutdown before it performs an abrupt shutdown.
    
     *  Fix: Honor `RequestBody.isOneShot()` in `MultipartBody`
    
     *  Fix in `okhttp-coroutines`: Don't leak response bodies in `executeAsync()`. We had a bug where
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 19:32:33 UTC 2025
    - 31.6K bytes
    - Viewed (2)
  8. cmd/erasure-object.go

    	disks := er.getDisks()
    	// Assume (N/2 + 1) quorum for Delete()
    	// this is a theoretical assumption such that
    	// for delete's we do not need to honor storage
    	// class for objects that have reduced quorum
    	// due to storage class - this only needs to be honored
    	// for Read() requests alone that we already do.
    	writeQuorum := len(disks)/2 + 1
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

              }
            }
          }
        }
    
        override fun priority(
          streamId: Int,
          streamDependency: Int,
          weight: Int,
          exclusive: Boolean,
        ) {
          // TODO: honor priority.
        }
    
        override fun pushPromise(
          streamId: Int,
          promisedStreamId: Int,
          requestHeaders: List<Header>,
        ) {
          pushRequestLater(promisedStreamId, requestHeaders)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/suggest/SuggesterTest.java

            assertEquals(0, response1.getNum());
            assertEquals(0, response1.getTotal());
    
            SuggestResponse response2 = suggester.suggest().setQuery("honor").setSuggestDetail(true).execute().getResponse();
            assertEquals(1, response2.getNum());
            assertEquals(1, response2.getTotal());
            assertEquals("honorificabilitudinitatibus", response2.getWords().get(0));
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 37.2K bytes
    - Viewed (0)
Back to top