- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 596 for limiting (0.12 sec)
-
android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* Past underutilization could mean that excess resources are available. Then, the RateLimiter * should speed up for a while, to take advantage of these resources. This is important when the * rate is applied to networking (limiting bandwidth), where past underutilization typically * translates to "almost empty buffers", which can be filled immediately. * * On the other hand, past underutilization could mean that "the server responsible for handling
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 19.3K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/CacheBuilder.java
if (strictParsing) { checkState( this.maximumSize == UNSET_INT, "weigher can not be combined with maximum size (%s provided)", this.maximumSize); } // safely limiting the kinds of caches this can produce @SuppressWarnings("unchecked") CacheBuilder<K1, V1> me = (CacheBuilder<K1, V1>) this; me.weigher = checkNotNull(weigher); return me; }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 15 16:12:13 UTC 2024 - 44.8K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheBuilder.java
if (strictParsing) { checkState( this.maximumSize == UNSET_INT, "weigher can not be combined with maximum size (%s provided)", this.maximumSize); } // safely limiting the kinds of caches this can produce @SuppressWarnings("unchecked") CacheBuilder<K1, V1> me = (CacheBuilder<K1, V1>) this; me.weigher = checkNotNull(weigher); return me; }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 15 16:12:13 UTC 2024 - 51.3K bytes - Viewed (0) -
src/runtime/export_test.go
func (l *GCCPULimiter) Capacity() uint64 { return l.limiter.bucket.capacity } func (l *GCCPULimiter) Overflow() uint64 { return l.limiter.overflow } func (l *GCCPULimiter) Limiting() bool { return l.limiter.limiting() } func (l *GCCPULimiter) NeedUpdate(now int64) bool { return l.limiter.needUpdate(now) } func (l *GCCPULimiter) StartGCTransition(enableGC bool, now int64) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:50:53 UTC 2024 - 46.1K bytes - Viewed (0) -
cmd/kubelet/app/options/options.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:05 UTC 2024 - 41.6K bytes - Viewed (0) -
pkg/proxy/healthcheck/healthcheck_test.go
} } func TestServerWithSelectiveListeningAddress(t *testing.T) { listener := newFakeListener() httpFactory := newFakeHTTPServerFactory() proxyChecker := &fakeProxierHealthChecker{true} // limiting addresses to loop back. We don't want any cleverness here around getting IP for // machine nor testing ipv6 || ipv4. using loop back guarantees the test will work on any machine
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 21.4K bytes - Viewed (0) -
src/runtime/profbuf.go
bufwords = min } // Buffer sizes must be power of two, so that we don't have to // worry about uint32 wraparound changing the effective position // within the buffers. We store 30 bits of count; limiting to 28 // gives us some room for intermediate calculations. if bufwords >= 1<<28 || tags >= 1<<28 { throw("newProfBuf: buffer too large") } var i int for i = 1; i < bufwords; i <<= 1 { }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 18.2K bytes - Viewed (0) -
src/runtime/mgcmark.go
// // TODO(mknyszek): Hide the details of inMarkAssist in tracer // functions and simplify all the state tracking. This is a lot. enteredMarkAssistForTracing := false retry: if gcCPULimiter.limiting() { // If the CPU limiter is enabled, intentionally don't // assist to reduce the amount of CPU time spent in the GC. if enteredMarkAssistForTracing { trace := traceAcquire() if trace.ok() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 21:25:11 UTC 2024 - 52.5K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteStreams.java
* @since 14.0 (since 1.0 as com.google.common.io.NullOutputStream) */ public static OutputStream nullOutputStream() { return NULL_OUTPUT_STREAM; } /** * Wraps a {@link InputStream}, limiting the number of bytes which can be read. * * @param in the input stream to be wrapped * @param limit the maximum number of bytes to be read * @return a length-limited {@link InputStream}
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Jan 17 18:59:58 UTC 2024 - 29.7K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteStreams.java
* @since 14.0 (since 1.0 as com.google.common.io.NullOutputStream) */ public static OutputStream nullOutputStream() { return NULL_OUTPUT_STREAM; } /** * Wraps a {@link InputStream}, limiting the number of bytes which can be read. * * @param in the input stream to be wrapped * @param limit the maximum number of bytes to be read * @return a length-limited {@link InputStream}
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Jan 17 18:59:58 UTC 2024 - 29.7K bytes - Viewed (0)