Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 362 for disks (0.18 seconds)

  1. cmd/erasure-healing-common.go

    			} else {
    				dataErrsByPart[p][i] = verifyResp.Results[p]
    			}
    		}
    	}
    
    	// Build dataErrs by disk from dataErrs by part
    	for part, disks := range dataErrsByPart {
    		for disk := range disks {
    			dataErrsByDisk[disk][part] = dataErrsByPart[part][disk]
    		}
    	}
    	return dataErrsByDisk, dataErrsByPart
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12K bytes
    - Click Count (0)
  2. 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()
    		}
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  3. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  4. .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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon May 27 19:17:46 GMT 2024
    - 802 bytes
    - Click Count (0)
  5. 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  6. cmd/erasure-object_test.go

    		}
    
    		// Step 3: Upload the object with some disks offline
    		sets.erasureDisksMu.Lock()
    		xl.getDisks = func() []StorageAPI {
    			disks := make([]StorageAPI, len(origErasureDisks))
    			copy(disks, origErasureDisks)
    			disks[0] = nil
    			disks[1] = nil
    			return disks
    		}
    		sets.erasureDisksMu.Unlock()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 38.3K bytes
    - Click Count (0)
  7. 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
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (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
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 21K bytes
    - Click Count (0)
  9. 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)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.1K bytes
    - Click Count (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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
Back to Top