Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  2. internal/s3select/select.go

    			}
    			// Test these compressor errors
    			errs := []error{
    				gzip.ErrHeader, gzip.ErrChecksum,
    				s2.ErrCorrupt, s2.ErrUnsupported, s2.ErrCRC,
    				zstd.ErrBlockTooSmall, zstd.ErrMagicMismatch, zstd.ErrWindowSizeExceeded, zstd.ErrUnknownDictionary, zstd.ErrWindowSizeTooSmall,
    				lz4.ErrInvalid, lz4.ErrBlockDependency,
    			}
    			for _, e := range errs {
    				if errors.Is(err, e) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
  3. cmd/erasure-object_test.go

    	parts7SC := storageclass.Config{
    		Standard: storageclass.StorageClass{
    			Parity: 5,
    		},
    	}
    
    	tests := []struct {
    		parts               []FileInfo
    		errs                []error
    		expectedReadQuorum  int
    		expectedWriteQuorum int
    		storageClassCfg     storageclass.Config
    		expectedError       error
    	}{
    		{parts1, errs1, 12, 12, parts1SC, nil},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. cmd/peer-s3-client.go

    			return err
    		}, idx)
    	}
    
    	errs := g.Wait()
    
    	var poolErrs []error
    	for poolIdx := 0; poolIdx < sys.poolsCount; poolIdx++ {
    		perPoolErrs := make([]error, 0, len(sys.peerClients))
    		for i, client := range sys.peerClients {
    			if slices.Contains(client.GetPools(), poolIdx) {
    				perPoolErrs = append(perPoolErrs, errs[i])
    			}
    		}
    		quorum := len(perPoolErrs) / 2
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K 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. 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)
  9. cmd/metacache-server-pool.go

    					allAtEOF = false
    				}
    				errs[i] = err
    			}(len(errs), set)
    			errs = append(errs, nil)
    		}
    	}
    	mu.Unlock()
    
    	// Gather results to a single channel.
    	// Quorum is one since we are merging across sets.
    	err := mergeEntryChannels(ctx, inputs, results, 1)
    
    	cancelList()
    	wg.Wait()
    
    	// we should return 'errs' from per disk
    	if isAllNotFound(errs) {
    		if isAllVolumeNotFound(errs) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  10. cmd/storage-rest-server.go

    		return errDiskAccessDenied
    	}
    
    	if countErrs(errs, errDiskNotDir) == len(errs) {
    		return errDiskNotDir
    	}
    
    	if countErrs(errs, errFaultyDisk) == len(errs) {
    		return errFaultyDisk
    	}
    
    	if countErrs(errs, errXLBackend) == len(errs) {
    		return errXLBackend
    	}
    
    	return nil
    }
    
    // A single function to write certain errors to be fatal
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
Back to top