This is an automated cherry-pick of tikv#16740

close tikv#16739 Signed-off-by: ti-chi-bot <ti-community-prow-bot@tidb.io>
ti-chi-bot · Apr 3, 2024 · dc81e14 · dc81e14
1 parent 7bbc6d9
commit dc81e14
Show file tree

Hide file tree

Showing 3 changed files with 557 additions and 46 deletions.
diff --git a/components/backup-stream/src/endpoint.rs b/components/backup-stream/src/endpoint.rs
@@ -61,7 +61,7 @@ use crate::{
     subscription_manager::{RegionSubscriptionManager, ResolvedRegions},
     subscription_track::{Ref, RefMut, ResolveResult, SubscriptionTracer},
     try_send,
-    utils::{self, CallbackWaitGroup, StopWatch, Work},
+    utils::{self, FutureWaitGroup, StopWatch, Work},
 };
 
 const SLOW_EVENT_THRESHOLD: f64 = 120.0;
@@ -1060,7 +1060,7 @@ where
     }
 
     pub fn do_backup(&self, events: Vec<CmdBatch>) {
-        let wg = CallbackWaitGroup::new();
+        let wg = FutureWaitGroup::new();
         for batch in events {
             self.backup_batch(batch, wg.clone().work());
         }