github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-20 01:01:22 +00:00
Code Issues Projects Releases Wiki Activity

Use RWLock for the controller cache

Browse Source 
It could help a tiny bit with parallel operations.
This commit is contained in:
Jan Safranek 2024-11-05 12:38:08 +01:00
parent e6807a8e4f
commit 6eab8a8691
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/controller/volume/selinuxwarning/cache/volumecache.go vendored
View File

@ -47,7 +47,7 @@ type VolumeCache interface {
// VolumeCache stores all volumes used by Pods and their properties that the controller needs to track, // VolumeCache stores all volumes used by Pods and their properties that the controller needs to track,
// like SELinux labels and SELinuxChangePolicies. // like SELinux labels and SELinuxChangePolicies.
type volumeCache struct { type volumeCache struct {
mutex sync.Mutex mutex sync.RWMutex
// All volumes of all existing Pods. // All volumes of all existing Pods.
volumes map[v1.UniqueVolumeName]usedVolume volumes map[v1.UniqueVolumeName]usedVolume
} }
@ -204,8 +204,8 @@ func (c *volumeCache) dump(logger klog.Logger) {
// GetPodsForCSIDriver returns all pods that use volumes with the given CSI driver. // GetPodsForCSIDriver returns all pods that use volumes with the given CSI driver.
func (c *volumeCache) GetPodsForCSIDriver(driverName string) []cache.ObjectName { func (c *volumeCache) GetPodsForCSIDriver(driverName string) []cache.ObjectName {
c.mutex.Lock() c.mutex.RLock()
defer c.mutex.Unlock() defer c.mutex.RUnlock()
var pods []cache.ObjectName var pods []cache.ObjectName
for _, volume := range c.volumes { for _, volume := range c.volumes {
@ -221,8 +221,8 @@ func (c *volumeCache) GetPodsForCSIDriver(driverName string) []cache.ObjectName
// SendConflicts sends all current conflicts to the given channel. // SendConflicts sends all current conflicts to the given channel.
func (c *volumeCache) SendConflicts(logger klog.Logger, ch chan<- Conflict) { func (c *volumeCache) SendConflicts(logger klog.Logger, ch chan<- Conflict) {
c.mutex.Lock() c.mutex.RLock()
defer c.mutex.Unlock() defer c.mutex.RUnlock()
logger.V(4).Info("Scraping conflicts") logger.V(4).Info("Scraping conflicts")
c.dump(logger) c.dump(logger)