Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 37 for Errs (0.02 sec)

  1. cmd/config-current.go

    		if err != nil {
    			errs = append(errs, fmt.Errorf("Unable to apply heal config: %w", err))
    		} else {
    			globalHealConfig.Update(healCfg)
    		}
    	case config.BatchSubSys:
    		batchCfg, err := batch.LookupConfig(s[config.BatchSubSys][config.Default])
    		if err != nil {
    			errs = append(errs, fmt.Errorf("Unable to apply batch config: %w", err))
    		} else {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 28.5K bytes
    - Viewed (0)
  2. cmd/peer-s3-server.go

    			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
    		}
    	}
    
    	return bucketInfo, nil
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  3. cmd/erasure-healing-common_test.go

    			}
    
    			partsMetadata, errs := readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    			fi, err := getLatestFileInfo(ctx, partsMetadata, z.serverPools[0].sets[0].defaultParityCount, errs)
    			if err != nil {
    				t.Fatalf("Failed to getLatestFileInfo %v", err)
    			}
    
    			for j := range partsMetadata {
    				if errs[j] != nil {
    					t.Fatalf("expected error to be nil: %s", errs[j])
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  4. cmd/erasure-healing_test.go

    		if err != nil {
    			t.Fatal(err)
    		}
    
    		fileInfos, errs = readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    		if countErrs(errs, nil) != len(fileInfos) {
    			t.Fatal("Expected all xl.meta healed, but partial heal detected")
    		}
    
    		fileInfos, errs = readAllFileInfo(ctx, erasureDisks, "", minioMetaBucket, cfgFile, "", false, true)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  5. cmd/post-policy-fan-out.go

    			}
    			hr, err := hash.NewReaderWithOpts(ctx, bytes.NewReader(fanOutBuf), hopts)
    			if err != nil {
    				errs[idx] = err
    				return
    			}
    
    			reader := NewPutObjReader(hr)
    			defer func() {
    				if err := reader.Close(); err != nil {
    					errs[idx] = err
    				}
    				if err := hr.Close(); err != nil {
    					errs[idx] = err
    				}
    			}()
    
    			userDefined := make(map[string]string, len(req.UserMetadata))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.5K bytes
    - Viewed (0)
  6. cmd/erasure-healing.go

    	return g.Wait()
    }
    
    func isAllVolumeNotFound(errs []error) bool {
    	return countErrs(errs, errVolumeNotFound) == len(errs)
    }
    
    // isAllNotFound will return if any element of the error slice is not
    // errFileNotFound, errFileVersionNotFound or errVolumeNotFound.
    // A 0 length slice will always return false.
    func isAllNotFound(errs []error) bool {
    	for _, err := range errs {
    		if err != nil {
    			switch err.Error() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    	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
    	if versionID == "" {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  8. cmd/format-erasure_test.go

    	}
    	for _, erasureDir := range erasureDirs {
    		defer os.RemoveAll(erasureDir)
    	}
    	endpoints := mustGetNewEndpoints(0, 8, erasureDirs...)
    
    	storageDisks, errs := initStorageDisksWithErrors(endpoints, storageOpts{cleanUp: false, healthCheck: false})
    	for _, err := range errs {
    		if err != nil && err != errDiskNotFound {
    			t.Fatal(err)
    		}
    	}
    
    	format := newFormatErasureV3(1, 8)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  9. cmd/peer-s3-client.go

    	if healBucketErr := reduceWriteQuorumErrs(ctx, errs, bucketOpIgnoredErrs, len(errs)/2+1); healBucketErr != nil {
    		return madmin.HealResultItem{}, toObjectErr(healBucketErr, bucket)
    	}
    
    	res := madmin.HealResultItem{
    		Type:     madmin.HealItemBucket,
    		Bucket:   bucket,
    		SetCount: -1, // explicitly set an invalid value -1, for bucket heal scenario
    	}
    
    	for i, err := range errs {
    		if err == nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  10. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
Back to top