remove unnecessary queue len check in unblock

Author: marcoferrer

limiter/lifo_blocking.go

@@ -119,33 +119,29 @@ func (l *LifoBlockingListener) unblock() {
 	l.limiter.mu.Lock()
 	defer l.limiter.mu.Unlock()
 
-	if l.limiter.backlog.len() > 0 {
+	evict, nextEvent := l.limiter.backlog.peek()
 
-		evict, nextEvent := l.limiter.backlog.peek()
-
-		// Last element expired between us checking the
-		// queue length and invoking peek
-		if nextEvent == nil {
-			return
-		}
+	// The queue is empty
+	if nextEvent == nil {
+		return
+	}
 
-		listener, ok := l.limiter.delegate.Acquire(nextEvent.ctx)
+	listener, ok := l.limiter.delegate.Acquire(nextEvent.ctx)
 
-		if ok && listener != nil {
-			// We successfully acquired a listener from the
-			// delegate. Now we can evict the element from
-			// the queue
-			evict()
+	if ok && listener != nil {
+		// We successfully acquired a listener from the
+		// delegate. Now we can evict the element from
+		// the queue
+		evict()
 
-			// If the listener is not accepted due to subtle timings
-			// between setListener being invoked and the element
-			// expiration elapsing we need to be sure to release it.
-			if accepted := nextEvent.setListener(listener); !accepted {
-				listener.OnIgnore()
-			}
+		// If the listener is not accepted due to subtle timings
+		// between setListener being invoked and the element
+		// expiration elapsing we need to be sure to release it.
+		if accepted := nextEvent.setListener(listener); !accepted {
+			listener.OnIgnore()
 		}
-		// otherwise: still can't acquire the limit.  unblock will be called again next time the limit is released.
 	}
+	// otherwise: still can't acquire the limit.  unblock will be called again next time the limit is released.
 }
 
 // OnDropped is called to indicate the request failed and was dropped due to being rejected by an external limit or