Merge pull request ReactiveX#62 from resilience4j/permissions_fix_for…

…_atomic_rateLlmiter

Permissions fix for atomic rate limiter

README.adoc

@@ -294,7 +294,7 @@ it takes only `143±1 [ns]` to acquire permission.
 So you can easily restrict not only network calls but your local in-memory operations, too.
 
 
-== Companies who use javaslang-circuitbreaker
+== Companies who use Resilience4j
 
 * Deutsche Telekom (In an application with over 400 million request per day)
 * AOL (In an application with low latency requirements)

resilience4j-ratelimiter/src/main/java/io/github/resilience4j/ratelimiter/internal/AtomicRateLimiter.java

@@ -66,7 +66,7 @@ public AtomicRateLimiter(String name, RateLimiterConfig rateLimiterConfig) {
         permissionsPerCycle = rateLimiterConfig.getLimitForPeriod();
 
         waitingThreads = new AtomicInteger(0);
-        state = new AtomicReference<>(new State(0, 0, 0));
+        state = new AtomicReference<>(new State(0, permissionsPerCycle, 0));
 
         PublishProcessor<RateLimiterEvent> publisher = PublishProcessor.create();
         this.eventPublisher = publisher.toSerialized();

resilience4j-ratelimiter/src/test/java/io/github/resilience4j/ratelimiter/internal/AtomicRateLimiterTest.java

@@ -49,6 +49,7 @@ public class AtomicRateLimiterTest {
     private static final String LIMITER_NAME = "test";
     private static final long CYCLE_IN_NANOS = 500_000_000L;
     private static final long POLL_INTERVAL_IN_NANOS = 2_000_000L;
+    private static final int PERMISSIONS_RER_CYCLE = 1;
     private RateLimiterConfig rateLimiterConfig;
     private AtomicRateLimiter rateLimiter;
     private AtomicRateLimiter.AtomicRateLimiterMetrics metrics;
@@ -68,7 +69,7 @@ private void setTimeOnNanos(long nanoTime) throws Exception {
     @Before
     public void setup() {
         rateLimiterConfig = RateLimiterConfig.custom()
-            .limitForPeriod(1)
+            .limitForPeriod(PERMISSIONS_RER_CYCLE)
             .limitRefreshPeriod(Duration.ofNanos(CYCLE_IN_NANOS))
             .timeoutDuration(Duration.ZERO)
             .build();
@@ -78,6 +79,14 @@ public void setup() {
         eventStream = rateLimiter.getEventStream();
     }
 
+    @Test
+    public void permissionsInFirstCycle() throws Exception {
+        setTimeOnNanos(CYCLE_IN_NANOS - 10);
+        RateLimiter.Metrics metrics = rateLimiter.getMetrics();
+        int availablePermissions = metrics.getAvailablePermissions();
+        then(availablePermissions).isEqualTo(PERMISSIONS_RER_CYCLE);
+    }
+
     @Test
     public void acquireAndRefreshWithEventPublishing() throws Exception {
         CompletableFuture<ArrayList<String>> events = subscribeOnAllEventsDescriptions(4);