- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for tryUpdate (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/dryrun.go
if err != nil { return err } updated, _, err := tryUpdate(current, storage.ResponseMeta{ResourceVersion: rev}) if err != nil { return err } return s.copyInto(updated, destination) } return s.Storage.GuaranteedUpdate(ctx, key, destination, ignoreNotFound, preconditions, tryUpdate, cachedExistingObject) } func (s *DryRunnableStorage) Count(key string) (int64, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 20:40:48 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/registry/core/service/allocator/storage/storage.go
e.lock.Lock() defer e.lock.Unlock() return e.tryUpdate(func() error { return e.alloc.Release(item) }) } func (e *Etcd) ForEach(fn func(int)) { e.lock.Lock() defer e.lock.Unlock() e.alloc.ForEach(fn) } // tryUpdate performs a read-update to persist the latest snapshot state of allocation. func (e *Etcd) tryUpdate(fn func() error) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 6.5K bytes - Viewed (0) -
src/net/nss.go
func getSystemNSS() *nssConf { nssConfig.tryUpdate() nssConfig.mu.Lock() conf := nssConfig.nssConf nssConfig.mu.Unlock() return conf } // init initializes conf and is only called via conf.initOnce. func (conf *nsswitchConfig) init() { conf.nssConf = parseNSSConfFile("/etc/nsswitch.conf") conf.lastChecked = time.Now() conf.ch = make(chan struct{}, 1) } // tryUpdate tries to update conf.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 15 20:15:51 UTC 2022 - 5.5K bytes - Viewed (0)