feat: remove concurrent_piece_count in scheduler (#228)

Signed-off-by: Gaius <[email protected]>
dragonflyoss · Dec 12, 2023 · ac0a2a4 · ac0a2a4
1 parent d333a92
commit ac0a2a4
Show file tree

Hide file tree

Showing 10 changed files with 10 additions and 66 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "dragonfly-api"
-version = "2.0.61"
+version = "2.0.62"
 authors = ["Gaius <[email protected]>"]
 edition = "2021"
 license = "Apache-2.0"

diff --git a/pkg/apis/scheduler/v1/scheduler.pb.go b/pkg/apis/scheduler/v1/scheduler.pb.go
diff --git a/pkg/apis/scheduler/v1/scheduler.pb.validate.go b/pkg/apis/scheduler/v1/scheduler.pb.validate.go
diff --git a/pkg/apis/scheduler/v1/scheduler.proto b/pkg/apis/scheduler/v1/scheduler.proto
@@ -133,8 +133,6 @@ message PeerPacket{
   string task_id = 2 [(validate.rules).string.min_len = 1];
   // Source peer id.
   string src_pid = 3 [(validate.rules).string.min_len = 1];
-  // Concurrent downloading count from main peer.
-  int32 parallel_count = 4 [(validate.rules).int32.gte = 1];
   // Main peer.
   DestPeer main_peer = 5;
   // Candidate peers.

diff --git a/pkg/apis/scheduler/v2/scheduler.pb.go b/pkg/apis/scheduler/v2/scheduler.pb.go
diff --git a/pkg/apis/scheduler/v2/scheduler.pb.validate.go b/pkg/apis/scheduler/v2/scheduler.pb.validate.go
diff --git a/pkg/apis/scheduler/v2/scheduler.proto b/pkg/apis/scheduler/v2/scheduler.proto
@@ -162,8 +162,6 @@ message EmptyTaskResponse {
 message NormalTaskResponse {
   // Candidate parents.
   repeated common.v2.Peer candidate_parents = 1 [(validate.rules).repeated = {min_items: 1}];
-  // Concurrent downloading piece count from the peers.
-  uint32 concurrent_piece_count = 2 [(validate.rules).uint32.gte = 1];
 }
 
 // NeedBackToSourceResponse represents need back-to-source response of AnnouncePeerResponse.

diff --git a/proto/scheduler.proto b/proto/scheduler.proto
@@ -155,8 +155,6 @@ message EmptyTaskResponse {
 message NormalTaskResponse {
   // Candidate parents.
   repeated common.v2.Peer candidate_parents = 1;
-  // Concurrent downloading piece count from the peers.
-  uint32 concurrent_piece_count = 2;
 }
 
 // NeedBackToSourceResponse represents need back-to-source response of AnnouncePeerResponse.

diff --git a/src/descriptor.bin b/src/descriptor.bin
diff --git a/src/scheduler.v2.rs b/src/scheduler.v2.rs
@@ -235,9 +235,6 @@ pub struct NormalTaskResponse {
     /// Candidate parents.
     #[prost(message, repeated, tag = "1")]
     pub candidate_parents: ::prost::alloc::vec::Vec<super::super::common::v2::Peer>,
-    /// Concurrent downloading piece count from the peers.
-    #[prost(uint32, tag = "2")]
-    pub concurrent_piece_count: u32,
 }
 /// NeedBackToSourceResponse represents need back-to-source response of AnnouncePeerResponse.
 #[derive(serde::Serialize, serde::Deserialize)]