Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 3 of 3 for updateCacheEntry (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/metacache-bucket.go

    					remove[cache.id] = struct{}{}
    				}
    			}
    		}
    	}
    
    	for id := range remove {
    		b.deleteCache(id)
    	}
    }
    
    // updateCacheEntry will update a cache.
    // Returns the updated status.
    func (b *bucketMetacache) updateCacheEntry(update metacache) (metacache, error) {
    	b.mu.Lock()
    	defer b.mu.Unlock()
    	existing, ok := b.caches[update.id]
    	if !ok {
    		return update, errFileNotFound
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  2. cmd/peer-rest-client.go

    func (client *peerRESTClient) UpdateMetacacheListing(ctx context.Context, m metacache) (metacache, error) {
    	if client == nil {
    		return localMetacacheMgr.updateCacheEntry(m)
    	}
    	resp, err := updateMetacacheListingRPC.Call(ctx, client.gridConn(), &m)
    	if err != nil || resp == nil {
    		return metacache{}, err
    	}
    	return *resp, nil
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  3. cmd/peer-rest-server.go

    	return &resp, nil
    }
    
    func (s *peerRESTServer) UpdateMetacacheListingHandler(req *metacache) (*metacache, *grid.RemoteErr) {
    	cache, err := localMetacacheMgr.updateCacheEntry(*req)
    	if err != nil {
    		return nil, grid.NewRemoteErr(err)
    	}
    	return &cache, nil
    }
    
    // PutBucketNotificationHandler - Set bucket policy.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
Back to Top