- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 242 for limiting (0.23 sec)
-
src/runtime/mgclimit.go
// // gomaxprocs isn't used directly so as to keep this structure unit-testable. nprocs int32 } // limiting returns true if the CPU limiter is currently enabled, meaning the Go GC // should take action to limit CPU utilization. // // It is safe to call concurrently with other operations. func (l *gcCPULimiterState) limiting() bool { return l.enabled.Load() } // startGCTransition notifies the limiter of a GC transition. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 22:07:41 UTC 2024 - 17.3K bytes - Viewed (0) -
src/runtime/debug/garbage.go
// The initial setting is 1 GB on 64-bit systems, 250 MB on 32-bit systems. // There may be a system-imposed maximum stack limit regardless // of the value provided to SetMaxStack. // // SetMaxStack is useful mainly for limiting the damage done by // goroutines that enter an infinite recursion. It only limits future // stack growth. func SetMaxStack(bytes int) int { return setMaxStack(bytes) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 9.9K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/loopbce.go
// the initial value (init) and the limiting value (limit). // // We also know that ind has the form (Phi init nxt) where // nxt is (Add inc nxt) which means: 1) inc dominates nxt // and 2) there is a loop starting at inc and containing nxt. // // We need to prove that the induction variable is incremented // only when it's smaller than the limiting value.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 07 17:37:47 UTC 2023 - 11.8K bytes - Viewed (0) -
samples/bookinfo/src/productpage/productpage.py
# flood reviews with unnecessary requests to demonstrate Istio rate limiting, asynchoronously async def floodReviewsAsynchronously(product_id, headers): # the response is disregarded await asyncio.gather(*(getProductReviewsIgnoreResponse(product_id, headers) for _ in range(flood_factor))) # flood reviews with unnecessary requests to demonstrate Istio rate limiting def floodReviews(product_id, headers):
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 14:35:54 UTC 2024 - 14.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/TimeLimiter.java
* wait on each method call to the proxy * @param timeoutUnit with timeoutDuration, the maximum length of time that callers are willing to * wait on each method call to the proxy * @return a time-limiting proxy * @throws IllegalArgumentException if {@code interfaceType} is a regular class, enum, or * annotation type, rather than an interface */ @SuppressWarnings("GoodTime") // should accept a java.time.Duration
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 15.3K bytes - Viewed (0) -
platforms/core-runtime/io/src/test/groovy/org/gradle/internal/io/StreamByteBufferTest.groovy
byteBuffer.readAsByteArray() == testBufferPart where: chunkSize = 8192 limit << [1, 8191, 8192, 8193, 8194] } def "can create buffer from InputStream and limiting size"() { given: def byteArrayInputStream = new ByteArrayInputStream(testbuffer) byte[] testBufferPart = new byte[limit] System.arraycopy(testbuffer, 0, testBufferPart, 0, limit)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 13:06:08 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/registry/certificates/certificates/strategy.go
fieldpath.MakePathOrDie("spec"), fieldpath.MakePathOrDie("status", "certificate"), ), } return fields } // PrepareForUpdate prepares the new certificate signing request by limiting // the data that is updated to only the conditions and populating condition timestamps func (csrApprovalStrategy) PrepareForUpdate(ctx context.Context, obj, old runtime.Object) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 18 21:41:43 UTC 2022 - 11.4K bytes - Viewed (0) -
internal/ioutil/ioutil.go
// an enscapsulated writer upto a certain length // and skip a certain number of bytes. type LimitWriter struct { io.Writer skipBytes int64 wLimit int64 } // Write implements the io.Writer interface limiting upto // configured length, also skips the first N bytes. func (w *LimitWriter) Write(p []byte) (n int, err error) { n = len(p) var n1 int if w.skipBytes > 0 { if w.skipBytes >= int64(len(p)) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 10.2K bytes - Viewed (0) -
LICENSE
add to a covered work, you may (if authorized by the copyright holders of that material) supplement the terms of this License with terms: a) Disclaiming warranty or limiting liability differently from the terms of sections 15 and 16 of this License; or b) Requiring preservation of specified reasonable legal notices or author attributions in that material or in the Appropriate Legal
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 33.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/start.go
// removes the newly created file and creates yet another // file. Then both processes would act as though they had the token. // This is very rare, but it's also okay because we're only grabbing // the token to do rate limiting, not for correctness. _ = os.Remove(tokenfile) } else if !os.IsNotExist(err) { log.Printf("error acquiring upload taken: statting token file: %v", err) return false }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 14:52:56 UTC 2024 - 10.8K bytes - Viewed (0)