Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for mergeEntryChannels (0.06 sec)

  1. 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)
  2. 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)
Back to top