Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 323 for disks (0.02 sec)

  1. cmd/erasure-heal_test.go

    		}
    
    		readers := make([]io.ReaderAt, len(disks))
    		for i, disk := range disks {
    			shardFilesize := erasure.ShardFileSize(test.size)
    			readers[i] = newBitrotReader(disk, nil, "testbucket", "testobject", shardFilesize, test.algorithm, bitrotWriterSum(writers[i]), erasure.ShardSize())
    		}
    
    		// setup stale disks for the test case
    		staleDisks := make([]StorageAPI, len(disks))
    		copy(staleDisks, disks)
    		for j := range staleDisks {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  2. cmd/erasure-sets.go

    if (disks not recognized) // Always error.
    
    // Specific checks.
    if (all disks online)
      if (all disks return format.json)
         if (jbod consistent)
            if (all disks recognized)
              return
      else
         if (all disks return format.json not found)
            return error
         else (some disks return format.json not found)
            (heal format)
            return
         fi
       fi
    else
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  3. cmd/erasure-healing.go

    			var wg sync.WaitGroup
    			// Remove versions in bulk for each disk
    			for index, disk := range storageDisks {
    				if disk == nil {
    					continue
    				}
    				wg.Add(1)
    				go func(index int, disk StorageAPI) {
    					defer wg.Done()
    					_ = disk.Delete(ctx, bucket, object, DeleteOptions{
    						Recursive: false,
    						Immediate: false,
    					})
    				}(index, disk)
    			}
    			wg.Wait()
    		}
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  4. cmd/metacache-set.go

    	// However many we ask, versions must exist on ~50%
    	listingQuorum := (askDisks + 1) / 2
    
    	if askDisks > 0 && len(disks) > askDisks {
    		rand.Shuffle(len(disks), func(i, j int) {
    			disks[i], disks[j] = disks[j], disks[i]
    		})
    		fallbackDisks = disks[askDisks:]
    		disks = disks[:askDisks]
    	}
    
    	// How to resolve results.
    	resolver := metadataResolutionParams{
    		dirQuorum: listingQuorum,
    		objQuorum: listingQuorum,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.7K bytes
    - Viewed (0)
  5. cmd/erasure-multipart.go

    	var uploadIDs []string
    	var disk StorageAPI
    	disks := er.getOnlineLocalDisks()
    	if len(disks) == 0 {
    		// If no local, get non-healing disks.
    		var ok bool
    		if disks, ok = er.getOnlineDisksWithHealing(false); !ok {
    			disks = er.getOnlineDisks()
    		}
    	}
    
    	for _, disk = range disks {
    		if disk == nil {
    			continue
    		}
    		if !disk.IsOnline() {
    			continue
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  6. .gitignore

    docs/debugging/healing-bin/healing-bin
    docs/debugging/inspect/inspect
    docs/debugging/pprofgoparser/pprofgoparser
    docs/debugging/reorder-disks/reorder-disks
    docs/debugging/populate-hard-links/populate-hardlinks
    docs/debugging/xattr/xattr
    hash-set
    healing-bin
    inspect
    pprofgoparser
    reorder-disks
    s3-check-md5
    s3-verify
    xattr
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 802 bytes
    - Viewed (0)
  7. cmd/server-main_test.go

    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    	// Tests for ErasureSD object layer.
    	nDisks := 1
    	disks, err := getRandomDisks(nDisks)
    	if err != nil {
    		t.Fatal("Failed to create drives for the backend")
    	}
    	defer removeRoots(disks)
    
    	obj, err := newObjectLayer(ctx, mustGetPoolEndpoints(0, disks...))
    	if err != nil {
    		t.Fatal("Unexpected object layer initialization error", err)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  8. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21K bytes
    - Viewed (0)
  9. 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 {
    		g.Go(func() (err error) {
    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    			rf, err := disks[index].ReadXL(ctx, bucket, object, readData)
    			if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  10. cmd/erasure-encode_test.go

    	}
    	disks := setup.disks
    	buffer := make([]byte, blockSizeV2, 2*blockSizeV2)
    	content := make([]byte, size)
    
    	for i := range dataDown {
    		disks[i] = OfflineDisk
    	}
    	for i := data; i < data+parityDown; i++ {
    		disks[i] = OfflineDisk
    	}
    
    	b.SetBytes(size)
    	b.ReportAllocs()
    	for b.Loop() {
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
Back to top