Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 133 for entries (0.26 sec)

  1. cmd/metacache-entries.go

    	// Reusable slice for resolution
    	candidates [][]xlMetaV2ShallowVersion
    }
    
    // resolve multiple entries.
    // entries are resolved by majority, then if tied by mod-time and versions.
    // Names must match on all entries in m.
    func (m metaCacheEntries) resolve(r *metadataResolutionParams) (selected *metaCacheEntry, ok bool) {
    	if len(m) == 0 {
    		return nil, false
    	}
    
    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/metacache-entries_test.go

    	entries.forwardTo("src/compress/zlib/reader_test.go")
    	got := entries.entries().names()
    	if !reflect.DeepEqual(got, want) {
    		t.Errorf("got unexpected result: %#v", got)
    	}
    
    	// Try with prefix
    	entries = org
    	entries.forwardTo("src/compress/zlib/reader_t")
    	got = entries.entries().names()
    	if !reflect.DeepEqual(got, want) {
    		t.Errorf("got unexpected result: %#v", got)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 31.6K bytes
    - Viewed (0)
  3. cmd/metacache-set.go

    			pr.CloseWithError(err)
    			tmp.Close()
    			entries.o = append(entries.o, e.o...)
    			if o.Limit > 0 && entries.len() > o.Limit {
    				entries.truncate(o.Limit)
    				return entries, nil
    			}
    			if err == nil {
    				// We stopped within the listing, we are done for now...
    				return entries, nil
    			}
    			if err != nil && !errors.Is(err, io.EOF) {
    				switch toObjectErr(err, minioMetaBucket, o.objectPath(partN)).(type) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:52:52 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  4. cmd/os_other.go

    			if fi.IsDir() {
    				// Append SlashSeparator instead of "\" so that sorting is achieved as expected.
    				entries = append(entries, fi.Name()+SlashSeparator)
    			} else if fi.Mode().IsRegular() {
    				entries = append(entries, fi.Name())
    			}
    			if opts.count > 0 {
    				remaining--
    			}
    		}
    	}
    	return entries, nil
    }
    
    func globalSync() {
    	// no-op not sure about plan9/solaris support for syscall support
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Sep 13 15:14:36 GMT 2023
    - 4K bytes
    - Viewed (0)
  5. cmd/metacache-walk.go

    		// Process in sort order.
    		sort.Strings(entries)
    		dirStack := make([]string, 0, 5)
    		prefix = "" // Remove prefix after first level as we have already filtered the list.
    		if len(forward) > 0 {
    			// Conservative forwarding. Entries may be either objects or prefixes.
    			for i, entry := range entries {
    				if entry >= forward || strings.HasPrefix(forward, entry) {
    					entries = entries[i:]
    					break
    				}
    			}
    		}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  6. cmd/metacache-stream_test.go

    	entries, err = r.readN(0, false, false, false, "")
    	if err != nil {
    		t.Fatal(err, entries.len())
    	}
    	if entries.len() != len(want) {
    		t.Fatal("unexpected length:", entries.len(), "want:", len(want))
    	}
    
    	entries, err = r.readN(5, false, false, false, "")
    	if err != nil {
    		t.Fatal(err, entries.len())
    	}
    	want = noDirs[:5]
    	if entries.len() != len(want) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 15K bytes
    - Viewed (0)
  7. cmd/bucket-replication-utils_gen.go

    			var zb0002 uint32
    			zb0002, err = dc.ReadMapHeader()
    			if err != nil {
    				err = msgp.WrapError(err, "Entries")
    				return
    			}
    			if z.Entries == nil {
    				z.Entries = make(map[string]MRFReplicateEntry, zb0002)
    			} else if len(z.Entries) > 0 {
    				for key := range z.Entries {
    					delete(z.Entries, key)
    				}
    			}
    			for zb0002 > 0 {
    				zb0002--
    				var za0001 string
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 61.1K bytes
    - Viewed (0)
  8. cmd/metacache-server-pool.go

    	}(*o)
    
    	entries, err = filteredResults()
    	cancelList()
    	wg.Wait()
    	if listErr != nil && !errors.Is(listErr, context.Canceled) {
    		return entries, listErr
    	}
    	entries.reuse = true
    	truncated := entries.len() > o.Limit || err == nil
    	entries.truncate(o.Limit)
    	if !o.Transient && truncated {
    		if o.ID == "" {
    			entries.listID = mustGetUUID()
    		} else {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  9. cmd/xl-storage-format-v2_test.go

    		t.Fatal("Data was not removed:", xl2.data.find(fi.VersionID))
    	}
    	if xl2.data.entries() != 1 {
    		t.Fatal("want 1 entry, got", xl2.data.entries())
    	}
    	// Re-add
    	xl2.data.replace(fi.VersionID, fi.Data)
    	failOnErr(xl2.data.validate())
    	if xl2.data.entries() != 2 {
    		t.Fatal("want 2 entries, got", xl2.data.entries())
    	}
    
    	// Replace entry
    	xl2.data.replace("756100c6-b393-4981-928a-d49bbc164741", data2)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 36.4K bytes
    - Viewed (0)
  10. internal/store/queuestore.go

    	store.RLock()
    	l := make([]string, 0, len(store.entries))
    	for k := range store.entries {
    		l = append(l, k)
    	}
    
    	// Sort entries...
    	sort.Slice(l, func(i, j int) bool {
    		return store.entries[l[i]] < store.entries[l[j]]
    	})
    	store.RUnlock()
    
    	return l, nil
    }
    
    // list will read all entries from disk.
    // Entries are returned sorted by modtime, oldest first.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 7.1K bytes
    - Viewed (0)
Back to top