feat: add piece_length for download piece span (#1172)

Signed-off-by: Gaius <gaius.qi@gmail.com>

Author: gaius-qi

Cargo.lock

@@ -12,7 +12,7 @@ members = [
 ]
 
 [workspace.package]
-version = "0.2.32"
+version = "0.2.33"
 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.32" }
-dragonfly-client-core = { path = "dragonfly-client-core", version = "0.2.32" }
-dragonfly-client-config = { path = "dragonfly-client-config", version = "0.2.32" }
-dragonfly-client-storage = { path = "dragonfly-client-storage", version = "0.2.32" }
-dragonfly-client-backend = { path = "dragonfly-client-backend", version = "0.2.32" }
-dragonfly-client-util = { path = "dragonfly-client-util", version = "0.2.32" }
-dragonfly-client-init = { path = "dragonfly-client-init", version = "0.2.32" }
+dragonfly-client = { path = "dragonfly-client", version = "0.2.33" }
+dragonfly-client-core = { path = "dragonfly-client-core", version = "0.2.33" }
+dragonfly-client-config = { path = "dragonfly-client-config", version = "0.2.33" }
+dragonfly-client-storage = { path = "dragonfly-client-storage", version = "0.2.33" }
+dragonfly-client-backend = { path = "dragonfly-client-backend", version = "0.2.33" }
+dragonfly-client-util = { path = "dragonfly-client-util", version = "0.2.33" }
+dragonfly-client-init = { path = "dragonfly-client-init", version = "0.2.33" }
 dragonfly-api = "=2.1.39"
 thiserror = "2.0"
 futures = "0.3.31"

Cargo.toml

@@ -335,6 +335,7 @@ impl Piece {
     ) -> Result<impl AsyncRead> {
         // Span record the piece_id.
         Span::current().record("piece_id", piece_id);
+        Span::current().record("piece_length", length);
 
         // Acquire the upload rate limiter.
         if !disable_rate_limit {
@@ -366,6 +367,7 @@ impl Piece {
     ) -> Result<impl AsyncRead> {
         // Span record the piece_id.
         Span::current().record("piece_id", piece_id);
+        Span::current().record("piece_length", length);
 
         // Acquire the download rate limiter.
         if !disable_rate_limit {
@@ -409,6 +411,7 @@ impl Piece {
     ) -> Result<metadata::Piece> {
         // Span record the piece_id.
         Span::current().record("piece_id", piece_id);
+        Span::current().record("piece_length", length);
 
         // Record the start of downloading piece.
         let piece = self
@@ -513,6 +516,7 @@ impl Piece {
     ) -> Result<metadata::Piece> {
         // Span record the piece_id.
         Span::current().record("piece_id", piece_id);
+        Span::current().record("piece_length", length);
 
         // Record the start of downloading piece.
         let piece = self
@@ -696,6 +700,7 @@ impl Piece {
     ) -> Result<impl AsyncRead> {
         // Span record the piece_id.
         Span::current().record("piece_id", piece_id);
+        Span::current().record("piece_length", length);
 
         // Acquire the upload rate limiter.
         self.upload_rate_limiter.acquire(length as usize).await;
@@ -725,6 +730,7 @@ impl Piece {
     ) -> Result<impl AsyncRead> {
         // Span record the piece_id.
         Span::current().record("piece_id", piece_id);
+        Span::current().record("piece_length", length);
 
         // Acquire the download rate limiter.
         if !disable_rate_limit {
@@ -769,6 +775,7 @@ impl Piece {
     ) -> Result<metadata::Piece> {
         // Span record the piece_id.
         Span::current().record("piece_id", piece_id);
+        Span::current().record("piece_length", length);
 
         if is_prefetch {
             // Acquire the prefetch rate limiter.