Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for react (0.18 sec)

  1. cmd/erasure-multipart.go

    	return evalDisks(disks, errs), reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum)
    }
    
    // writeAllDisks - writes 'b' to all provided disks.
    // If write cannot reach quorum, the files will be deleted from all disks.
    func writeAllDisks(ctx context.Context, disks []StorageAPI, dstBucket, dstEntry string, b []byte, writeQuorum int) ([]StorageAPI, error) {
    	g := errgroup.WithNErrs(len(disks))
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  2. internal/config/config.go

    	}
    	if !isFound {
    		return
    	}
    
    	if target == "" {
    		target = Default
    	}
    
    	if redactSecrets {
    		// If the configuration parameter is a secret, make sure to redact it when
    		// we return.
    		helpKV, _ := HelpSubSysMap[subSys].Lookup(cfgParam)
    		if helpKV.Secret {
    			defer func() {
    				value = ""
    				isRedacted = true
    			}()
    		}
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 37.3K bytes
    - Viewed (0)
  3. cmd/admin-handlers.go

    		newConcurrent := concurrent + (concurrent+1)/2
    		autoTunedCapacityNeeded := uint64(newConcurrent * size)
    		if capacity < autoTunedCapacityNeeded {
    			// Turn-off auto-tuning if next possible concurrency would reach beyond disk capacity.
    			return true, false, ""
    		}
    	}
    
    	return true, autotune, ""
    }
    
    // DriveSpeedtestHandler - reports throughput of drives available in the cluster
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  4. cmd/service.go

    // For each call, unfreezeServices must be called once.
    func unfreezeServices() {
    	// We need a lock since we need the 2 atomic values to remain in sync.
    	globalServiceFreezeMu.Lock()
    	// Close when we reach 0
    	globalServiceFreezeCnt--
    	if globalServiceFreezeCnt <= 0 {
    		// Set to a nil channel.
    		var _ch chan struct{}
    		if val := globalServiceFreeze.Swap(_ch); val != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Feb 28 07:02:14 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  5. cmd/erasure-healing.go

    	if err != nil {
    		return result, err
    	}
    
    	// List of disks having all parts as per latest metadata.
    	// NOTE: do not pass in latestDisks to diskWithAllParts since
    	// the diskWithAllParts needs to reach the drive to ensure
    	// validity of the metadata content, we should make sure that
    	// we pass in disks as is for it to be verified. Once verified
    	// the disksWithAllParts() returns the actual disks that can be
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  6. cmd/http-tracer.go

    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/mcontext"
    )
    
    var ldapPwdRegex = regexp.MustCompile("(^.*?)LDAPPassword=([^&]*?)(&(.*?))?$")
    
    // redact LDAP password if part of string
    func redactLDAPPwd(s string) string {
    	parts := ldapPwdRegex.FindStringSubmatch(s)
    	if len(parts) > 3 {
    		return parts[1] + "LDAPPassword=*REDACTED*" + parts[3]
    	}
    	return s
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 5.9K bytes
    - Viewed (0)
  7. cmd/metacache-entries.go

    			continue
    		}
    	}
    
    	// Return dir entries, if enough...
    	if selected != nil && selected.isDir() && dirExists >= r.dirQuorum {
    		return selected, true
    	}
    
    	// If we would never be able to reach read quorum.
    	if objsValid < r.objQuorum {
    		return nil, false
    	}
    
    	// If all objects agree.
    	if selected != nil && objsAgree == objsValid {
    		return selected, true
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  8. internal/s3select/sql/jsonpath.go

    				if arr, ok := rval.([]interface{}); ok {
    					result = append(result, arr...)
    					continue
    				}
    			}
    			result = append(result, rval)
    		}
    		return result, true, nil
    	}
    	panic("cannot reach here")
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  9. docs/hotfixes.md

    lead to conflicts and the patch will not cleanly apply. Conflicts might be trivial which can be resolved easily, when conflicts seem to be non-trivial or touches the part of the code-base the developer is not confident - to get additional clarity reach out to #hack on MinIOHQ slack channel. Hasty changes must be avoided, minor fixes and logs may be added to hotfix branches but this should not be followed as practice.*
    
    Once the **patch** is successfully applied, developer must run tests to...
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Feb 14 21:36:02 GMT 2024
    - 5K bytes
    - Viewed (0)
  10. cmd/globals.go

    	globalDirSuffixWithSlash       = globalDirSuffix + slashSeparator
    
    	// Add new global values here.
    )
    
    const (
    	// Limit fields size (except file) to 1Mib since Policy document
    	// can reach that size according to https://aws.amazon.com/articles/1434
    	maxFormFieldSize = int64(1 * humanize.MiByte)
    
    	// The maximum allowed time difference between the incoming request
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
Back to top