Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for mergeEntryChannels (0.28 sec)

  1. 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)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 04:34:26 UTC 2024
    - 24K bytes
    - Viewed (0)
  2. 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
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 23 01:12:23 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    		}
    	}()
    	go func() {
    		// 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.
    		storageLogIf(ctx, mergeEntryChannels(ctx, entries, merged, 1))
    	}()
    
    	return nil
    }
    
    // HealObjectFn closure function heals the object.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 30 11:58:12 UTC 2024
    - 82.5K bytes
    - Viewed (0)
  4. 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(context.Background(), entries, out, 1)
    		if err != nil {
    			t.Fatal(err)
    		}
    		got, ok := <-out
    		if !ok {
    			t.Fatal("Got no result")
    		}
    
    		xl, err := got.xlmeta()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 36.4K bytes
    - Viewed (0)
Back to top