Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for metaCacheEntries (0.2 sec)

  1. cmd/metacache-entries_test.go

    		}
    		inputSerialized[i] = entry
    	}
    
    	tests := []struct {
    		name         string
    		m            metaCacheEntries
    		r            metadataResolutionParams
    		wantSelected *metaCacheEntry
    		wantOk       bool
    	}{
    		{
    			name:         "consistent",
    			m:            metaCacheEntries{inputSerialized[0], inputSerialized[0], inputSerialized[0], inputSerialized[0]},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 31.6K bytes
    - Viewed (0)
  2. cmd/metacache-entries.go

    			},
    		}, nil
    	}
    	// Too small gains to reuse cache here.
    	return getFileInfoVersions(e.metadata, bucket, e.name, true)
    }
    
    // metaCacheEntries is a slice of metacache entries.
    type metaCacheEntries []metaCacheEntry
    
    // less function for sorting.
    func (m metaCacheEntries) less(i, j int) bool {
    	return m[i].name < m[j].name
    }
    
    // sort entries by name.
    // m is sorted and a sorted metadata object is returned.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  3. cmd/metacache-set.go

    		if err != nil {
    			return entries, err
    		}
    	}
    	o.debugln("forwarded to ", o.Prefix, "marker:", o.Marker, "sep:", o.Separator)
    
    	// Filter
    	if !o.Recursive {
    		entries.o = make(metaCacheEntries, 0, o.Limit)
    		pastPrefix := false
    		err := r.readFn(func(entry metaCacheEntry) bool {
    			if o.Prefix != "" && !strings.HasPrefix(entry.name, o.Prefix) {
    				// We are past the prefix, don't continue.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  4. cmd/metacache-stream.go

    	r.checkInit()
    	if n == 0 {
    		return metaCacheEntriesSorted{}, nil
    	}
    	if r.err != nil {
    		return metaCacheEntriesSorted{}, r.err
    	}
    
    	var res metaCacheEntries
    	if n > 0 {
    		res = make(metaCacheEntries, 0, n)
    	}
    	if prefix != "" {
    		if err := r.forwardTo(prefix); err != nil {
    			return metaCacheEntriesSorted{}, err
    		}
    	}
    	next, err := r.peek()
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  5. cmd/global-heal.go

    			forwardTo:      forwardTo,
    			minDisks:       1,
    			reportNotFound: false,
    			agreed: func(entry metaCacheEntry) {
    				jt.Take()
    				go healEntry(bucket, entry)
    			},
    			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()
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-rebalance.go

    		disks:          disks,
    		bucket:         bucketName,
    		recursive:      true,
    		forwardTo:      "",
    		minDisks:       listingQuorum,
    		reportNotFound: false,
    		agreed:         fn,
    		partial: func(entries metaCacheEntries, _ []error) {
    			entry, ok := entries.resolve(&resolver)
    			if ok {
    				fn(*entry)
    			}
    		},
    		finished: nil,
    	})
    	return err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  7. cmd/erasure-healing.go

    		minDisks:       1,
    		reportNotFound: false,
    		agreed: func(entry metaCacheEntry) {
    			if err := healEntry(bucket, entry, scanMode); err != nil {
    				cancel()
    			}
    		},
    		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()
    			}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-decom.go

    		bucket:         bi.Name,
    		path:           bi.Prefix,
    		recursive:      true,
    		forwardTo:      "",
    		minDisks:       listingQuorum,
    		reportNotFound: false,
    		agreed:         fn,
    		partial: func(entries metaCacheEntries, _ []error) {
    			entry, ok := entries.resolve(&resolver)
    			if ok {
    				fn(*entry)
    			}
    		},
    		finished: nil,
    	})
    	return err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  9. cmd/data-scanner.go

    					if f.dataUsageScannerDebug {
    						console.Debugf(healObjectsPrefix+" got agreement: %v\n", entry.name)
    					}
    				},
    				// Some disks have data for this.
    				partial: func(entries metaCacheEntries, errs []error) {
    					if !f.shouldHeal() {
    						cancel()
    						return
    					}
    					entry, ok := entries.resolve(&resolver)
    					if !ok {
    						// check if we can get one entry at least
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool.go

    					forwardTo:      opts.Marker,
    					perDiskLimit:   opts.Limit,
    					minDisks:       listingQuorum,
    					reportNotFound: false,
    					agreed:         send,
    					partial: func(entries metaCacheEntries, _ []error) {
    						entry, ok := entries.resolve(&resolver)
    						if ok {
    							send(*entry)
    						}
    					},
    					finished: nil,
    				}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top