From 380c6cbd0daa47cfc4535514bd58f22b7294a7c0 Mon Sep 17 00:00:00 2001 From: Andrew Sy Kim Date: Fri, 31 May 2019 08:26:21 -0400 Subject: [PATCH] route controller: respect rate limit for delete Signed-off-by: Andrew Sy Kim Co-authored-by: Khaled Henidak --- pkg/controller/route/route_controller.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pkg/controller/route/route_controller.go b/pkg/controller/route/route_controller.go index b5dd1ca9782..f8755aae97e 100644 --- a/pkg/controller/route/route_controller.go +++ b/pkg/controller/route/route_controller.go @@ -216,12 +216,14 @@ func (rc *RouteController) reconcile(nodes []*v1.Node, routes []*cloudprovider.R // Delete the route. go func(route *cloudprovider.Route, startTime time.Time) { defer wg.Done() + rateLimiter <- struct{}{} klog.Infof("Deleting route %s %s", route.Name, route.DestinationCIDR) if err := rc.routes.DeleteRoute(context.TODO(), rc.clusterName, route); err != nil { klog.Errorf("Could not delete route %s %s after %v: %v", route.Name, route.DestinationCIDR, time.Since(startTime), err) } else { klog.Infof("Deleted route %s %s after %v", route.Name, route.DestinationCIDR, time.Since(startTime)) } + <-rateLimiter }(route, time.Now()) } }