Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 35 for Graves (0.23 sec)

  1. cmd/endpoint-ellipses.go

    	// prefers setCounts to be sorted for optimal behavior.
    	if divisibleSize < setCounts[len(setCounts)-1] {
    		return divisibleSize
    	}
    
    	// Figure out largest value of total_drives_in_erasure_set which results
    	// in least number of total_drives/total_drives_erasure_set ratio.
    	prevD := divisibleSize / setCounts[0]
    	for _, cnt := range setCounts {
    		if divisibleSize%cnt == 0 {
    			d := divisibleSize / cnt
    			if d <= prevD {
    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)
  2. utils/utils.go

    func FileWithLineNum() string {
    	pcs := [13]uintptr{}
    	// the third caller usually from gorm internal
    	len := runtime.Callers(3, pcs[:])
    	frames := runtime.CallersFrames(pcs[:len])
    	for i := 0; i < len; i++ {
    		// second return value is "more", not "ok"
    		frame, _ := frames.Next()
    		if (!strings.HasPrefix(frame.File, gormSourceDir) ||
    			strings.HasSuffix(frame.File, "_test.go")) && !strings.HasSuffix(frame.File, ".gen.go") {
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Mon Apr 22 06:43:02 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  3. cmd/metrics-resource.go

    	resourceMetricsMapMu sync.RWMutex
    	// resourceMetricsHelpMap maps metric name to its help string
    	resourceMetricsHelpMap map[MetricName]string
    	resourceMetricsGroups  []*MetricsGroupV2
    	// initial values for drives (at the time  of server startup)
    	// used for calculating avg values for drive metrics
    	latestDriveStats      map[string]madmin.DiskIOStats
    	latestDriveStatsMu    sync.RWMutex
    	lastDriveStatsRefresh time.Time
    )
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 17.4K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    // Special object test type for stale files situations.
    type objTestStaleFilesType func(obj ObjectLayer, instanceType string, dirs []string, t *testing.T)
    
    // ExecObjectLayerStaleFilesTest - executes object layer tests those leaves stale
    // files/directories under .minio/tmp.  Creates Erasure ObjectLayer instance and runs test for Erasure layer.
    func ExecObjectLayerStaleFilesTest(t *testing.T, objTest objTestStaleFilesType) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  5. cmd/format-erasure.go

    		DistributionAlgo string `json:"distributionAlgo"`
    	} `json:"xl"`
    	Info DiskInfo `json:"-"`
    }
    
    func (f *formatErasureV3) Drives() (drives int) {
    	for _, set := range f.Erasure.Sets {
    		drives += len(set)
    	}
    	return drives
    }
    
    func (f *formatErasureV3) Clone() *formatErasureV3 {
    	b, err := json.Marshal(f)
    	if err != nil {
    		panic(err)
    	}
    	var dst formatErasureV3
    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)
  6. cmd/erasure-server-pool-decom.go

    func (set *erasureObjects) listObjectsToDecommission(ctx context.Context, bi decomBucketInfo, fn func(entry metaCacheEntry)) error {
    	disks, _ := set.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    		return fmt.Errorf("no online drives found for set with endpoints %s", set.getEndpoints())
    	}
    
    	// However many we ask, versions must exist on ~50%
    	listingQuorum := (set.setDriveCount + 1) / 2
    
    	// How to resolve partial results.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  7. internal/event/target/postgresql.go

    	if err := target.db.Ping(); err != nil {
    		if IsConnErr(err) {
    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store if questore is configured, which will be replayed when the PostgreSQL connection is active.
    func (target *PostgreSQLTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:51:07 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  8. cmd/tier.go

    		delete(config.Tiers, k)
    	}
    	// Copy over the new tier configs
    	for tier, cfg := range newConfig.Tiers {
    		config.Tiers[tier] = cfg
    	}
    	config.lastRefreshedAt = UTCNow()
    	return nil
    }
    
    // Save saves tier configuration onto objAPI
    func (config *TierConfigMgr) Save(ctx context.Context, objAPI ObjectLayer) error {
    	if objAPI == nil {
    		return errServerNotInitialized
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  9. cmd/storage-rest-server.go

    		var hint string
    		if endpoint.URL != nil {
    			hint = fmt.Sprintf("Drive '%s' does not support O_DIRECT flags, MinIO erasure coding requires filesystems with O_DIRECT support", endpoint.Path)
    		} else {
    			hint = "Drives do not support O_DIRECT flags, MinIO erasure coding requires filesystems with O_DIRECT support"
    		}
    		logger.Fatal(config.ErrUnsupportedBackend(err).Hint(hint), "Unable to initialize backend")
    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)
  10. cmd/xl-storage.go

    // ReadAll is a raw call, reads content at any path and returns the buffer.
    func (s *xlStorage) ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error) {
    	// Specific optimization to avoid re-read from the drives for `format.json`
    	// in-case the caller is a network operation.
    	if volume == minioMetaBucket && path == formatConfigFile {
    		s.RLock()
    		formatData := make([]byte, len(s.formatData))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
Back to top