Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 154 for nDisks (0.04 seconds)

  1. cmd/metrics.go

    		float64(GetTotalUsableCapacityFree(server.Disks, sinfo)),
    	)
    
    	// MinIO Offline Disks per node
    	ch <- prometheus.MustNewConstMetric(
    		prometheus.NewDesc(
    			prometheus.BuildFQName(minioNamespace, "disks", "offline"),
    			"Total number of offline drives in current MinIO server instance",
    			nil, nil),
    		prometheus.GaugeValue,
    		float64(offlineDisks.Sum()),
    	)
    
    	// MinIO Total Disks per node
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:06:31 GMT 2025
    - 16.7K bytes
    - Click Count (0)
  2. .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
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Sep 18 20:47:03 GMT 2023
    - 384 bytes
    - Click Count (0)
  3. 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
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 3.9K bytes
    - Click Count (0)
  4. 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.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 23.1K bytes
    - Click Count (0)
  5. 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) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 25.8K bytes
    - Click Count (0)
  6. 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 capacity
    }
    
    // GetTotalCapacityFree gets the total capacity free in the cluster.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  7. 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
    	)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  8. cmd/peer-s3-server.go

    	g := errgroup.WithNErrs(len(localDrives))
    
    	// Disk states slices
    	beforeState := make([]string, len(localDrives))
    	afterState := make([]string, len(localDrives))
    
    	// Make a volume entry on all underlying storage disks.
    	for index := range localDrives {
    		g.Go(func() (serr error) {
    			if localDrives[index] == nil {
    				beforeState[index] = madmin.DriveStateOffline
    				afterState[index] = madmin.DriveStateOffline
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  9. 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
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 30 22:03:28 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  10. cmd/erasure-multipart-conditional_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	existingETag := objInfo.ETag
    
    	// Simulate read quorum failure by taking enough disks offline
    	// With 16 disks (EC 8+8), read quorum is 9. Taking 8 disks offline leaves only 8,
    	// which is below read quorum.
    	erasureDisks := xl.getDisks()
    	z.serverPools[0].erasureDisksMu.Lock()
    	xl.getDisks = func() []StorageAPI {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 6.9K bytes
    - Click Count (0)
Back to Top