- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 167 for Decrement (0.67 sec)
-
pilot/pkg/model/typed_xds_cache.go
xdsCacheEvictionsOnClear = xdsCacheEvictions.With(typeTag.Value("clear")) xdsCacheEvictionsOnSize = xdsCacheEvictions.With(typeTag.Value("size")) ) func hit() { xdsCacheHits.Increment() } func miss() { xdsCacheMisses.Increment() } func size(cs int) { xdsCacheSize.Record(float64(cs)) } type CacheToken uint64 type dependents interface { DependentConfigs() []ConfigHash }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 11K bytes - Viewed (0) -
cni/pkg/install/install.go
// and we harm no one by doing so. copiedFiles, err := copyBinaries(in.cfg.CNIBinSourceDir, in.cfg.CNIBinTargetDirs) if err != nil { cniInstalls.With(resultLabel.Value(resultCopyBinariesFailure)).Increment() return copiedFiles, fmt.Errorf("copy binaries: %v", err) } // Install kubeconfig (if needed) - we write/update this in the shared node CNI netdir,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 10.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
private fun readWindowUpdate( handler: Handler, length: Int, flags: Int, streamId: Int, ) { val increment: Long try { if (length != 4) throw IOException("TYPE_WINDOW_UPDATE length !=4: $length") increment = source.readInt() and 0x7fffffffL if (increment == 0L) throw IOException("windowSizeIncrement was 0") } catch (e: Exception) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
proxyLog.WithLabels("id", con.conID).Debugf("upstream terminated with status %v", err) metrics.IstiodConnectionCancellations.Increment() } else { proxyLog.WithLabels("id", con.conID).Warnf("upstream terminated with unexpected error %v", err) metrics.IstiodConnectionErrors.Increment() } select { case con.upstreamError <- err: case <-con.stopChan: } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
pkg/wasm/convert.go
With(resultTag.Value(unmarshalFailure)). Increment() convertErrs[i] = err return } if extConfig == nil || (wasmHTTPConfig == nil && wasmNetworkConfig == nil) { // If there is no config, it is not wasm config. // Let's bypass the ECDS resource. wasmConfigConversionCount. With(resultTag.Value(noRemoteLoad)). Increment() return } if wasmHTTPConfig != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 13.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/subresources_test.go
} // UpdateStatus does not increment generation updatedStatusInstance, err := noxuResourceClient.UpdateStatus(context.TODO(), gottenNoxuInstance, metav1.UpdateOptions{}) if err != nil { t.Fatalf("unable to update status: %v", err) } if updatedStatusInstance.GetGeneration() != 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 12 17:35:34 UTC 2024 - 33.2K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheBuildServiceIntegrationTest.groovy
${ finalize ? "countingService.finalizeValue()" : "" } doLast { assert countingService.get().increment() == 2 assert requiredServices.elements.size() == 1 assert altServiceProvider.get().increment() == 3 } } """ def configurationCache = newConfigurationCacheFixture() when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 11:47:23 UTC 2024 - 29.1K bytes - Viewed (0) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkerExecutorParametersIntegrationTest.groovy
${parameterWorkAction('Property<CountingService>', 'println "value = " + parameters.testParam.get().increment()')} abstract class CountingService implements BuildService<BuildServiceParameters.None> { private final value = new AtomicInteger() int increment() { def value = value.incrementAndGet() println("service: value is \${value}")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:36:27 UTC 2023 - 13.2K bytes - Viewed (0) -
android/guava/src/com/google/common/math/LongMath.java
int signum = 1 | (int) ((p ^ q) >> (Long.SIZE - 1)); boolean increment; switch (mode) { case UNNECESSARY: checkRoundingUnnecessary(rem == 0); // fall through case DOWN: increment = false; break; case UP: increment = true; break; case CEILING: increment = signum > 0; break; case FLOOR:
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 07 17:50:39 UTC 2024 - 44.6K bytes - Viewed (0) -
src/runtime/testdata/testprog/gc.go
// Don't set this too high, because this is a *live heap* target which // is not directly comparable to a total memory limit. maxTarget := int64((myLimit / 10) * 8) increment := int64((myLimit / 10) * 1) for i := increment; i < maxTarget; i += increment { target <- i // Check to make sure the memory limit is maintained. // We're just sampling here so if it transiently goes over we might miss it.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Oct 02 02:28:27 UTC 2022 - 12.1K bytes - Viewed (0)