- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 42 for lastErr (0.16 sec)
-
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) -
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) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/recognizer/recognizer.go
// to have understood the object if out == nil || !runtime.IsStrictDecodingError(err) { lastErr = err continue } } return out, actual, err } if lastErr == nil { lastErr = fmt.Errorf("no serialization format matched the provided data") } return nil, nil, lastErr
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 19 21:24:36 UTC 2021 - 3.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/configuration/configuration_manager.go
if a.ready { return a.mergedConfiguration, nil } } if a.lastErr != nil { return nil, a.lastErr } return nil, ErrNotReady } func (a *poller) setConfigurationAndReady(value runtime.Object) { a.lock.Lock() defer a.lock.Unlock() a.bootstrapped = true a.mergedConfiguration = value a.ready = true a.lastErr = nil } func (a *poller) Run(stopCh <-chan struct{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 06 02:02:38 UTC 2017 - 4.3K bytes - Viewed (0) -
src/vendor/golang.org/x/net/lif/lif.go
return syscall.Close(int(ep.s)) } func newEndpoints(af int) ([]endpoint, error) { var lastErr error var eps []endpoint afs := []int{syscall.AF_INET, syscall.AF_INET6} if af != syscall.AF_UNSPEC { afs = []int{af} } for _, af := range afs { s, err := syscall.Socket(af, syscall.SOCK_DGRAM, 0) if err != nil { lastErr = err continue } eps = append(eps, endpoint{af: af, s: uintptr(s)}) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 950 bytes - Viewed (0) -
internal/bucket/bandwidth/reader.go
BucketOptions HeaderSize int } // Read implements a throttled read func (r *MonitoredReader) Read(buf []byte) (n int, err error) { if r.throttle == nil { return r.r.Read(buf) } if r.lastErr != nil { err = r.lastErr return } b := r.throttle.Burst() // maximum available tokens need := len(buf) // number of bytes requested by caller hdr := r.opts.HeaderSize // remaining header bytes
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Sep 06 03:21:59 UTC 2023 - 3.1K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/driver/tempfile.go
func cleanupTempFiles() error { tempFilesMu.Lock() defer tempFilesMu.Unlock() var lastErr error for _, f := range tempFiles { if err := os.Remove(f); err != nil { lastErr = err } } tempFiles = nil return lastErr
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 22 23:33:06 UTC 2020 - 1.7K bytes - Viewed (0) -
cmd/kubeadm/app/util/runtime/runtime.go
if err := runtime.impl.RemovePodSandbox(ctx, runtime.runtimeService, container); err != nil { lastErr = errors.Wrapf(err, "failed to remove pod %s", container) cancel() continue } cancel() lastErr = nil break } if lastErr != nil { errs = append(errs, lastErr) } } return errorsutil.NewAggregate(errs) } // PullImage pulls the image
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 06:33:22 UTC 2024 - 8.4K bytes - Viewed (0) -
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) -
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)