Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for evalDisks (0.05 sec)

  1. cmd/erasure-metadata-utils.go

    func shuffleDisks(disks []StorageAPI, distribution []int) []StorageAPI {
    	return shuffleWithDist[StorageAPI](disks, distribution)
    }
    
    // evalDisks - returns a new slice of disks where nil is set if
    // the corresponding error in errs slice is not nil
    func evalDisks(disks []StorageAPI, errs []error) []StorageAPI {
    	if len(errs) != len(disks) {
    		bugLogIf(GlobalContext, errors.New("unexpected drives/errors slice length"))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  2. cmd/erasure-metadata-utils_test.go

    		shuffledDisks[13] != disks[1] ||
    		shuffledDisks[14] != disks[15] ||
    		shuffledDisks[15] != disks[0] {
    		t.Errorf("shuffleDisks returned incorrect order.")
    	}
    }
    
    // TestEvalDisks tests the behavior of evalDisks
    func TestEvalDisks(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	nDisks := 16
    	disks, err := getRandomDisks(nDisks)
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  3. cmd/erasure-metadata.go

    				}
    				return disks[index].Delete(ctx, bucket, pathJoin(prefix, xlStorageFormatFile), DeleteOptions{
    					Recursive: true,
    				})
    			}, index)
    		}
    		ng.Wait()
    	}
    
    	return evalDisks(disks, mErrs), err
    }
    
    func writeAllMetadata(ctx context.Context, disks []StorageAPI, origbucket, bucket, prefix string, files []FileInfo, quorum int) ([]StorageAPI, error) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.3K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    	if err != nil {
    		er.cleanupMultipartPath(ctx, paths...)
    	}
    
    	// We can safely allow RenameFile errors up to len(er.getDisks()) - writeQuorum
    	// otherwise return failure. Cleanup successful renames.
    	return evalDisks(disks, errs), err
    }
    
    // PutObjectPart - reads incoming stream and internally erasure codes
    // them. This call is similar to single put operation but it is part
    // of the multipart transaction.
    //
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    				break
    			}
    		}
    		dataDir = reduceCommonDataDir(dataDirs, writeQuorum)
    	}
    
    	// We can safely allow RenameData errors up to len(er.getDisks()) - writeQuorum
    	// otherwise return failure.
    	return evalDisks(disks, errs), versions, dataDir, err
    }
    
    func (er erasureObjects) putMetacacheObject(ctx context.Context, key string, r *PutObjReader, opts ObjectOptions) (objInfo ObjectInfo, err error) {
    	data := r.Reader
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
Back to top