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

fix: use schedulerCache instead of podlister in config factory

Browse Source
This commit is contained in:
draveness
2019-07-08 14:35:30 +08:00
parent 932487c744
commit 2fe0d4da27
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

@@ -167,8 +167,6 @@ type configFactory struct {
client clientset.Interface client clientset.Interface
// a means to list all known scheduled pods. // a means to list all known scheduled pods.
scheduledPodLister corelisters.PodLister scheduledPodLister corelisters.PodLister
// a means to list all known scheduled pods and pods assumed to have been scheduled.
podLister algorithm.PodLister
// a means to list all nodes // a means to list all nodes
nodeLister corelisters.NodeLister nodeLister corelisters.NodeLister
// a means to list all PersistentVolumes // a means to list all PersistentVolumes
@@ -279,7 +277,6 @@ func NewConfigFactory(args *ConfigFactoryArgs) Configurator {
c := &configFactory{ c := &configFactory{
client: args.Client, client: args.Client,
podLister: schedulerCache,
podQueue: internalqueue.NewSchedulingQueue(stopEverything, framework), podQueue: internalqueue.NewSchedulingQueue(stopEverything, framework),
nodeLister: args.NodeInformer.Lister(), nodeLister: args.NodeInformer.Lister(),
pVLister: args.PvInformer.Lister(), pVLister: args.PvInformer.Lister(),
@@ -569,7 +566,7 @@ func (c *configFactory) GetPredicates(predicateKeys sets.String) (map[string]pre
func (c *configFactory) getPluginArgs() (*PluginFactoryArgs, error) { func (c *configFactory) getPluginArgs() (*PluginFactoryArgs, error) {
return &PluginFactoryArgs{ return &PluginFactoryArgs{
PodLister: c.podLister, PodLister: c.schedulerCache,
ServiceLister: c.serviceLister, ServiceLister: c.serviceLister,
ControllerLister: c.controllerLister, ControllerLister: c.controllerLister,
ReplicaSetLister: c.replicaSetLister, ReplicaSetLister: c.replicaSetLister,