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

cleanup duplicate assignment logic in scheduler

Browse Source
This commit is contained in:
Wei Huang
2018-09-20 00:13:50 -07:00
parent 0787715978
commit 56fcfc5fee
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/scheduler/factory/factory.go
View File

@@ -176,6 +176,7 @@ func NewConfigFactory(args *ConfigFactoryArgs) scheduler.Configurator {
client: args.Client, client: args.Client,
podLister: schedulerCache, podLister: schedulerCache,
podQueue: core.NewSchedulingQueue(), podQueue: core.NewSchedulingQueue(),
nodeLister: args.NodeInformer.Lister(),
pVLister: args.PvInformer.Lister(), pVLister: args.PvInformer.Lister(),
pVCLister: args.PvcInformer.Lister(), pVCLister: args.PvcInformer.Lister(),
serviceLister: args.ServiceInformer.Lister(), serviceLister: args.ServiceInformer.Lister(),
@@ -255,7 +256,6 @@ func NewConfigFactory(args *ConfigFactoryArgs) scheduler.Configurator {
DeleteFunc: c.deleteNodeFromCache, DeleteFunc: c.deleteNodeFromCache,
}, },
) )
c.nodeLister = args.NodeInformer.Lister()
// On add and delete of PVs, it will affect equivalence cache items // On add and delete of PVs, it will affect equivalence cache items
// related to persistent volume // related to persistent volume
@@ -267,7 +267,6 @@ func NewConfigFactory(args *ConfigFactoryArgs) scheduler.Configurator {
DeleteFunc: c.onPvDelete, DeleteFunc: c.onPvDelete,
}, },
) )
c.pVLister = args.PvInformer.Lister()
// This is for MaxPDVolumeCountPredicate: add/delete PVC will affect counts of PV when it is bound. // This is for MaxPDVolumeCountPredicate: add/delete PVC will affect counts of PV when it is bound.
args.PvcInformer.Informer().AddEventHandler( args.PvcInformer.Informer().AddEventHandler(
@@ -277,7 +276,6 @@ func NewConfigFactory(args *ConfigFactoryArgs) scheduler.Configurator {
DeleteFunc: c.onPvcDelete, DeleteFunc: c.onPvcDelete,
}, },
) )
c.pVCLister = args.PvcInformer.Lister()
// This is for ServiceAffinity: affected by the selector of the service is updated. // This is for ServiceAffinity: affected by the selector of the service is updated.
// Also, if new service is added, equivalence cache will also become invalid since // Also, if new service is added, equivalence cache will also become invalid since
@@ -289,7 +287,6 @@ func NewConfigFactory(args *ConfigFactoryArgs) scheduler.Configurator {
DeleteFunc: c.onServiceDelete, DeleteFunc: c.onServiceDelete,
}, },
) )
c.serviceLister = args.ServiceInformer.Lister()
// Existing equivalence cache should not be affected by add/delete RC/Deployment etc, // Existing equivalence cache should not be affected by add/delete RC/Deployment etc,
// it only make sense when pod is scheduled or deleted // it only make sense when pod is scheduled or deleted