Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 380 for diskID (0.23 sec)

  1. cmd/metacache-set.go

    	// However many we ask, versions must exist on ~50%
    	listingQuorum := (askDisks + 1) / 2
    
    	if askDisks > 0 && len(disks) > askDisks {
    		rand.Shuffle(len(disks), func(i, j int) {
    			disks[i], disks[j] = disks[j], disks[i]
    		})
    		fallbackDisks = disks[askDisks:]
    		disks = disks[:askDisks]
    	}
    
    	// How to resolve results.
    	resolver := metadataResolutionParams{
    		dirQuorum: listingQuorum,
    		objQuorum: listingQuorum,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  2. cmd/erasure-decode_test.go

    	}
    	disks := setup.disks
    	erasure, err := NewErasure(context.Background(), data, parity, blockSizeV2)
    	if err != nil {
    		b.Fatalf("failed to create ErasureStorage: %v", err)
    	}
    
    	writers := make([]io.Writer, len(disks))
    	for i, disk := range disks {
    		if disk == nil {
    			continue
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  3. cmd/erasure-metadata-utils.go

    }
    
    // shuffleDisks - shuffle input disks slice depending on the
    // erasure distribution. Return shuffled slice of disks with
    // their expected distribution.
    func shuffleDisks(disks []StorageAPI, distribution []int) (shuffledDisks []StorageAPI) {
    	if distribution == nil {
    		return disks
    	}
    	shuffledDisks = make([]StorageAPI, len(disks))
    	// Shuffle disks for expected distribution.
    	for index := range disks {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    	var uploadIDs []string
    	var disk StorageAPI
    	disks := er.getOnlineLocalDisks()
    	if len(disks) == 0 {
    		// If no local, get non-healing disks.
    		var ok bool
    		if disks, ok = er.getOnlineDisksWithHealing(false); !ok {
    			disks = er.getOnlineDisks()
    		}
    	}
    
    	for _, disk = range disks {
    		if disk == nil {
    			continue
    		}
    		if !disk.IsOnline() {
    			continue
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  5. cmd/erasure-encode_test.go

    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    			}
    			disk.Delete(context.Background(), "testbucket", "object", DeleteOptions{
    				Recursive: false,
    				Immediate: false,
    			})
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(size), DefaultBitrotAlgorithm, erasure.ShardSize())
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    }
    
    func readAllRawFileInfo(ctx context.Context, disks []StorageAPI, bucket, object string, readData bool) ([]RawFileInfo, []error) {
    	rawFileInfos := make([]RawFileInfo, len(disks))
    	g := errgroup.WithNErrs(len(disks))
    	for index := range disks {
    		index := index
    		g.Go(func() (err error) {
    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    			rf, err := disks[index].ReadXL(ctx, bucket, object, readData)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  7. cmd/metrics.go

    		float64(totalDisks.Sum()),
    	)
    
    	for _, disk := range server.Disks {
    		// Total disk usage by the disk
    		ch <- prometheus.MustNewConstMetric(
    			prometheus.NewDesc(
    				prometheus.BuildFQName(diskNamespace, "storage", "used"),
    				"Total disk storage used on the drive",
    				[]string{"disk"}, nil),
    			prometheus.GaugeValue,
    			float64(disk.UsedSpace),
    			disk.DrivePath,
    		)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  8. cmd/erasure-metadata-utils_test.go

    	if shuffledDisks[0] != disks[8] ||
    		shuffledDisks[1] != disks[7] ||
    		shuffledDisks[2] != disks[9] ||
    		shuffledDisks[3] != disks[6] ||
    		shuffledDisks[4] != disks[10] ||
    		shuffledDisks[5] != disks[5] ||
    		shuffledDisks[6] != disks[11] ||
    		shuffledDisks[7] != disks[4] ||
    		shuffledDisks[8] != disks[12] ||
    		shuffledDisks[9] != disks[3] ||
    		shuffledDisks[10] != disks[13] ||
    		shuffledDisks[11] != disks[2] ||
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  9. cmd/metrics-realtime.go

    		m.ByDisk = make(map[string]madmin.DiskMetric)
    		aggr := madmin.DiskMetric{
    			CollectedAt: time.Now(),
    		}
    		for name, disk := range collectLocalDisksMetrics(opts.disks) {
    			m.ByDisk[name] = disk
    			aggr.Merge(&disk)
    		}
    		m.Aggregated.Disk = &aggr
    	}
    
    	if types.Contains(madmin.MetricsScanner) {
    		metrics := globalScannerMetrics.report()
    		m.Aggregated.Scanner = &metrics
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  10. cmd/erasure-object_test.go

    		}
    
    		// Step 3: Upload the object with some disks offline
    		sets.erasureDisksMu.Lock()
    		xl.getDisks = func() []StorageAPI {
    			disks := make([]StorageAPI, len(origErasureDisks))
    			copy(disks, origErasureDisks)
    			disks[0] = nil
    			disks[1] = nil
    			return disks
    		}
    		sets.erasureDisksMu.Unlock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
Back to top