- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 165 for nDisks (0.04 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
.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) -
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) -
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)