gc retries failed garbage collection

2016-09-01 10:42:55 -07:00
parent c337778803
commit 25966e1148
1 changed files with 3 additions and 0 deletions
--- a/pkg/controller/garbagecollector/garbagecollector.go
+++ b/pkg/controller/garbagecollector/garbagecollector.go
@@ -581,6 +581,9 @@ func (gc *GarbageCollector) worker() {
 	err := gc.processItem(timedItem.Object.(*node))
 	if err != nil {
 		utilruntime.HandleError(fmt.Errorf("Error syncing item %#v: %v", timedItem.Object, err))
+		// retry if garbage collection of an object failed.
+		gc.dirtyQueue.Add(timedItem)
+		return
 	}
 	DirtyProcessingLatency.Observe(sinceInMicroseconds(gc.clock, timedItem.StartTime))
 }