- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 582 for observ (0.12 sec)
-
src/testing/testing_windows.go
unwrapped := errors.Unwrap(err) if unwrapped == nil { break } err = unwrapped } if err == syscall.ERROR_ACCESS_DENIED { return true // Observed in https://go.dev/issue/50051. } if err == windows.ERROR_SHARING_VIOLATION { return true // Observed in https://go.dev/issue/51442. } return false } // highPrecisionTime represents a single point in time with query performance counter.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 22:55:25 UTC 2024 - 1.9K bytes - Viewed (0) -
docs/es/docs/tutorial/path-params.md
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Fri Mar 22 01:42:11 UTC 2024 - 9.4K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
computeZoneStateFunc func(nodeConditions []*v1.NodeCondition) (int, ZoneState) knownNodeSet map[string]*v1.Node // per Node map storing last observed health together with a local time when it was observed. nodeHealthMap *nodeHealthMap // evictorLock protects zonePodEvictor and zoneNoExecuteTainter. evictorLock sync.Mutex // workers that are responsible for tainting nodes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/maxinflight.go
} } // watermark tracks requests being executed (not waiting in a queue) var watermark = &requestWatermark{ phase: metrics.ExecutingPhase, } // startWatermarkMaintenance starts the goroutines to observe and maintain the specified watermark. func startWatermarkMaintenance(watermark *requestWatermark, stopCh <-chan struct{}) { // Periodically update the inflight usage metric. go wait.Until(func() { watermark.lock.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 11:34:15 UTC 2023 - 6.9K bytes - Viewed (0) -
src/runtime/proflabel.go
// This uses racereleasemerge rather than just racerelease so // the acquire in profBuf.read synchronizes with *all* prior // setProfLabel operations, not just the most recent one. This // is important because profBuf.read will observe different // labels set by different setProfLabel operations on // different goroutines, so it needs to synchronize with all // of them (this wouldn't be an issue if we could synchronize
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 2.1K bytes - Viewed (0) -
src/runtime/lock_wasip1.go
return false } func lock(l *mutex) { lockWithRank(l, getLockRank(l)) } func lock2(l *mutex) { if l.key == mutex_locked { // wasm is single-threaded so we should never // observe this. throw("self deadlock") } gp := getg() if gp.m.locks < 0 { throw("lock count") } gp.m.locks++ l.key = mutex_locked } func unlock(l *mutex) { unlockWithRank(l) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 21:02:20 UTC 2023 - 2K bytes - Viewed (0) -
cmd/metrics-v2_test.go
// observations. This is to test the channel based // synchronization used internally. select { case <-ticker.C: ttfbHist.With(prometheus.Labels{"api": obs.label}).Observe(obs.val) } } metrics := getHistogramMetrics(ttfbHist, getBucketTTFBDistributionMD(), false) // additional labels for +Inf for all histogram metrics
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Mar 04 18:05:56 UTC 2024 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/stats.go
if hit { tag = hitTag } else { tag = missTag } latency := time.Since(start) requestCount.WithContext(ctx).WithLabelValues(tag).Inc() requestLatency.WithContext(ctx).WithLabelValues(tag).Observe(float64(latency.Milliseconds()) / 1000) } } func (statsCollector) blocking(ctx context.Context) func() { activeFetchCount.WithContext(ctx).WithLabelValues(fetchBlockedTag).Inc()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 01 18:49:09 UTC 2021 - 2.9K bytes - Viewed (0) -
pkg/kubelet/eviction/types.go
// signalObservation is the observed resource usage type signalObservation struct { // The resource capacity capacity *resource.Quantity // The available resource available *resource.Quantity // Time at which the observation was taken time metav1.Time } // signalObservations maps a signal to an observed quantity type signalObservations map[evictionapi.Signal]signalObservation
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 7.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MapMaker.java
* be performed atomically on the returned map. Additionally, {@code size} and {@code * containsValue} are implemented as bulk read operations, and thus may fail to observe concurrent * writes. * * @return a serializable concurrent map having the requested features */ public <K, V> ConcurrentMap<K, V> makeMap() { if (!useCustomMap) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Mar 13 14:30:51 UTC 2023 - 12.8K bytes - Viewed (0)