Fix off by 1_000_000

Kuadrant · May 14, 2024 · d364a01 · d364a01
1 parent 9a30916
commit d364a01
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/limitador/src/storage/distributed/cr_counter_value.rs b/limitador/src/storage/distributed/cr_counter_value.rs
@@ -45,7 +45,7 @@ impl<A: Ord> CrCounterValue<A> {
     pub fn inc_at(&self, increment: u64, time_window: Duration, when: SystemTime) {
         if self
             .expiry
-            .update_if_expired(time_window.as_micros() as u64, when)
+            .update_if_expired(time_window.as_secs(), when)
         {
             self.value.store(increment, Ordering::SeqCst);
         } else {

diff --git a/limitador/tests/integration_tests.rs b/limitador/tests/integration_tests.rs
@@ -16,7 +16,7 @@ macro_rules! test_with_all_storage_impls {
             #[tokio::test]
             async fn [<$function _distributed_storage>]() {
                 let rate_limiter =
-                    RateLimiter::new_with_storage(Box::new(CrInMemoryStorage::new("test_node".to_owned(), 10_000)));
+                    RateLimiter::new_with_storage(Box::new(CrInMemoryStorage::new("test_node".to_owned(), 10_000, "127.0.0.1:19876".to_owned(), "127.0.0.255:19876".to_owned())));
                 $function(&mut TestsLimiter::new_from_blocking_impl(rate_limiter)).await;
             }