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

Merge pull request #76256 from tedyu/master

Browse Source 
Use RWMutex for accessing scheduler factory obj
This commit is contained in:
Kubernetes Prow Robot 2019-04-10 22:42:08 -07:00 committed by GitHub
commit 98cf84ff86
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
pkg/scheduler/factory/plugins.go
View File

@ -245,8 +245,8 @@ func RegisterCustomFitPredicate(policy schedulerapi.PredicatePolicy) string {
// IsFitPredicateRegistered is useful for testing providers. // IsFitPredicateRegistered is useful for testing providers.
func IsFitPredicateRegistered(name string) bool { func IsFitPredicateRegistered(name string) bool {
schedulerFactoryMutex.Lock() schedulerFactoryMutex.RLock()
defer schedulerFactoryMutex.Unlock() defer schedulerFactoryMutex.RUnlock()
_, ok := fitPredicateMap[name] _, ok := fitPredicateMap[name]
return ok return ok
} }
@ -408,8 +408,8 @@ func GetAlgorithmProvider(name string) (*AlgorithmProviderConfig, error) {
} }
func getFitPredicateFunctions(names sets.String, args PluginFactoryArgs) (map[string]predicates.FitPredicate, error) { func getFitPredicateFunctions(names sets.String, args PluginFactoryArgs) (map[string]predicates.FitPredicate, error) {
schedulerFactoryMutex.Lock() schedulerFactoryMutex.RLock()
defer schedulerFactoryMutex.Unlock() defer schedulerFactoryMutex.RUnlock()
fitPredicates := map[string]predicates.FitPredicate{} fitPredicates := map[string]predicates.FitPredicate{}
for _, name := range names.List() { for _, name := range names.List() {
@ -451,8 +451,8 @@ func getPredicateMetadataProducer(args PluginFactoryArgs) (predicates.PredicateM
} }
func getPriorityFunctionConfigs(names sets.String, args PluginFactoryArgs) ([]priorities.PriorityConfig, error) { func getPriorityFunctionConfigs(names sets.String, args PluginFactoryArgs) ([]priorities.PriorityConfig, error) {
schedulerFactoryMutex.Lock() schedulerFactoryMutex.RLock()
defer schedulerFactoryMutex.Unlock() defer schedulerFactoryMutex.RUnlock()
var configs []priorities.PriorityConfig var configs []priorities.PriorityConfig
for _, name := range names.List() { for _, name := range names.List() {
@ -538,8 +538,8 @@ func validatePriorityOrDie(priority schedulerapi.PriorityPolicy) {
// ListRegisteredFitPredicates returns the registered fit predicates. // ListRegisteredFitPredicates returns the registered fit predicates.
func ListRegisteredFitPredicates() []string { func ListRegisteredFitPredicates() []string {
schedulerFactoryMutex.Lock() schedulerFactoryMutex.RLock()
defer schedulerFactoryMutex.Unlock() defer schedulerFactoryMutex.RUnlock()
var names []string var names []string
for name := range fitPredicateMap { for name := range fitPredicateMap {
@ -550,8 +550,8 @@ func ListRegisteredFitPredicates() []string {
// ListRegisteredPriorityFunctions returns the registered priority functions. // ListRegisteredPriorityFunctions returns the registered priority functions.
func ListRegisteredPriorityFunctions() []string { func ListRegisteredPriorityFunctions() []string {
schedulerFactoryMutex.Lock() schedulerFactoryMutex.RLock()
defer schedulerFactoryMutex.Unlock() defer schedulerFactoryMutex.RUnlock()
var names []string var names []string
for name := range priorityFunctionMap { for name := range priorityFunctionMap {