Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. staging/src/k8s.io/apiserver/pkg/storage/interfaces.go

    	// GuaranteedUpdate keeps calling 'tryUpdate()' to update key 'key' (of type 'destination')
    	// retrying the update until success if there is index conflict.
    	// Note that object passed to tryUpdate may change across invocations of tryUpdate() if
    	// other writers are simultaneously updating it, so tryUpdate() needs to take into account
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 07:53:48 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  2. src/net/dnsclient_unix.go

    	// Prepare ch so that only one update of resolverConfig may
    	// run at once.
    	conf.ch = make(chan struct{}, 1)
    }
    
    // tryUpdate tries to update conf with the named resolv.conf file.
    // The name variable only exists for testing. It is otherwise always
    // "/etc/resolv.conf".
    func (conf *resolverConfig) tryUpdate(name string) {
    	conf.initOnce.Do(conf.init)
    
    	if conf.dnsConfig.Load().noReload {
    		return
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:23:45 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go

    // GuaranteedUpdate implements storage.Interface.GuaranteedUpdate.
    func (s *store) GuaranteedUpdate(
    	ctx context.Context, key string, destination runtime.Object, ignoreNotFound bool,
    	preconditions *storage.Preconditions, tryUpdate storage.UpdateFunc, cachedExistingObject runtime.Object) error {
    	preparedKey, err := s.prepareKey(key)
    	if err != nil {
    		return err
    	}
    	ctx, span := tracing.Start(ctx, "GuaranteedUpdate etcd3",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 35.2K bytes
    - Viewed (0)
Back to top