Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for GetMetacacheListing (0.16 sec)

  1. cmd/metacache-server-pool.go

    		var c *metacache
    		if rpc == nil {
    			resp := localMetacacheMgr.getBucket(ctx, o.Bucket).findCache(*o)
    			c = &resp
    		} else {
    			rctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    			c, err = rpc.GetMetacacheListing(rctx, *o)
    			cancel()
    		}
    		if err != nil {
    			if errors.Is(err, context.Canceled) {
    				// Context is canceled, return at once.
    				// request canceled, no entries to return
    				return entries, io.EOF
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. cmd/metacache-manager.go

    // Should only be called if a failure occurred.
    func (o listPathOptions) checkMetacacheState(ctx context.Context, rpc *peerRESTClient) error {
    	// We operate on a copy...
    	o.Create = false
    	c, err := rpc.GetMetacacheListing(ctx, o)
    	if err != nil {
    		return err
    	}
    	cache := *c
    
    	if cache.status == scanStateNone || cache.fileNotFound {
    		return errFileNotFound
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  3. cmd/peer-rest-client.go

    	resp, err := getBackgroundHealStatusRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	return resp.ValueOrZero(), err
    }
    
    // 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
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
Back to top