Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 78 for Entries (0.04 seconds)

  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
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 08 15:29:58 GMT 2024
    - 24.1K bytes
    - Click Count (0)
  2. 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) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 15K bytes
    - Click Count (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) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 30.7K bytes
    - Click Count (0)
  4. internal/lru/lru.go

    const numBuckets = 100
    
    // NewLRU returns a new thread-safe cache with expirable entries.
    //
    // Size parameter set to 0 makes cache of unlimited size, e.g. turns LRU mechanism off.
    //
    // Providing 0 TTL turns expiring off.
    //
    // Delete expired entries every 1/100th of ttl value. Goroutine which deletes expired entries runs indefinitely.
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 12.5K bytes
    - Click Count (0)
  5. 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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  6. internal/logger/target/http/http.go

    				name,
    			)
    
    			time.Sleep(retryIntvl)
    			if maxRetries == 0 {
    				goto retry
    			}
    			retries++
    			if retries <= maxRetries {
    				goto retry
    			}
    		}
    
    		entries = make([]any, 0)
    		count = 0
    		if !isDirQueue {
    			buf.Reset()
    		}
    
    		if !mainWorker && len(h.logCh) < cap(h.logCh)/2 {
    			if time.Since(h.lastStarted).Seconds() > 30 {
    				return
    			}
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  7. 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)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 31.6K bytes
    - Click Count (0)
  8. 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)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37.8K bytes
    - Click Count (0)
  9. tests/joins_test.go

    	home := &Building{Name: "relation_empty"}
    	DB.Create(home)
    
    	var entries []Building
    	assert.NotPanics(t, func() {
    		assert.NoError(t,
    			DB.Preload("Owner.Furnitures").
    				Joins("Owner.Company").
    				Find(&entries).Error)
    	})
    
    	AssertEqual(t, entries, []Building{{Model: home.Model, Name: "relation_empty", Owner: Owner{Company: Company{}}}})
    }
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun May 25 07:40:40 GMT 2025
    - 15K bytes
    - Click Count (0)
  10. 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
    				}
    			}
    		}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon May 26 07:06:43 GMT 2025
    - 12.6K bytes
    - Click Count (0)
Back to Top