Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for lastErr (0.23 sec)

  1. pkg/controlplane/apiserver/config.go

    	lastErr error,
    ) {
    	genericConfig = genericapiserver.NewConfig(legacyscheme.Codecs)
    	genericConfig.MergedResourceConfig = resourceConfig
    
    	if lastErr = s.GenericServerRunOptions.ApplyTo(genericConfig); lastErr != nil {
    		return
    	}
    
    	if lastErr = s.SecureServing.ApplyTo(&genericConfig.SecureServing, &genericConfig.LoopbackClientConfig); lastErr != nil {
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/util/apiclient/wait.go

    		true, func(_ context.Context) (bool, error) {
    			hash, err := getStaticPodSingleHash(w.client, nodeName, component)
    			if err != nil {
    				lastErr = err
    				return false, nil
    			}
    			// Set lastErr to nil to be able to later distinguish between getStaticPodSingleHash() and timeout errors
    			lastErr = nil
    			// We should continue polling until the UID changes
    			if hash == previousHash {
    				return false, nil
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  3. pkg/volume/fc/fc_util.go

    	var lastErr error
    	for _, device := range devices {
    		err := util.detachFCDisk(c.io, c.exec, device)
    		if err != nil {
    			klog.Errorf("fc: detachFCDisk failed. device: %v err: %v", device, err)
    			lastErr = fmt.Errorf("fc: detachFCDisk failed. device: %v err: %v", device, err)
    		}
    	}
    	if lastErr != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 16 11:12:06 UTC 2022
    - 12.8K bytes
    - Viewed (0)
  4. src/net/dnsclient_unix.go

    					// This error will abort the nameList loop.
    					hitStrictError = true
    					lastErr = result.error
    				} else if lastErr == nil || fqdn == name+"." {
    					// Prefer error for original name.
    					lastErr = result.error
    				}
    				continue
    			}
    
    			// Presotto says it's okay to assume that servers listed in
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:23:45 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  5. pkg/volume/iscsi/iscsi_util.go

    					lastErr = fmt.Errorf("iscsi: failed to sendtargets to portal %s output: %s, err %v", tp, out, err)
    					continue
    				}
    
    				err = updateISCSINode(b, tp)
    				if err != nil {
    					// failure to update node db is rare. But deleting record will likely impact those who already start using it.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 22 12:53:01 UTC 2022
    - 34.1K bytes
    - Viewed (0)
  6. pkg/kubelet/volumemanager/reconciler/reconstruct_test.go

    			}
    			// Unmount runs in a go routine, wait for its finish
    			var lastErr error
    			err = retryWithExponentialBackOff(testOperationBackOffDuration, func() (bool, error) {
    				if err := verifyTearDownCalls(fakePlugin, tc.expectedUnmounts); err != nil {
    					lastErr = err
    					return false, nil
    				}
    				return true, nil
    			})
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  7. pkg/kubeapiserver/authenticator/config.go

    	if err != nil {
    		return err
    	}
    
    	var lastErr error
    	if waitErr := wait.PollUntilContextCancel(ctx, 10*time.Second, true, func(_ context.Context) (done bool, err error) {
    		lastErr = updatedJWTAuthenticator.healthCheck()
    		return lastErr == nil, nil
    	}); lastErr != nil || waitErr != nil {
    		updatedJWTAuthenticator.cancel()
    		return utilerrors.NewAggregate([]error{lastErr, waitErr}) // filters out nil errors
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 19:29:33 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storageversion/manager.go

    	// this map allows quick status lookup for a GroupResource, during API request handling.
    	managedStatus map[schema.GroupResource]*updateStatus
    }
    
    type updateStatus struct {
    	done    bool
    	lastErr error
    }
    
    // NewDefaultManager creates a new defaultManager.
    func NewDefaultManager() Manager {
    	s := &defaultManager{}
    	s.completed.Store(false)
    	s.managedResourceInfos = make(map[*ResourceInfo]struct{})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 14 17:47:19 UTC 2023
    - 10.5K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/devicemanager/plugin/v1beta1/stub.go

    				var lastErr error
    
    				err := wait.PollUntilContextTimeout(context.Background(), 10*time.Second, 2*time.Minute, false, func(context.Context) (done bool, err error) {
    					restartErr := m.Restart()
    					if restartErr == nil {
    						return true, nil
    					}
    					klog.ErrorS(restartErr, "Retrying after error")
    					lastErr = restartErr
    					return false, nil
    				})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 11:19:10 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  10. internal/rest/client.go

    	TraceOutput io.Writer // Debug trace output
    
    	httpClient   *http.Client
    	url          *url.URL
    	newAuthToken func(audience string) string
    
    	sync.RWMutex // mutex for lastErr
    	lastErr      error
    	lastErrTime  time.Time
    }
    
    type restError string
    
    func (e restError) Error() string {
    	return string(e)
    }
    
    func (e restError) Timeout() bool {
    	return true
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 14.4K bytes
    - Viewed (0)
Back to top