Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for tryUpdate (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top