- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for StorageAPI (0.04 sec)
-
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) -
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) -
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) -
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)