Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 35 for errs (0.02 sec)

  1. cmd/erasure-healing-common.go

    		// because of bugs found in CopyObject/PutObjectTags) https://github.com/minio/minio/pull/10772
    		erasureDistributionReliable = false
    	}
    
    	metaErrs := make([]error, len(errs))
    
    	for i, onlineDisk := range onlineDisks {
    		if errs[i] != nil {
    			metaErrs[i] = errs[i]
    			continue
    		}
    		if onlineDisk == OfflineDisk {
    			metaErrs[i] = errDiskNotFound
    			continue
    		}
    
    		meta := partsMetadata[i]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    	respBody, err := client.call(ctx, storageRESTMethodDeleteVersions, values, &buffer, -1)
    	defer xhttp.DrainBody(respBody)
    	if err != nil {
    		if contextCanceled(ctx) {
    			err = ctx.Err()
    		}
    		for i := range errs {
    			errs[i] = err
    		}
    		return errs
    	}
    
    	reader, err := waitForHTTPResponse(respBody)
    	if err != nil {
    		for i := range errs {
    			errs[i] = toStorageErr(err)
    		}
    		return errs
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    	lfi, err := meta.ToFileInfo(bucket, object, "", inclFreeVers, true)
    	if err != nil {
    		for i := range errs {
    			if errs[i] == nil {
    				errs[i] = err
    			}
    		}
    		return metaFileInfos, errs
    	}
    	if !lfi.IsValid() {
    		for i := range errs {
    			if errs[i] == nil {
    				errs[i] = errFileCorrupt
    			}
    		}
    		return metaFileInfos, errs
    	}
    
    	versionID := lfi.VersionID
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    	// Merely for tracing storage
    	path := ""
    	if len(versions) > 0 {
    		path = versions[0].Name
    	}
    	errs = make([]error, len(versions))
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricDeleteVersions, volume, path)
    	if err != nil {
    		for i := range errs {
    			errs[i] = ctx.Err()
    		}
    		return errs
    	}
    	defer func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  5. 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)
  6. cni/pkg/nodeagent/net.go

    		errs = append(errs, err)
    	}
    	return errors.Join(errs...)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  7. cmd/erasure-metadata.go

    			}
    			return errFileCorrupt
    		}, index)
    	}
    
    	// Wait for all the routines.
    	mErrs := g.Wait()
    
    	err := reduceWriteQuorumErrs(ctx, mErrs, objectOpIgnoredErrs, quorum)
    	if err != nil && revert {
    		ng := errgroup.WithNErrs(len(disks))
    		for index := range disks {
    			if mErrs[index] != nil {
    				continue
    			}
    			index := index
    			ng.Go(func() error {
    				if disks[index] == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  8. cmd/storage-datatypes_gen.go

    			z.Volume, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "Volume")
    				return
    			}
    		case "fp":
    			z.FilePath, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "FilePath")
    				return
    			}
    		case "fi":
    			err = z.FI.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "FI")
    				return
    			}
    		default:
    			err = dc.Skip()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  9. istioctl/pkg/proxyconfig/proxyconfig.go

    					if err != nil {
    						return err
    					}
    
    					configWriter, err = setupPodConfigdumpWriter(kubeClient, podName, podNamespace, true, c.OutOrStdout())
    					if err != nil {
    						return err
    					}
    				} else {
    					var err error
    					configWriter, err = setupFileConfigdumpWriter(configDumpFile, c.OutOrStdout())
    					if err != nil {
    						return err
    					}
    				}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 15:53:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  10. cmd/data-scanner.go

    	}
    
    	// Get last healing information
    	buf, err := readConfig(ctx, objAPI, backgroundHealInfoPath)
    	if err != nil {
    		if !errors.Is(err, errConfigNotFound) {
    			internalLogOnceIf(ctx, err, backgroundHealInfoPath)
    		}
    		return backgroundHealInfo{}
    	}
    	var info backgroundHealInfo
    	if err = json.Unmarshal(buf, &info); err != nil {
    		bugLogIf(ctx, err, backgroundHealInfoPath)
    	}
    	return info
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
Back to top