- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for mergeEntryChannels (0.06 sec)
-
cmd/erasure-server-pool.go
go func() { defer close(errCh) // Merge all entries from all disks. // We leave quorum at 1, since entries are already resolved to have the desired quorum. // mergeEntryChannels will close 'merged' channel upon completion or cancellation. errCh <- mergeEntryChannels(ctx, entries, merged, 1) }() return nil } // HealObjectFn closure function heals the object.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.1K bytes - Viewed (0) -
cmd/xl-storage-format-v2_test.go
for _, v := range vers { v.cached = nil ch := make(chan metaCacheEntry, 1) ch <- v close(ch) entries = append(entries, ch) } out := make(chan metaCacheEntry, 1) err := mergeEntryChannels(t.Context(), entries, out, 1) if err != nil { t.Fatal(err) } got, ok := <-out if !ok { t.Fatal("Got no result") } xl, err := got.xlmeta() if err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 37.8K bytes - Viewed (0)