- Sort Score
- Num 10 results
- Language All
Results 31 - 40 of 153 for nDisks (0.05 seconds)
-
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 Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 23.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java
public void testModify_basher() throws Exception { int nTasks = 3000; int nThreads = 100; int getsPerTask = 1000; int deltaRange = 10000; String key = "key"; AtomicLongMap<String> map = AtomicLongMap.create(); ExecutorService threadPool = newFixedThreadPool(nThreads); ArrayList<Future<Long>> futures = new ArrayList<>(); for (int i = 0; i < nTasks; i++) { futures.add( threadPool.submit(
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 4.2K bytes - Click Count (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)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 4.8K bytes - Click Count (0) -
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 Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:06:31 GMT 2025 - 16.7K bytes - Click Count (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
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Sep 18 20:47:03 GMT 2023 - 384 bytes - Click Count (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) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 25.8K bytes - Click Count (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 )
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 22.4K bytes - Click Count (0) -
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 Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.2K bytes - Click Count (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 capacity } // GetTotalCapacityFree gets the total capacity free in the cluster.Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 2.2K bytes - Click Count (0) -
cmd/benchmark-utils_test.go
ctx, cancel := context.WithCancel(b.Context()) defer cancel() objLayer, disks, err := prepareTestBackend(ctx, instanceType) if err != nil { b.Fatalf("Failed obtaining Temp Backend: <ERROR> %s", err) } // cleaning up the backend by removing all the directories and files created on function return. defer removeRoots(disks) // uses *testing.B and the object Layer to run the benchmark.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.1K bytes - Click Count (0)