feat: add max for ratelimit

Signed-off-by: Gaius <[email protected]>

Cargo.toml

@@ -12,7 +12,7 @@ members = [
 ]
 
 [workspace.package]
-version = "0.2.4"
+version = "0.2.5"
 authors = ["The Dragonfly Developers"]
 homepage = "https://d7y.io/"
 repository = "https://github.com/dragonflyoss/client.git"
@@ -22,13 +22,13 @@ readme = "README.md"
 edition = "2021"
 
 [workspace.dependencies]
-dragonfly-client = { path = "dragonfly-client", version = "0.2.4" }
-dragonfly-client-core = { path = "dragonfly-client-core", version = "0.2.4" }
-dragonfly-client-config = { path = "dragonfly-client-config", version = "0.2.4" }
-dragonfly-client-storage = { path = "dragonfly-client-storage", version = "0.2.4" }
-dragonfly-client-backend = { path = "dragonfly-client-backend", version = "0.2.4" }
-dragonfly-client-util = { path = "dragonfly-client-util", version = "0.2.4" }
-dragonfly-client-init = { path = "dragonfly-client-init", version = "0.2.4" }
+dragonfly-client = { path = "dragonfly-client", version = "0.2.5" }
+dragonfly-client-core = { path = "dragonfly-client-core", version = "0.2.5" }
+dragonfly-client-config = { path = "dragonfly-client-config", version = "0.2.5" }
+dragonfly-client-storage = { path = "dragonfly-client-storage", version = "0.2.5" }
+dragonfly-client-backend = { path = "dragonfly-client-backend", version = "0.2.5" }
+dragonfly-client-util = { path = "dragonfly-client-util", version = "0.2.5" }
+dragonfly-client-init = { path = "dragonfly-client-init", version = "0.2.5" }
 thiserror = "1.0"
 dragonfly-api = "=2.1.3"
 reqwest = { version = "0.12.4", features = [

dragonfly-client/src/resource/piece.rs

@@ -103,6 +103,7 @@ impl Piece {
                 RateLimiter::builder()
                     .initial(config.download.rate_limit.as_u64() as usize)
                     .refill(config.download.rate_limit.as_u64() as usize)
+                    .max(MAX_PIECE_LENGTH as usize)
                     .interval(Duration::from_secs(1))
                     .fair(false)
                     .build(),
@@ -111,14 +112,18 @@ impl Piece {
                 RateLimiter::builder()
                     .initial(config.upload.rate_limit.as_u64() as usize)
                     .refill(config.upload.rate_limit.as_u64() as usize)
+                    .max(MAX_PIECE_LENGTH as usize)
                     .interval(Duration::from_secs(1))
+                    .fair(false)
                     .build(),
             ),
             prefetch_rate_limiter: Arc::new(
                 RateLimiter::builder()
                     .initial(config.proxy.prefetch_rate_limit.as_u64() as usize)
                     .refill(config.proxy.prefetch_rate_limit.as_u64() as usize)
+                    .max(MAX_PIECE_LENGTH as usize)
                     .interval(Duration::from_secs(1))
+                    .fair(false)
                     .build(),
             ),
         })