- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for updateCacheEntry (0.21 sec)
-
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) -
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) -
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) -
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) -
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)