- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for mergeEntryChannels (0.08 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/metacache-entries.go
if serverDebugLog { console.Debugln("mergeEntryChannels: discarding directory", other.name, "for object", best.name) } // Discard the directory. if err := selectFrom(otherIdx); err != nil { return err } continue } // Replace directory with object. if serverDebugLog { console.Debugln("mergeEntryChannels: discarding directory", best.name, "for object", other.name)Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 08 15:29:58 GMT 2024 - 24.1K bytes - Click Count (0) -
cmd/metacache-server-pool.go
errs[i] = err }(len(errs), set) errs = append(errs, nil) } } mu.Unlock() // Gather results to a single channel. // Quorum is one since we are merging across sets. err := mergeEntryChannels(ctx, inputs, results, 1) cancelList() wg.Wait() // we should return 'errs' from per disk if isAllNotFound(errs) { if isAllVolumeNotFound(errs) { return errVolumeNotFound }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12.9K bytes - Click Count (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 {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 37.8K bytes - Click Count (0)