From 301d41cac88e2a4dd4fe777ff26fe4e4727040e5 Mon Sep 17 00:00:00 2001 From: zhangjie Date: Wed, 30 Aug 2017 10:18:00 +0800 Subject: [PATCH] change AddEventHandlerWithResyncPeriod to AddEventHandler in factory.go Signed-off-by: zhangjie --- plugin/pkg/scheduler/factory/factory.go | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/plugin/pkg/scheduler/factory/factory.go b/plugin/pkg/scheduler/factory/factory.go index ae9cd535bd3..60b1bcf0cb7 100644 --- a/plugin/pkg/scheduler/factory/factory.go +++ b/plugin/pkg/scheduler/factory/factory.go @@ -207,48 +207,44 @@ func NewConfigFactory( c.scheduledPodLister = assignedPodLister{podInformer.Lister()} // Only nodes in the "Ready" condition with status == "True" are schedulable - nodeInformer.Informer().AddEventHandlerWithResyncPeriod( + nodeInformer.Informer().AddEventHandler( cache.ResourceEventHandlerFuncs{ AddFunc: c.addNodeToCache, UpdateFunc: c.updateNodeInCache, DeleteFunc: c.deleteNodeFromCache, }, - 0, ) c.nodeLister = nodeInformer.Lister() // On add and delete of PVs, it will affect equivalence cache items // related to persistent volume - pvInformer.Informer().AddEventHandlerWithResyncPeriod( + pvInformer.Informer().AddEventHandler( cache.ResourceEventHandlerFuncs{ // MaxPDVolumeCountPredicate: since it relies on the counts of PV. AddFunc: c.onPvAdd, DeleteFunc: c.onPvDelete, }, - 0, ) c.pVLister = pvInformer.Lister() // This is for MaxPDVolumeCountPredicate: add/delete PVC will affect counts of PV when it is bound. - pvcInformer.Informer().AddEventHandlerWithResyncPeriod( + pvcInformer.Informer().AddEventHandler( cache.ResourceEventHandlerFuncs{ AddFunc: c.onPvcAdd, DeleteFunc: c.onPvcDelete, }, - 0, ) c.pVCLister = pvcInformer.Lister() // 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 // existing pods may be "captured" by this service and change this predicate result. - serviceInformer.Informer().AddEventHandlerWithResyncPeriod( + serviceInformer.Informer().AddEventHandler( cache.ResourceEventHandlerFuncs{ AddFunc: c.onServiceAdd, UpdateFunc: c.onServiceUpdate, DeleteFunc: c.onServiceDelete, }, - 0, ) c.serviceLister = serviceInformer.Lister()