RateLimiter: change CanAccept() to TryAccept()

2025-11-02 03:08:15 +00:00 · 2015-11-23 16:36:23 -08:00
parent 367f0e03dd
commit 13d152a873
6 changed files with 15 additions and 14 deletions
--- a/pkg/controller/node/rate_limited_queue.go
+++ b/pkg/controller/node/rate_limited_queue.go
@@ -163,7 +163,7 @@ func (q *RateLimitedTimedQueue) Try(fn ActionFunc) {
 	val, ok := q.queue.Head()
 	for ok {
 		// rate limit the queue checking
-		if !q.limiter.CanAccept() {
+		if !q.limiter.TryAccept() {
 			glog.V(10).Info("Try rate limitted...")
 			// Try again later
 			break