Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for metacache (0.12 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-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)
  5. 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)
  6. cmd/metacache-server-pool.go

    	"time"
    
    	"github.com/minio/minio/internal/grid"
    	xioutil "github.com/minio/minio/internal/ioutil"
    )
    
    func renameAllBucketMetacache(epPath string) error {
    	// Rename all previous `.minio.sys/buckets/<bucketname>/.metacache` to
    	// to `.minio.sys/tmp/` for deletion.
    	return readDirFn(pathJoin(epPath, minioMetaBucket, bucketMetaPrefix), func(name string, typ os.FileMode) error {
    		if typ == os.ModeDir {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  7. cmd/peer-rest-client.go

    // GetMetacacheListing - get a new or existing metacache.
    func (client *peerRESTClient) GetMetacacheListing(ctx context.Context, o listPathOptions) (*metacache, error) {
    	if client == nil {
    		resp := localMetacacheMgr.getBucket(ctx, o.Bucket).findCache(o)
    		return &resp, nil
    	}
    	return getMetacacheListingRPC.Call(ctx, client.gridConn(), &o)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  8. cmd/peer-rest-server.go

    	updateMetacacheListingRPC      = grid.NewSingleHandler[*metacache, *metacache](grid.HandlerUpdateMetacacheListing, func() *metacache { return &metacache{} }, func() *metacache { return &metacache{} })
    	cleanupUploadIDCacheMetaRPC    = grid.NewSingleHandler[*grid.MSS, grid.NoPayload](grid.HandlerClearUploadID, grid.NewMSS, grid.NewNoPayload)
    
    	// STREAMS
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  9. cmd/mrf.go

    			return
    		case u, ok := <-m.opCh:
    			if !ok {
    				return
    			}
    
    			// We might land at .metacache, .trash, .multipart
    			// no need to heal them skip, only when bucket
    			// is '.minio.sys'
    			if u.Bucket == minioMetaBucket {
    				// No MRF needed for temporary objects
    				if wildcard.Match("buckets/*/.metacache/*", u.Object) {
    					continue
    				}
    				if wildcard.Match("tmp/*", u.Object) {
    					continue
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  10. cmd/global-heal.go

    			}
    			if entry.isDir() {
    				// ignore healing entry.name's with `/` suffix.
    				return
    			}
    
    			// We might land at .metacache, .trash, .multipart
    			// no need to heal them skip, only when bucket
    			// is '.minio.sys'
    			if bucket == minioMetaBucket {
    				if wildcard.Match("buckets/*/.metacache/*", entry.name) {
    					return
    				}
    				if wildcard.Match("tmp/.trash/*", entry.name) {
    					return
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
Back to top