Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 425 for disks (0.05 sec)

  1. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  2. 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 {
    		index := index
    		g.Go(func() (err error) {
    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    			rf, err := disks[index].ReadXL(ctx, bucket, object, readData)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  3. cmd/erasure-encode_test.go

    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    			}
    			disk.Delete(context.Background(), "testbucket", "object", DeleteOptions{
    				Recursive: false,
    				Immediate: false,
    			})
    			writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(size), DefaultBitrotAlgorithm, erasure.ShardSize())
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  5. cmd/format-erasure.go

    // relinquishes the underlying connection for all storage disks.
    func closeStorageDisks(storageDisks ...StorageAPI) {
    	var wg sync.WaitGroup
    	for _, disk := range storageDisks {
    		if disk == nil {
    			continue
    		}
    		wg.Add(1)
    		go func(disk StorageAPI) {
    			defer wg.Done()
    			disk.Close()
    		}(disk)
    	}
    	wg.Wait()
    }
    
    // Initialize storage disks for each endpoint.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  6. cmd/object-api-putobject_test.go

    	if err != nil {
    		// Failed to create newbucket, abort.
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	// Take 4 disks down, one more we loose quorum on 16 disk node.
    	for _, disk := range disks[:4] {
    		os.RemoveAll(disk)
    	}
    
    	testCases := []struct {
    		bucketName    string
    		objName       string
    		inputData     []byte
    		inputMeta     map[string]string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  7. cmd/erasure-healing-common_test.go

    	}
    
    	for diskIndex, disk := range filteredDisks {
    		if _, ok := diskFailures[diskIndex]; ok {
    			if disk != nil {
    				t.Errorf("Drive not filtered as expected, drive: %d", diskIndex)
    			}
    			if !partNeedsHealing(dataErrsPerDisk[diskIndex]) {
    				t.Errorf("Disk expected to be healed, driveIndex: %d", diskIndex)
    			}
    		} else {
    			if disk == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 25 19:37:26 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  9. .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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 18 20:47:03 UTC 2023
    - 384 bytes
    - Viewed (0)
  10. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
Back to top