github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

kubelet: DRA: change key of claimInfo cache to "namespace/claimname"

Browse Source 
Signed-off-by: Kevin Klues <kklues@nvidia.com>
This commit is contained in:
Kevin Klues
2024-04-30 11:34:05 +00:00
parent 639e887631
commit f80be2728e
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/kubelet/cm/dra/claiminfo.go
View File

@@ -39,7 +39,7 @@ type ClaimInfo struct {
prepared bool prepared bool
} }
// claimInfoCache is a cache of processed resource claims keyed by namespace + claim name. // claimInfoCache is a cache of processed resource claims keyed by namespace/claimname.
type claimInfoCache struct { type claimInfoCache struct {
sync.RWMutex sync.RWMutex
state state.CheckpointState state state.CheckpointState
@@ -172,7 +172,7 @@ func newClaimInfoCache(stateDir, checkpointName string) (*claimInfoCache, error)
for _, entry := range curState { for _, entry := range curState {
info := newClaimInfoFromState(&entry) info := newClaimInfoFromState(&entry)
cache.claimInfo[info.ClaimName+info.Namespace] = info cache.claimInfo[info.Namespace+"/"+info.ClaimName] = info
} }
return cache, nil return cache, nil
@@ -194,25 +194,25 @@ func (cache *claimInfoCache) withRLock(f func() error) error {
// add adds a new claim info object into the claim info cache. // add adds a new claim info object into the claim info cache.
func (cache *claimInfoCache) add(info *ClaimInfo) *ClaimInfo { func (cache *claimInfoCache) add(info *ClaimInfo) *ClaimInfo {
cache.claimInfo[info.ClaimName+info.Namespace] = info cache.claimInfo[info.Namespace+"/"+info.ClaimName] = info
return info return info
} }
// contains checks to see if a specific claim info object is already in the cache. // contains checks to see if a specific claim info object is already in the cache.
func (cache *claimInfoCache) contains(claimName, namespace string) bool { func (cache *claimInfoCache) contains(claimName, namespace string) bool {
_, exists := cache.claimInfo[claimName+namespace] _, exists := cache.claimInfo[namespace+"/"+claimName]
return exists return exists
} }
// get gets a specific claim info object from the cache. // get gets a specific claim info object from the cache.
func (cache *claimInfoCache) get(claimName, namespace string) (*ClaimInfo, bool) { func (cache *claimInfoCache) get(claimName, namespace string) (*ClaimInfo, bool) {
info, exists := cache.claimInfo[claimName+namespace] info, exists := cache.claimInfo[namespace+"/"+claimName]
return info, exists return info, exists
} }
// delete deletes a specific claim info object from the cache. // delete deletes a specific claim info object from the cache.
func (cache *claimInfoCache) delete(claimName, namespace string) { func (cache *claimInfoCache) delete(claimName, namespace string) {
delete(cache.claimInfo, claimName+namespace) delete(cache.claimInfo, namespace+"/"+claimName)
} }
// hasPodReference checks if there is at least one claim // hasPodReference checks if there is at least one claim