- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,105 for errC (0.04 sec)
-
cmd/storage-rest-server.go
if err != nil { s.writeErrorResponse(w, err) return } length, err := strconv.ParseInt(r.Form.Get(storageRESTLength), 10, 64) if err != nil { s.writeErrorResponse(w, err) return } rc, err := s.getStorage().ReadFileStream(r.Context(), volume, filePath, offset, length) if err != nil { s.writeErrorResponse(w, err) return } defer rc.Close()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 45.7K bytes - Viewed (0) -
internal/http/listener_test.go
nextTest: for i, testCase := range testCases { listener, errs := newHTTPListener(context.Background(), testCase.serverAddrs, TCPOptions{}, ) for _, err := range errs { if err != nil { if strings.Contains(err.Error(), "The requested address is not valid in its context") { // Ignore if IP is unbindable. continue nextTest } if strings.Contains(err.Error(), "bind: address already in use") {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 17:41:02 UTC 2024 - 11.8K bytes - Viewed (0) -
cmd/erasure-healing-common.go
onlineDisks[index] = nil } } return onlineDisks, modTime, "" } // Convert verify or check parts returned error to integer representation func convPartErrToInt(err error) int { err = unwrapAll(err) switch err { case nil: return checkPartSuccess case errFileNotFound, errFileVersionNotFound: return checkPartFileNotFound case errFileCorrupt: return checkPartFileCorrupt
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 12.7K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
if err := yaml.UnmarshalStrict(doc, &out); err != nil { errs = multierror.Append(errs, multierror.Prefix(err, fmt.Sprintf("failed to decode file %s: ", path))) return warnings, errs } un := unstructured.Unstructured{Object: out} warning, err := v.validateResource(*istioNamespace, defaultNamespace, &un, writer) if err != nil { errs = multierror.Append(errs, multierror.Prefix(err, fmt.Sprintf("%s/%s/%s:",
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 15 22:27:47 UTC 2024 - 14.3K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
// the corresponding error in errs slice is not nil func evalDisks(disks []StorageAPI, errs []error) []StorageAPI { if len(errs) != len(disks) { bugLogIf(GlobalContext, errors.New("unexpected drives/errors slice length")) return nil } newDisks := make([]StorageAPI, len(disks)) for index := range errs { if errs[index] == nil { newDisks[index] = disks[index] } else {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.7K bytes - Viewed (0) -
cmd/admin-handlers-users-race_test.go
uClient := s.getUserClient(c, accessKeys[i], secretKeys[i], "") err := s.adm.RemoveUser(ctx, accessKeys[i]) if err != nil { return err } c.mustNotListObjects(ctx, uClient, bucket) return nil } }(i), i) } if errs := g.Wait(); len(errs) > 0 { c.Fatalf("unable to remove users: %v", errs) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 28 09:06:25 UTC 2024 - 4K bytes - Viewed (0) -
cmd/global-heal.go
if !isMinioMetaBucketName(bucket) { vc, err = globalBucketVersioningSys.Get(bucket) if err != nil { retErr = err healingLogIf(ctx, err) continue } // Check if the current bucket has a configured lifecycle policy lc, err = globalLifecycleSys.Get(bucket) if err != nil && !errors.Is(err, BucketLifecycleNotFound{Bucket: bucket}) { retErr = err healingLogIf(ctx, err) continue }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.3K bytes - Viewed (0) -
cmd/peer-s3-server.go
} return err } bucketsInfo[index] = BucketInfo{Name: bucket, Created: volInfo.Created} return nil }, index) } errs := g.Wait() if err := reduceReadQuorumErrs(ctx, errs, bucketOpIgnoredErrs, (len(localDrives) / 2)); err != nil { return BucketInfo{}, err } var bucketInfo BucketInfo for i, err := range errs { if err == nil { bucketInfo = bucketsInfo[i] break }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 22 21:57:20 UTC 2024 - 8.1K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
meta, err := loadBucketMetadata(ctx, sys.objAPI, buckets[index]) if err != nil { return err } bucketMetas[index] = meta return nil }, index) } errs := g.Wait() for index, err := range errs { if err != nil { internalLogOnceIf(ctx, fmt.Errorf("Unable to load bucket metadata, will be retried: %w", err),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 20.4K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
log.Debug("removing annotation from pod") if err := util.AnnotateUnenrollPod(s.kubeClient, &pod.ObjectMeta); err != nil { log.Errorf("failed to annotate pod unenrollment: %v", err) errs = append(errs, err) return errors.Join(errs...) } return errors.Join(errs...) } // syncHostIPSets is called after the host node ipset has been created (or found + flushed)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Sep 25 20:54:34 UTC 2024 - 13.4K bytes - Viewed (0)