Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 37 for metacache (0.07 sec)

  1. cmd/metacache-bucket.go

    func (b *bucketMetacache) findCache(o listPathOptions) metacache {
    	if b == nil {
    		logger.Info("bucketMetacache.findCache: nil cache for bucket %s", o.Bucket)
    		return metacache{}
    	}
    
    	if o.Bucket != b.bucket {
    		logger.Info("bucketMetacache.findCache: bucket %s does not match this bucket %s", o.Bucket, b.bucket)
    		debug.PrintStack()
    		return metacache{}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  2. cmd/metacache.go

    }
    
    // delete all cache data on disks.
    func (m *metacache) delete(ctx context.Context) {
    	if m.bucket == "" || m.id == "" {
    		bugLogIf(ctx, fmt.Errorf("metacache.delete: bucket (%s) or id (%s) empty", m.bucket, m.id))
    		return
    	}
    	objAPI := newObjectLayerFn()
    	if objAPI == nil {
    		internalLogIf(ctx, errors.New("metacache.delete: no object layer"))
    		return
    	}
    	ez, ok := objAPI.(deleteAllStorager)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. cmd/metacache-walk.go

    		if s.walkMu != nil {
    			s.walkMu.Unlock()
    		}
    		if err != nil {
    			// Folder could have gone away in-between
    			if err != errVolumeNotFound && err != errFileNotFound {
    				internalLogOnceIf(ctx, err, "metacache-walk-scan-dir")
    			}
    			if opts.ReportNotFound && err == errFileNotFound && current == opts.BaseDir {
    				err = errFileNotFound
    			} else {
    				err = nil
    			}
    			diskHealthCheckOK(ctx, err)
    			return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 01 05:17:37 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  4. cmd/metacache-stream.go

    //
    // Streams can be assumed to be sorted in ascending order.
    // If the stream ends before a false boolean it can be assumed it was truncated.
    
    const metacacheStreamVersion = 2
    
    // metacacheWriter provides a serializer of metacache objects.
    type metacacheWriter struct {
    	streamErr   error
    	mw          *msgp.Writer
    	creator     func() error
    	closer      func() error
    	blockSize   int
    	streamWg    sync.WaitGroup
    	reuseBlocks bool
    }
    
    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/metacache-entries.go

    					Mode:   uint32(os.ModeDir),
    				},
    			},
    		}, 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  6. cmd/metacache-manager.go

    func (m *metacacheManager) updateCacheEntry(update metacache) (metacache, error) {
    	m.mu.RLock()
    	if meta, ok := m.trash[update.id]; ok {
    		m.mu.RUnlock()
    		return meta, nil
    	}
    
    	b, ok := m.buckets[update.bucket]
    	m.mu.RUnlock()
    	if ok {
    		return b.updateCacheEntry(update)
    	}
    
    	// We should have either a trashed bucket or this
    	return metacache{}, errVolumeNotFound
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  7. cmd/metacache-set.go

    	o.Versioning = vc
    	o.Replication = replicationConfig{
    		Config:  replCfg,
    		remotes: tgts,
    	}
    	o.Retention = rcfg
    }
    
    // newMetacache constructs a new metacache from the options.
    func (o listPathOptions) newMetacache() metacache {
    	return metacache{
    		id:          o.ID,
    		bucket:      o.Bucket,
    		root:        o.BaseDir,
    		recursive:   o.Recursive,
    		status:      scanStateStarted,
    		error:       "",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  8. cmd/metacache-entries_test.go

    Harshavardhana <******@****.***> 1641143706 -0800
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 31.6K bytes
    - Viewed (0)
  9. cmd/metacache-stream_test.go

    func loadMetacacheSample(t testing.TB) *metacacheReader {
    	b, err := os.ReadFile("testdata/metacache.s2")
    	if err != nil {
    		t.Fatal(err)
    	}
    	return newMetacacheReader(bytes.NewReader(b))
    }
    
    func loadMetacacheSampleEntries(t testing.TB) metaCacheEntriesSorted {
    	r := loadMetacacheSample(t)
    	defer r.Close()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 15K bytes
    - Viewed (0)
  10. cmd/metacache-bucket_test.go

    Harshavardhana <******@****.***> 1648250985 -0700
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 25 23:29:45 UTC 2022
    - 1.8K bytes
    - Viewed (0)
Back to top