Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 165 for nDisks (0.04 sec)

  1. cmd/metrics.go

    	totalDisks := offlineDisks.Merge(onlineDisks)
    
    	// Report total capacity
    	ch <- prometheus.MustNewConstMetric(
    		prometheus.NewDesc(
    			prometheus.BuildFQName(minioNamespace, "capacity_raw", "total"),
    			"Total capacity online in the cluster",
    			nil, nil),
    		prometheus.GaugeValue,
    		float64(GetTotalCapacity(server.Disks)),
    	)
    
    	// Report total capacity free
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  2. cmd/object-api-putobject_test.go

    }
    
    // Wrapper for calling PutObject tests for both Erasure multiple disks case
    // when quorum is not available.
    func TestObjectAPIPutObjectDiskNotFound(t *testing.T) {
    	ExecObjectLayerDiskAlteredTest(t, testObjectAPIPutObjectDiskNotFound)
    }
    
    // Tests validate correctness of PutObject.
    func testObjectAPIPutObjectDiskNotFound(obj ObjectLayer, instanceType string, disks []string, t *testing.T) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  3. cmd/format-erasure.go

    		This    string `json:"this"`    // This field carries assigned disk uuid.
    		// Sets field carries the input disk order generated the first
    		// time when fresh disks were supplied, it is a two dimensional
    		// array second dimension represents list of disks used per set.
    		Sets [][]string `json:"sets"`
    		// Distribution algorithm represents the hashing algorithm
    		// to pick the right set index for an object.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 23.1K bytes
    - Viewed (0)
  4. cmd/notification-summary.go

    	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.TotalSpace
    		}
    	}
    	return
    }
    
    // GetTotalCapacityFree gets the total capacity free in the cluster.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  5. cmd/erasure_test.go

    	diskPaths    []string
    	disks        []StorageAPI
    }
    
    // Returns an initialized setup for erasure tests.
    func newErasureTestSetup(tb testing.TB, dataBlocks int, parityBlocks int, blockSize int64) (*erasureTestSetup, error) {
    	diskPaths := make([]string, dataBlocks+parityBlocks)
    	disks := make([]StorageAPI, len(diskPaths))
    	var err error
    	for i := range diskPaths {
    		disks[i], diskPaths[i], err = newXLStorageTestSetup(tb)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  6. cmd/metrics-v3-cluster-health.go

    	m.Set(healthCapacityRawTotalBytes, float64(GetTotalCapacity(storageInfo.Disks)))
    	m.Set(healthCapacityRawFreeBytes, float64(GetTotalCapacityFree(storageInfo.Disks)))
    	m.Set(healthCapacityUsableTotalBytes, float64(GetTotalUsableCapacity(storageInfo.Disks, storageInfo)))
    	m.Set(healthCapacityUsableFreeBytes, float64(GetTotalUsableCapacityFree(storageInfo.Disks, storageInfo)))
    
    	return nil
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  7. cmd/admin-handlers.go

    		types = madmin.MetricType(t)
    	} else {
    		types = madmin.MetricsAll
    	}
    
    	disks := strings.Split(r.Form.Get("disks"), ",")
    	byDisk := strings.EqualFold(r.Form.Get("by-disk"), "true")
    	var diskMap map[string]struct{}
    	if len(disks) > 0 && disks[0] != "" {
    		diskMap = make(map[string]struct{}, len(disks))
    		for _, k := range disks {
    			if k != "" {
    				diskMap[k] = struct{}{}
    			}
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  8. .dockerignore

    docs/debugging/s3-check-md5/s3-check-md5
    docs/debugging/hash-set/hash-set
    docs/debugging/healing-bin/healing-bin
    docs/debugging/inspect/inspect
    docs/debugging/pprofgoparser/pprofgoparser
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Sep 18 20:47:03 UTC 2023
    - 384 bytes
    - Viewed (0)
  9. cmd/erasure-healing-common_test.go

    		t.Skip()
    	}
    
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	obj, disks, err := prepareErasure16(ctx)
    	if err != nil {
    		t.Fatalf("Prepare Erasure backend failed - %v", err)
    	}
    	setObjectLayer(obj)
    	defer obj.Shutdown(t.Context())
    	defer removeRoots(disks)
    
    	type tamperKind int
    	const (
    		noTamper tamperKind = iota
    		deletePart
    		corruptPart
    	)
    
    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. android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java

                .concurrencyLevel(20)
                .build(new DelayingIdentityLoader<String>(computationShouldWait, computationLatch));
    
        int nThreads = 100;
        int nTasks = 1000;
        int nSeededEntries = 100;
        Set<String> expectedKeys = Sets.newHashSetWithExpectedSize(nTasks + nSeededEntries);
        // seed the map, so its segments have a count>0; otherwise, clear() won't visit the in-progress
        // entries
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 25.1K bytes
    - Viewed (0)
Back to top