- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 166 for limiting (0.15 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) -
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) -
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) -
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) -
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) -
src/mime/multipart/formdata_test.go
return } t.Errorf("ReadForm(x) failed for x < 1024, expect success") } // TestReadForm_MetadataTooLarge verifies that we account for the size of field names, // MIME headers, and map entry overhead while limiting the memory consumption of parsed forms. func TestReadForm_MetadataTooLarge(t *testing.T) { for _, test := range []struct { name string f func(*Writer) }{{ name: "large name", f: func(fw *Writer) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 05 18:31:56 UTC 2024 - 14K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/text/unicode/norm/composition.go
rune [maxBufferSize]Properties // Per character info. byte [maxByteBufferSize]byte // UTF-8 buffer. Referenced by runeInfo.pos. nbyte uint8 // Number or bytes. ss streamSafe // For limiting length of non-starter sequence. nrune int // Number of runeInfos. f formInfo src input nsrc int tmpBytes input out []byte
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
err := c.syncConfigMap() if err == nil { // if you had no error, tell the queue to stop tracking history for your key. This will // reset things like failure counts for per-item rate limiting c.queue.Forget(key) return true } // there was a failure so be sure to report it. This method allows for pluggable error handling // which can be used for things like cluster-monitoring
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
tensorflow/cc/saved_model/loader.cc
return absl::OkStatus(); } namespace { // Session wrapper that prevents calls to Session::Create(), Session::Extend(), // and the deprecated partial-run methods. // // Limiting the available methods on a returned Session gives us the option // to replace the Session with a cut-down implementation, without breaking any // users. class LiteSessionWrapper : public Session { public:
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Apr 02 04:36:00 UTC 2024 - 23K bytes - Viewed (0)