- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 42 for lastErr (0.14 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
src/syscall/dll_windows.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:03:59 UTC 2024 - 7.7K bytes - Viewed (0) -
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) -
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)