Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for findCache (0.24 sec)

  1. cmd/metacache-bucket.go

    		console.Debugf(format+"\n", data...)
    	}
    }
    
    // findCache will attempt to find a matching cache for the provided options.
    // If a cache with the same ID exists already it will be returned.
    // If none can be found a new is created with the provided ID.
    func (b *bucketMetacache) findCache(o listPathOptions) metacache {
    	if b == nil {
    		logger.Info("bucketMetacache.findCache: nil cache for bucket %s", o.Bucket)
    		return metacache{}
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6.6K bytes
    - Viewed (0)
  2. cmd/metacache-bucket_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"fmt"
    	"testing"
    )
    
    func Benchmark_bucketMetacache_findCache(b *testing.B) {
    	bm := newBucketMetacache("", false)
    	const elements = 50000
    	const paths = 100
    	if elements%paths != 0 {
    		b.Fatal("elements must be divisible by the number of paths")
    	}
    	var pathNames [paths]string
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 25 23:29:45 GMT 2022
    - 1.8K bytes
    - Viewed (0)
  3. cmd/metacache-server-pool.go

    		// Create or ping with handout...
    		rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix))
    		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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  4. cmd/peer-rest-client.go

    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)
    }
    
    // UpdateMetacacheListing - update an existing metacache it will unconditionally be updated to the new state.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  5. cmd/peer-rest-server.go

    	}
    
    	return
    }
    
    func (s *peerRESTServer) GetMetacacheListingHandler(opts *listPathOptions) (*metacache, *grid.RemoteErr) {
    	resp := localMetacacheMgr.getBucket(context.Background(), opts.Bucket).findCache(*opts)
    	return &resp, nil
    }
    
    func (s *peerRESTServer) UpdateMetacacheListingHandler(req *metacache) (*metacache, *grid.RemoteErr) {
    	cache, err := localMetacacheMgr.updateCacheEntry(*req)
    	if err != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
Back to top