- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 58 for Unlock1 (0.18 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
cacher.bookmarkWatchers.popExpiredWatchersThreadUnsafe() cacher.Unlock() } } }() // wait for adding/removing watchers to end wg.Wait() if watchErr != nil { t.Fatal(watchErr) } // wait out the expiration period and pop expired watchers time.Sleep(2 * time.Second) cacher.Lock() defer cacher.Unlock() cacher.bookmarkWatchers.popExpiredWatchersThreadUnsafe()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
cmd/erasure-healing_test.go
copy(disks, newDisks) objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock() } getDisk := func(n int) StorageAPI { objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Lock() disk := disks[n] objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock() return disk } // Remove 4 disks. setDisks(nil, nil, nil, nil)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 49K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
// called and the state is fully propagated to local cache. func (proxier *Proxier) OnServiceSynced() { proxier.mu.Lock() proxier.servicesSynced = true proxier.setInitialized(proxier.endpointSlicesSynced) proxier.mu.Unlock() // Sync unconditionally - this is called once per lifetime. proxier.syncProxyRules() } // OnEndpointSliceAdd is called whenever creation of a new endpoint slice object // is observed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
if ps == nil { log.Infof("Metric without context %s %v %s", key, proxyID, msg) return } ps.proxyStatusMutex.Lock() defer ps.proxyStatusMutex.Unlock() metricMap, f := ps.ProxyStatus[metric.Name()] if !f { metricMap = map[string]ProxyPushStatus{} ps.ProxyStatus[metric.Name()] = metricMap } ev := ProxyPushStatus{Message: msg, Proxy: proxyID}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0) -
src/runtime/malloc.go
// Once arenasHugePages is set, all new L2 entries will be eligible for // huge pages. We'll set all the old entries after we release the lock. lock(&h.lock) if h.arenasHugePages { unlock(&h.lock) return } h.arenasHugePages = true unlock(&h.lock) // N.B. The arenas L1 map is quite small on all platforms, so it's fine to // just iterate over the whole thing. for i := range h.arenas {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 59.6K bytes - Viewed (0) -
src/cmd/go/internal/modload/init.go
} func (mms *MainModuleSet) Index(m module.Version) *modFileIndex { mms.indexMu.Lock() defer mms.indexMu.Unlock() return mms.indices[m] } func (mms *MainModuleSet) SetIndex(m module.Version, index *modFileIndex) { mms.indexMu.Lock() defer mms.indexMu.Unlock() mms.indices[m] = index } func (mms *MainModuleSet) ModFile(m module.Version) *modfile.File { return mms.modFiles[m] }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 18:36:30 UTC 2024 - 69.8K bytes - Viewed (0) -
src/runtime/mgcpacer.go
out = gcController.setMemoryLimit(in) if in < 0 || out == in { // If we're just checking the value or not changing // it, there's no point in doing the rest. unlock(&mheap_.lock) return } gcControllerCommit() unlock(&mheap_.lock) }) return out } func readGOMEMLIMIT() int64 { p := gogetenv("GOMEMLIMIT") if p == "" || p == "off" { return maxInt64 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 55.4K bytes - Viewed (0) -
testing/performance/src/templates/native-dependents-resources/googleTest/libs/googleTest/1.7.0/include/gtest/internal/gtest-port.h
// Acquires this mutex. void Lock() { GTEST_CHECK_POSIX_SUCCESS_(pthread_mutex_lock(&mutex_)); owner_ = pthread_self(); has_owner_ = true; } // Releases this mutex. void Unlock() { // Since the lock is being released the owner_ field should no longer be // considered valid. We don't protect writing to has_owner_ here, as it's
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 67.2K bytes - Viewed (0) -
cmd/xl-storage.go
return "", err } if xioutil.SameFile(fi, fileInfo) && diskID != "" { s.Lock() // If the file has not changed, just return the cached diskID information. s.formatLastCheck = time.Now() s.Unlock() return diskID, nil } b, err := os.ReadFile(s.formatFile) if err != nil { // If the disk is still not initialized. if osIsNotExist(err) { if err = Access(s.drivePath); err == nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 85.3K bytes - Viewed (0) -
src/cmd/dist/build.go
} func startInstall(dir string) chan struct{} { installedMu.Lock() ch := installed[dir] if ch == nil { ch = make(chan struct{}) installed[dir] = ch go runInstall(dir, ch) } installedMu.Unlock() return ch } // runInstall installs the library, package, or binary associated with pkg, // which is relative to $GOROOT/src. func runInstall(pkg string, ch chan struct{}) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 18:34:40 UTC 2024 - 54K bytes - Viewed (0)