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

Petset hotlooping issue.

Browse Source
This commit is contained in:
Anirudh 2016-08-19 11:49:05 -07:00
parent 8356afbe10
commit 0e5a49f667
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/controller/petset/pet_set.go
View File

@ -73,7 +73,7 @@ type PetSetController struct {
blockingPetStore *unhealthyPetTracker blockingPetStore *unhealthyPetTracker
// Controllers that need to be synced. // Controllers that need to be synced.
queue *workqueue.Type queue workqueue.RateLimitingInterface
// syncHandler handles sync events for petsets. // syncHandler handles sync events for petsets.
// Abstracted as a func to allow injection for testing. // Abstracted as a func to allow injection for testing.
@ -94,7 +94,7 @@ func NewPetSetController(podInformer framework.SharedIndexInformer, kubeClient *
newSyncer: func(blockingPet *pcb) *petSyncer { newSyncer: func(blockingPet *pcb) *petSyncer {
return &petSyncer{pc, blockingPet} return &petSyncer{pc, blockingPet}
}, },
queue: workqueue.New(), queue: workqueue.NewRateLimitingQueue(workqueue.DefaultControllerRateLimiter()),
} }
podInformer.AddEventHandler(framework.ResourceEventHandlerFuncs{ podInformer.AddEventHandler(framework.ResourceEventHandlerFuncs{
@ -268,7 +268,9 @@ func (psc *PetSetController) worker() {
defer psc.queue.Done(key) defer psc.queue.Done(key)
if errs := psc.syncHandler(key.(string)); len(errs) != 0 { if errs := psc.syncHandler(key.(string)); len(errs) != 0 {
glog.Errorf("Error syncing PetSet %v, requeuing: %v", key.(string), errs) glog.Errorf("Error syncing PetSet %v, requeuing: %v", key.(string), errs)
psc.queue.Add(key) psc.queue.AddRateLimited(key)
} else {
psc.queue.Forget(key)
} }
}() }()
} }