Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 42 for lastErr (0.14 sec)

  1. cmd/kubeadm/app/util/etcd/etcd.go

    		func(_ context.Context) (bool, error) {
    			var overallEtcdPodCount int
    			if etcdEndpoints, overallEtcdPodCount, lastErr = getRawEtcdEndpointsFromPodAnnotationWithoutRetry(client); lastErr != nil {
    				return false, nil
    			}
    			if len(etcdEndpoints) == 0 || overallEtcdPodCount != len(etcdEndpoints) {
    				klog.V(4).Infof("found a total of %d etcd pods and the following endpoints: %v; retrying",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 11:04:08 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  2. pkg/volume/util/atomic_writer.go

    	ps := string(os.PathSeparator)
    	var lasterr error
    	for p := range paths {
    		// only remove symlinks from the volume root directory (i.e. items that don't contain '/')
    		if strings.Contains(p, ps) {
    			continue
    		}
    		if err := os.Remove(filepath.Join(w.targetDir, p)); err != nil {
    			klog.Errorf("%s: error pruning old user-visible path %s: %v", w.logContext, p, err)
    			lasterr = err
    		}
    	}
    
    	return lasterr
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go

    	// 2. if the quota changed and the update passes, be happy
    	// 3. if the quota changed and the update fails, add the original to a retry list
    	var updatedFailedQuotas []corev1.ResourceQuota
    	var lastErr error
    	for i := range quotas {
    		newQuota := quotas[i]
    
    		// if this quota didn't have its status changed, skip it
    		if quota.Equals(originalQuotas[i].Status.Used, newQuota.Status.Used) {
    			continue
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  4. src/database/sql/sql.go

    	raw []byte
    }
    
    // lasterrOrErrLocked returns either lasterr or the provided err.
    // rs.closemu must be read-locked.
    func (rs *Rows) lasterrOrErrLocked(err error) error {
    	if rs.lasterr != nil && rs.lasterr != io.EOF {
    		return rs.lasterr
    	}
    	return err
    }
    
    // bypassRowsAwaitDone is only used for testing.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:53 UTC 2024
    - 103.6K bytes
    - Viewed (0)
  5. src/cmd/vendor/golang.org/x/sys/windows/dll_windows.go

    // (according to the semantics of the specific function being called) before consulting
    // the error. The error will be guaranteed to contain windows.Errno.
    func (p *Proc) Call(a ...uintptr) (r1, r2 uintptr, lastErr error) {
    	switch len(a) {
    	case 0:
    		return syscall.Syscall(p.Addr(), uintptr(len(a)), 0, 0, 0)
    	case 1:
    		return syscall.Syscall(p.Addr(), uintptr(len(a)), a[0], 0, 0)
    	case 2:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat Dec 05 12:36:42 UTC 2020
    - 12K bytes
    - Viewed (0)
  6. src/database/sql/convert.go

    			}
    			// Chain the cancel function.
    			parentCancel := rows.cancel
    			rows.cancel = func() {
    				// When Rows.cancel is called, the closemu will be locked as well.
    				// So we can access rs.lasterr.
    				d.close(rows.lasterr)
    				if parentCancel != nil {
    					parentCancel()
    				}
    			}
    			rows.closemu.Unlock()
    			return nil
    		}
    	}
    
    	var sv reflect.Value
    
    	switch d := dest.(type) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  7. pkg/volume/util/util.go

    func GetReliableMountRefs(mounter mount.Interface, mountPath string) ([]string, error) {
    	var paths []string
    	var lastErr error
    	err := wait.PollImmediate(10*time.Millisecond, time.Minute, func() (bool, error) {
    		var err error
    		paths, err = mounter.GetMountRefs(mountPath)
    		if io.IsInconsistentReadError(err) {
    			lastErr = err
    			return false, nil
    		}
    		if err != nil {
    			return false, err
    		}
    		return true, nil
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 28.8K bytes
    - Viewed (0)
  8. src/syscall/dll_windows.go

    	return p.proc.Addr()
    }
    
    // Call executes procedure p with arguments a. See the documentation of
    // Proc.Call for more information.
    //
    //go:uintptrescapes
    func (p *LazyProc) Call(a ...uintptr) (r1, r2 uintptr, lastErr error) {
    	p.mustFind()
    	return p.proc.Call(a...)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 21:03:59 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  9. pkg/controller/volume/attachdetach/reconciler/reconciler_test.go

    			return true, nil
    		}
    		lastErr = fmt.Errorf("Check volume <%v> is reported as attached to node <%v>, got %v, expected %v",
    			volumeName,
    			nodeName,
    			result,
    			isAttached)
    		return false, nil
    	})
    	if err != nil {
    		t.Fatalf("last error: %q, wait timeout: %q", lastErr, err.Error())
    	}
    
    }
    
    func verifyVolumeNoStatusUpdateNeeded(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 07:00:14 UTC 2024
    - 72.8K bytes
    - Viewed (0)
  10. src/syscall/zsyscall_windows.go

    	n = uint32(r0)
    	if n == 0 {
    		err = errnoErr(e1)
    	}
    	return
    }
    
    func GetLastError() (lasterr error) {
    	r0, _, _ := Syscall(procGetLastError.Addr(), 0, 0, 0, 0)
    	if r0 != 0 {
    		lasterr = Errno(r0)
    	}
    	return
    }
    
    func GetLongPathName(path *uint16, buf *uint16, buflen uint32) (n uint32, err error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 21 11:49:46 UTC 2024
    - 56.3K bytes
    - Viewed (1)
Back to top