github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-22 19:31:44 +00:00
Code Issues Projects Releases Wiki Activity

Perform dead storage removal linearly

Browse Source
This commit is contained in:
Ted Yu 2020-01-03 08:05:21 -08:00
parent 9f841bf423
commit 9bc862ec69
1 changed files with 9 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go
View File

@ -526,29 +526,21 @@ func (r *crdHandler) removeDeadStorage() {
r.customStorageLock.Lock()
defer r.customStorageLock.Unlock()
oldInfos := []*crdInfo{}
storageMap := r.customStorage.Load().(crdStorageMap)
// Copy because we cannot write to storageMap without a race
// as it is used without locking elsewhere
storageMap2 := storageMap.clone()
for uid, s := range storageMap2 {
found := false
for _, crd := range allCustomResourceDefinitions {
if crd.UID == uid {
found = true
break
}
}
if !found {
klog.V(4).Infof("Removing dead CRD storage for %s/%s", s.spec.Group, s.spec.Names.Kind)
oldInfos = append(oldInfos, s)
delete(storageMap2, uid)
storageMap2 := make(crdStorageMap)
for _, crd := range allCustomResourceDefinitions {
if _, ok := storageMap[crd.UID]; ok {
storageMap2[crd.UID] = storageMap[crd.UID]
}
}
r.customStorage.Store(storageMap2)
for _, s := range oldInfos {
go r.tearDown(s)
for uid, crdInfo := range storageMap {
if _, ok := storageMap2[uid]; !ok {
klog.V(4).Infof("Removing dead CRD storage for %s/%s", crdInfo.spec.Group, crdInfo.spec.Names.Kind)
go r.tearDown(crdInfo)
}
}
}