Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 283 for diskID (0.4 sec)

  1. cmd/notification-summary.go

    func GetTotalUsableCapacityFree(diskInfo []madmin.Disk, s StorageInfo) (capacity uint64) {
    	for _, disk := range diskInfo {
    		// Ignore invalid.
    		if disk.PoolIndex < 0 || len(s.Backend.StandardSCData) <= disk.PoolIndex {
    			// https://github.com/minio/minio/issues/16500
    			continue
    		}
    		// Ignore parity disks
    		if disk.DiskIndex < s.Backend.StandardSCData[disk.PoolIndex] {
    			capacity += disk.AvailableSpace
    		}
    	}
    	return
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  2. cmd/erasure-heal_test.go

    		}
    
    		readers := make([]io.ReaderAt, len(disks))
    		for i, disk := range disks {
    			shardFilesize := erasure.ShardFileSize(test.size)
    			readers[i] = newBitrotReader(disk, nil, "testbucket", "testobject", shardFilesize, test.algorithm, bitrotWriterSum(writers[i]), erasure.ShardSize())
    		}
    
    		// setup stale disks for the test case
    		staleDisks := make([]StorageAPI, len(disks))
    		copy(staleDisks, disks)
    		for j := range staleDisks {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  3. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  5. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  6. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21K bytes
    - Viewed (0)
  7. cmd/erasure-encode_test.go

    	}
    	disks := setup.disks
    	buffer := make([]byte, blockSizeV2, 2*blockSizeV2)
    	content := make([]byte, size)
    
    	for i := range dataDown {
    		disks[i] = OfflineDisk
    	}
    	for i := data; i < data+parityDown; i++ {
    		disks[i] = OfflineDisk
    	}
    
    	b.SetBytes(size)
    	b.ReportAllocs()
    	for b.Loop() {
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  8. 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 {
    		g.Go(func() (err error) {
    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    			rf, err := disks[index].ReadXL(ctx, bucket, object, readData)
    			if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  9. cmd/erasure-healing-common_test.go

    	_, _ = checkObjectWithAllParts(ctx, erasureDisks, partsMetadata,
    		errs, fi, false, bucket, object, madmin.HealDeepScan)
    
    	for diskIndex, disk := range erasureDisks {
    		if diskIndex == 0 && disk != nil {
    			t.Errorf("Drive not filtered as expected, drive: %d", diskIndex)
    		}
    		if diskIndex != 0 && disk == nil {
    			t.Errorf("Drive erroneously filtered, driveIndex: %d", diskIndex)
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 22.4K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K bytes
    - Viewed (0)
Back to top