Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for Cool (0.14 sec)

  1. cmd/erasure-server-pool.go

    	for _, pool := range pools {
    		if opts.SkipDecommissioned && z.IsSuspended(pool.Index) {
    			continue
    		}
    		// Skip object if it's from pools participating in a rebalance operation.
    		if opts.SkipRebalancing && z.IsPoolRebalancing(pool.Index) {
    			continue
    		}
    		if isErrReadQuorum(pool.Err) || pool.Err == nil {
    			errs = append(errs, poolErrs{Err: pool.Err, Index: pool.Index})
    		}
    	}
    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)
  2. cmd/erasure-object.go

    	}
    
    	toEncode := io.Reader(data)
    	if data.Size() >= bigFileThreshold {
    		// We use 2 buffers, so we always have a full buffer of input.
    		pool := globalBytePoolCap.Load()
    		bufA := pool.Get()
    		bufB := pool.Get()
    		defer pool.Put(bufA)
    		defer pool.Put(bufB)
    		ra, err := readahead.NewReaderBuffer(data, [][]byte{bufA[:fi.Erasure.BlockSize], bufB[:fi.Erasure.BlockSize]})
    		if err == nil {
    			toEncode = ra
    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)
  3. cmd/object-api-errors.go

    func isErrWriteQuorum(err error) bool {
    	var rquorum InsufficientWriteQuorum
    	return errors.As(err, &rquorum)
    }
    
    // isErrObjectNotFound - Check if error type is ObjectNotFound.
    func isErrObjectNotFound(err error) bool {
    	var objNotFound ObjectNotFound
    	return errors.As(err, &objNotFound)
    }
    
    // isErrVersionNotFound - Check if error type is VersionNotFound.
    func isErrVersionNotFound(err error) bool {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 21.3K bytes
    - Viewed (0)
  4. cmd/httprange_test.go

    	}
    }
    
    func TestHTTPRequestRangeToHeader(t *testing.T) {
    	validRangeSpecs := []struct {
    		spec        string
    		errExpected bool
    	}{
    		{"bytes=0-", false},
    		{"bytes=1-", false},
    
    		{"bytes=0-9", false},
    		{"bytes=1-10", false},
    		{"bytes=1-1", false},
    		{"bytes=2-5", false},
    
    		{"bytes=-5", false},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 3.7K bytes
    - Viewed (0)
  5. cmd/api-errors.go

    	},
    	ErrAdminRebalanceAlreadyStarted: {
    		Code:           "XMinioAdminRebalanceAlreadyStarted",
    		Description:    "Pool rebalance is already started",
    		HTTPStatusCode: http.StatusConflict,
    	},
    	ErrAdminRebalanceNotStarted: {
    		Code:           "XMinioAdminRebalanceNotStarted",
    		Description:    "Pool rebalance is not started",
    		HTTPStatusCode: http.StatusNotFound,
    	},
    	ErrMaximumExpires: {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  6. cmd/format-erasure.go

    	}
    	return i
    }
    
    // Does all errors indicate we need to initialize all disks?.
    func shouldInitErasureDisks(errs []error) bool {
    	return countErrs(errs, errUnformattedDisk) == len(errs)
    }
    
    // Check if unformatted disks are equal to 50%+1 of all the drives.
    func quorumUnformattedDisks(errs []error) bool {
    	return countErrs(errs, errUnformattedDisk) >= (len(errs)/2)+1
    }
    
    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/common-main.go

    	if updateMsg == "" {
    		return
    	}
    
    	logger.Info(prepareUpdateMessage("Run `mc admin update ALIAS`", lrTime.Sub(currentReleaseTime)))
    }
    
    func newConfigDir(dir string, dirSet bool, getDefaultDir func() string) (*ConfigDir, error) {
    	if dir == "" {
    		dir = getDefaultDir()
    	}
    
    	if dir == "" {
    		if !dirSet {
    			return nil, fmt.Errorf("missing option must be provided")
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  8. cmd/config-current.go

    	SubSys          string         `json:"subSys"`
    	Description     string         `json:"description"`
    	MultipleTargets bool           `json:"multipleTargets"`
    	KeysHelp        config.HelpKVS `json:"keysHelp"`
    }
    
    // GetHelp - returns help for sub-sys, a key for a sub-system or all the help.
    func GetHelp(subSys, key string, envOnly bool) (Help, error) {
    	if len(subSys) == 0 {
    		return Help{KeysHelp: config.HelpSubSysMap[subSys]}, nil
    	}
    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)
  9. cmd/endpoint-ellipses.go

    						return layout, err
    					}
    				}
    			default:
    				if err := endpointsList.add(arg); err != nil {
    					return layout, err
    				}
    			}
    		}
    
    		var stopping bool
    		var singleNode bool
    		var eps []string
    
    		for i := 0; ; i++ {
    			for _, node := range endpointsList {
    				if node.nodeName == "" {
    					singleNode = true
    				}
    
    				if len(node.disks) <= i {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  10. docs/distributed/CONFIG.md

    ```
    
    ### Things to know
    
    - Fields such as `version` and `pools` are mandatory, however all other fields are optional.
    - Each pool expects a minimum of 2 nodes per pool, and unique non-repeating hosts for each argument.
    - Each pool expects each host in this pool has the same number of drives specified as any other host.
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 4.2K bytes
    - Viewed (0)
Back to top