Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for StorageAPI (0.04 sec)

  1. cmd/erasure-multipart-conditional_test.go

    	// With 16 disks (EC 8+8), read quorum is 9. Taking 8 disks offline leaves only 8,
    	// which is below read quorum.
    	erasureDisks := xl.getDisks()
    	z.serverPools[0].erasureDisksMu.Lock()
    	xl.getDisks = func() []StorageAPI {
    		for i := range erasureDisks[:8] {
    			erasureDisks[i] = nil
    		}
    		return erasureDisks
    	}
    	z.serverPools[0].erasureDisksMu.Unlock()
    
    	t.Run("if-none-match with read quorum failure", func(t *testing.T) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 6.9K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    	return objInfo, wquorum, nil
    }
    
    // Similar to rename but renames data from srcEntry to dstEntry at dataDir
    func renameData(ctx context.Context, disks []StorageAPI, srcBucket, srcEntry string, metadata []FileInfo, dstBucket, dstEntry string, writeQuorum int) ([]StorageAPI, []byte, string, error) {
    	g := errgroup.WithNErrs(len(disks))
    
    	fvID := mustGetUUID()
    	for index := range disks {
    		metadata[index].SetTierFreeVersionID(fvID)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    			continue
    		}
    		wg.Add(1)
    		go func(disk StorageAPI) {
    			defer wg.Done()
    			disk.Delete(ctx, bucket, prefix, DeleteOptions{
    				Recursive: true,
    				Immediate: false,
    			})
    		}(disk)
    	}
    	wg.Wait()
    }
    
    // Remove the old multipart uploads on the given disk.
    func (er erasureObjects) cleanupStaleUploadsOnDisk(ctx context.Context, disk StorageAPI) {
    	drivePath := disk.Endpoint().Path
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 47.1K bytes
    - Viewed (0)
  4. cmd/erasure-object-conditional_test.go

    	// With 16 disks (EC 8+8), read quorum is 9. Taking 8 disks offline leaves only 8,
    	// which is below read quorum.
    	erasureDisks := xl.getDisks()
    	z.serverPools[0].erasureDisksMu.Lock()
    	xl.getDisks = func() []StorageAPI {
    		for i := range erasureDisks[:8] {
    			erasureDisks[i] = nil
    		}
    		return erasureDisks
    	}
    	z.serverPools[0].erasureDisksMu.Unlock()
    
    	t.Run("if-none-match with read quorum failure", func(t *testing.T) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 4.9K bytes
    - Viewed (0)
Back to top