Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 33 for Ferris (0.15 sec)

  1. cmd/erasure-metadata.go

    			}
    			return errFileCorrupt
    		}, index)
    	}
    
    	// Wait for all the routines.
    	mErrs := g.Wait()
    
    	err := reduceWriteQuorumErrs(ctx, mErrs, objectOpIgnoredErrs, quorum)
    	return evalDisks(disks, mErrs), err
    }
    
    func commonParity(parities []int, defaultParityCount int) int {
    	N := len(parities)
    
    	occMap := make(map[int]int)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  2. cmd/erasure-server-pool.go

    		derrs[i] = checkDelObjArgs(ctx, bucket, objects[i].ObjectName)
    		objSets.Add(objects[i].ObjectName)
    	}
    
    	// Acquire a bulk write lock across 'objects'
    	multiDeleteLock := z.NewNSLock(bucket, objSets.ToSlice()...)
    	lkctx, err := multiDeleteLock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		for i := range derrs {
    			derrs[i] = err
    		}
    		return dobjects, derrs
    	}
    	ctx = lkctx.Context()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  3. 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 == "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  4. cmd/erasure-healing.go

    	if err != nil {
    		m, err := er.deleteIfDangling(ctx, bucket, object, partsMetadata, errs, nil, ObjectOptions{
    			VersionID: versionID,
    		})
    		errs = make([]error, len(errs))
    		for i := range errs {
    			errs[i] = err
    		}
    		if err == nil {
    			// Dangling object successfully purged, size is '0'
    			m.Size = 0
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  5. cmd/erasure-sets.go

    		drive := endpoints.GetString(i)
    		state := madmin.DriveStateCorrupt
    		switch {
    		case format != nil:
    			state = madmin.DriveStateOk
    		case sErrs[i] == errUnformattedDisk:
    			state = madmin.DriveStateMissing
    		case sErrs[i] == errDiskNotFound:
    			state = madmin.DriveStateOffline
    		}
    		beforeDrives[i] = madmin.HealDriveInfo{
    			UUID: func() string {
    				if format != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
  6. cmd/format-erasure.go

    // countErrs - count a specific error.
    func countErrs(errs []error, err error) int {
    	i := 0
    	for _, err1 := range errs {
    		if err1 == err || errors.Is(err1, err) {
    			i++
    		}
    	}
    	return i
    }
    
    // Does all errors indicate we need to initialize all disks?.
    func shouldInitErasureDisks(errs []error) bool {
    	return countErrs(errs, errUnformattedDisk) == len(errs)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  7. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 30.8K bytes
    - Viewed (0)
  8. doc/README.md

    Use the following forms in your markdown:
    
    	[http.Request]                     # symbol documentation; auto-linked as in Go doc strings
    	[#12345](/issue/12345)             # GitHub issues
    	[CL 6789](/cl/6789)                # Gerrit changelists
    
    ## For the release team
    
    At the start of a release development cycle, the contents of `next` should be deleted
    and replaced with those of `initial`. From the repo root:
    
        > cd doc
    Plain Text
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Fri Apr 26 21:24:36 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  9. cmd/storage-rest-client.go

    		for i := range errs {
    			errs[i] = toStorageErr(err)
    		}
    		return errs
    	}
    
    	dErrResp := &DeleteVersionsErrsResp{}
    	if err = gob.NewDecoder(reader).Decode(dErrResp); err != nil {
    		for i := range errs {
    			errs[i] = toStorageErr(err)
    		}
    		return errs
    	}
    
    	for i, dErr := range dErrResp.Errs {
    		errs[i] = toStorageErr(dErr)
    	}
    
    	return errs
    }
    
    // RenameFile - renames a file.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 11.3K bytes
    - Viewed (0)
Back to top