Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for updateCacheEntry (0.21 sec)

  1. cmd/metacache-manager.go

    			}
    			m.mu.Unlock()
    		}
    	}()
    }
    
    // updateCacheEntry will update non-transient state.
    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)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  2. 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
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  3. 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
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  4. cmd/metacache-set.go

    }
    
    // updateMetacacheListing will update the metacache listing.
    func (o *listPathOptions) updateMetacacheListing(m metacache, rpc *peerRESTClient) (metacache, error) {
    	if rpc == nil {
    		return localMetacacheMgr.updateCacheEntry(m)
    	}
    	return rpc.UpdateMetacacheListing(context.Background(), m)
    }
    
    func getMetacacheBlockInfo(fi FileInfo, block int) (*metacacheBlock, error) {
    	var tmp metacacheBlock
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  5. 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
Back to top