- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 483 for rwmutex (0.18 sec)
-
pilot/pkg/networking/core/envoyfilter/monitoring.go
return features.EnableEnvoyFilterMetrics }), ) ) var ( envoyFilterStatusMap = map[string]map[string]bool{} // Map of Envoy filter name, patch and status. envoyFilterMutex sync.RWMutex ) // IncrementEnvoyFilterMetric increments filter metric. func IncrementEnvoyFilterMetric(name string, pt PatchType, applied bool) { if !features.EnableEnvoyFilterMetrics { return } envoyFilterMutex.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/configuration/configuration_manager_test.go
"testing" "time" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/util/wait" ) func TestTolerateBootstrapFailure(t *testing.T) { var fakeGetSucceed bool var fakeGetSucceedLock sync.RWMutex fakeGetFn := func() (runtime.Object, error) { fakeGetSucceedLock.RLock() defer fakeGetSucceedLock.RUnlock() if fakeGetSucceed { return nil, nil } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 06 02:02:38 UTC 2017 - 2.4K bytes - Viewed (0) -
pkg/ledger/trie_cache.go
"sync" "time" "istio.io/istio/pkg/cache" ) type cacheDB struct { // updatedNodes that have will be flushed to disk updatedNodes byteCache // updatedMux is a lock for updatedNodes updatedMux sync.RWMutex } // byteCache implements a modified ExpiringCache interface, returning byte arrays // for ease of integration with smt calls. type byteCache struct { cache cache.ExpiringCache }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2K bytes - Viewed (0) -
src/syscall/forkpipe2.go
var ( // Guard the forking variable. forkingLock sync.Mutex // Number of goroutines currently forking, and thus the // number of goroutines holding a conceptual write lock // on ForkLock. forking int ) // hasWaitingReaders reports whether any goroutine is waiting // to acquire a read lock on rw. It is defined in the sync package. func hasWaitingReaders(rw *sync.RWMutex) bool // acquireForkLock acquires a write lock on ForkLock.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jul 10 19:19:59 UTC 2023 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/dropped_requests_tracker.go
} // unixStat keeps a statistic how many requests were dropped within // a single second. type unixStat struct { unixTime int64 requests int64 } type droppedRequestsStats struct { lock sync.RWMutex // history stores the history of dropped requests. history []unixStat // To reduce lock-contention, we store the information about // the current second here, which we can then access under // reader lock.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 26 13:50:25 UTC 2023 - 6.5K bytes - Viewed (0) -
src/runtime/race/testdata/sync_test.go
go f4() x = 2 <-ch } // A nil pointer in a mutex method call should not // corrupt the race detector state. // Used to hang indefinitely. func TestNoRaceNilMutexCrash(t *testing.T) { var mutex sync.Mutex panics := 0 defer func() { if x := recover(); x != nil { mutex.Lock() panics++ mutex.Unlock() } else { panic("no panic") } }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 10 15:05:17 UTC 2020 - 3K bytes - Viewed (0) -
src/crypto/x509/root.go
// - github.com/breml/rootcerts // // Do not remove or change the type signature. // See go.dev/issue/67401. // //go:linkname systemRoots var ( once sync.Once systemRootsMu sync.RWMutex systemRoots *CertPool systemRootsErr error fallbacksSet bool ) func systemRootsPool() *CertPool { once.Do(initSystemRoots) systemRootsMu.RLock() defer systemRootsMu.RUnlock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 2.3K bytes - Viewed (0) -
pkg/kubelet/config/sources.go
sourcesReadyFn: sourcesReadyFn, } } // sourcesImpl implements SourcesReady. It is thread-safe. type sourcesImpl struct { // lock protects access to sources seen. lock sync.RWMutex // set of sources seen. sourcesSeen sets.Set[string] // sourcesReady is a function that evaluates if the sources are ready. sourcesReadyFn SourcesReadyFn }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/quota/v1/generic/registry.go
*/ package generic import ( "sync" "k8s.io/apimachinery/pkg/runtime/schema" quota "k8s.io/apiserver/pkg/quota/v1" ) // implements a basic registry type simpleRegistry struct { lock sync.RWMutex // evaluators tracked by the registry evaluators map[schema.GroupResource]quota.Evaluator } // NewRegistry creates a simple registry with initial list of evaluators
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 04 12:53:52 UTC 2020 - 2.2K bytes - Viewed (0) -
internal/config/callhome/callhome.go
type Config struct { // Flag indicating whether callhome is enabled. Enable bool `json:"enable"` // The interval between callhome cycles Frequency time.Duration `json:"frequency"` } var configLock sync.RWMutex // Enabled - indicates if callhome is enabled or not func (c *Config) Enabled() bool { configLock.RLock() defer configLock.RUnlock() return c.Enable }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.6K bytes - Viewed (0)