- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 323 for disks (0.02 sec)
-
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) -
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) -
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) -
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) -
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) -
.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) -
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) -
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) -
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) -
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)