Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for cancelList (4.3 sec)

  1. cmd/metacache-server-pool.go

    	var mu sync.Mutex
    	var wg sync.WaitGroup
    	var errs []error
    	allAtEOF := true
    	var inputs []chan metaCacheEntry
    	mu.Lock()
    	// Ask all sets and merge entries.
    	listCtx, cancelList := context.WithCancel(ctx)
    	defer cancelList()
    	for _, pool := range z.serverPools {
    		for _, set := range pool.sets {
    			wg.Add(1)
    			innerResults := make(chan metaCacheEntry, 100)
    			inputs = append(inputs, innerResults)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
Back to top