Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for firstFound (0.27 sec)

  1. cmd/metacache-entries.go

    	if err != nil {
    		bugLogIf(context.Background(), err)
    		return nil, false
    	}
    	return selected, true
    }
    
    // firstFound returns the first found and the number of set entries.
    func (m metaCacheEntries) firstFound() (first *metaCacheEntry, n int) {
    	for i, entry := range m {
    		if entry.name != "" {
    			n++
    			if first == nil {
    				first = &m[i]
    			}
    		}
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    				entry, ok := entries.resolve(&resolver)
    				if !ok {
    					// check if we can get one entry at least
    					// proceed to heal nonetheless.
    					entry, _ = entries.firstFound()
    				}
    				jt.Take()
    				go healEntry(bucket, *entry)
    			},
    			finished: nil,
    		})
    		jt.Wait() // synchronize all the concurrent heal jobs
    		xioutil.SafeClose(results)
    		if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  3. cmd/erasure-healing.go

    		},
    		partial: func(entries metaCacheEntries, _ []error) {
    			entry, ok := entries.resolve(&resolver)
    			if !ok {
    				// check if we can get one entry at least
    				// proceed to heal nonetheless.
    				entry, _ = entries.firstFound()
    			}
    
    			if err := healEntry(bucket, *entry, scanMode); err != nil {
    				cancel()
    				return
    			}
    		},
    		finished: nil,
    	}
    
    	if err := listPathRaw(ctx, lopts); err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  4. cmd/data-scanner.go

    					entry, ok := entries.resolve(&resolver)
    					if !ok {
    						// check if we can get one entry at least
    						// proceed to heal nonetheless, since
    						// this object might be dangling.
    						entry, _ = entries.firstFound()
    					}
    					wait := noWait
    					if f.weSleep() {
    						// wait timer per object.
    						wait = scannerSleeper.Timer(ctx)
    					}
    					defer wait()
    					f.updateCurrentPath(entry.name)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 47.4K bytes
    - Viewed (0)
Back to top