feat: remove SyncPiecesFailedRequest in scheduler (#223)

Signed-off-by: Gaius <[email protected]>
dragonflyoss · Nov 29, 2023 · f94caaa · f94caaa
1 parent 8e004ee
commit f94caaa
Show file tree

Hide file tree

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

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
@@ -126,14 +126,6 @@ message DownloadPieceBackToSourceFailedRequest {
   }
 }
 
-// SyncPiecesFailedRequest syncs pieces failed request of AnnouncePeerRequest.
-message SyncPiecesFailedRequest {
-	// Parent peer id.
-  string parent_id = 1 [(validate.rules).string.min_len = 1];
-  // The description of the error.
-  optional string description = 2 [(validate.rules).string.min_len = 1];
-}
-
 // AnnouncePeerRequest represents request of AnnouncePeer.
 message AnnouncePeerRequest {
   // Host id.
@@ -159,7 +151,6 @@ message AnnouncePeerRequest {
     DownloadPieceBackToSourceFinishedRequest download_piece_back_to_source_finished_request = 14;
     DownloadPieceFailedRequest download_piece_failed_request = 15;
     DownloadPieceBackToSourceFailedRequest download_piece_back_to_source_failed_request = 16;
-    SyncPiecesFailedRequest sync_pieces_failed_request = 17;
   }
 }
 

diff --git a/proto/scheduler.proto b/proto/scheduler.proto
@@ -121,14 +121,6 @@ message DownloadPieceBackToSourceFailedRequest {
   }
 }
 
-// SyncPiecesFailedRequest syncs pieces failed request of AnnouncePeerRequest.
-message SyncPiecesFailedRequest {
-	// Parent peer id.
-  string parent_id = 1;
-  // The description of the error.
-  optional string description = 2;
-}
-
 // AnnouncePeerRequest represents request of AnnouncePeer.
 message AnnouncePeerRequest {
   // Host id.
@@ -152,7 +144,6 @@ message AnnouncePeerRequest {
     DownloadPieceBackToSourceFinishedRequest download_piece_back_to_source_finished_request = 14;
     DownloadPieceFailedRequest download_piece_failed_request = 15;
     DownloadPieceBackToSourceFailedRequest download_piece_back_to_source_failed_request = 16;
-    SyncPiecesFailedRequest sync_pieces_failed_request = 17;
   }
 }
 

diff --git a/src/descriptor.bin b/src/descriptor.bin
diff --git a/src/scheduler.v2.rs b/src/scheduler.v2.rs
@@ -158,18 +158,6 @@ pub mod download_piece_back_to_source_failed_request {
         HttpResponse(super::HttpResponse),
     }
 }
-/// SyncPiecesFailedRequest syncs pieces failed request of AnnouncePeerRequest.
-#[derive(serde::Serialize, serde::Deserialize)]
-#[allow(clippy::derive_partial_eq_without_eq)]
-#[derive(Clone, PartialEq, ::prost::Message)]
-pub struct SyncPiecesFailedRequest {
-    /// Parent peer id.
-    #[prost(string, tag = "1")]
-    pub parent_id: ::prost::alloc::string::String,
-    /// The description of the error.
-    #[prost(string, optional, tag = "2")]
-    pub description: ::core::option::Option<::prost::alloc::string::String>,
-}
 /// AnnouncePeerRequest represents request of AnnouncePeer.
 #[derive(serde::Serialize, serde::Deserialize)]
 #[allow(clippy::derive_partial_eq_without_eq)]
@@ -186,7 +174,7 @@ pub struct AnnouncePeerRequest {
     pub peer_id: ::prost::alloc::string::String,
     #[prost(
         oneof = "announce_peer_request::Request",
-        tags = "4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17"
+        tags = "4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16"
     )]
     pub request: ::core::option::Option<announce_peer_request::Request>,
 }
@@ -232,8 +220,6 @@ pub mod announce_peer_request {
         DownloadPieceBackToSourceFailedRequest(
             super::DownloadPieceBackToSourceFailedRequest,
         ),
-        #[prost(message, tag = "17")]
-        SyncPiecesFailedRequest(super::SyncPiecesFailedRequest),
     }
 }
 /// EmptyTaskResponse represents empty task response of AnnouncePeerResponse.