fix(bulkload) follow clang-tidy advice

apache · Aug 21, 2024 · 020b105 · 020b105
1 parent d040484
commit 020b105
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 22 deletions.
diff --git a/src/replica/bulk_load/replica_bulk_loader.cpp b/src/replica/bulk_load/replica_bulk_loader.cpp
@@ -16,13 +16,15 @@
 // under the License.
 
 #include <fmt/core.h>
+#include <algorithm>
 #include <functional>
+#include <iterator>
 #include <memory>
+#include <string_view>
 #include <unordered_map>
 #include <utility>
 #include <vector>
 
-#include <string_view>
 #include "block_service/block_service_manager.h"
 #include "common/bulk_load_common.h"
 #include "common/gpid.h"
@@ -474,12 +476,11 @@ error_code replica_bulk_loader::start_download(const std::string &remote_dir,
 
     // start download
     _is_downloading.store(true);
-    _download_task =
-        tasking::enqueue(LPC_BACKGROUND_BULK_LOAD,
-                         tracker(),
-                         [this, remote_dir, local_dir, download_file_metas, fs] {
-                             download_sst_file(remote_dir, local_dir, download_file_metas, fs);
-                         });
+    _download_task = tasking::enqueue(
+        LPC_BACKGROUND_BULK_LOAD,
+        tracker(),
+        std::bind(
+            &replica_bulk_loader::download_files, this, provider_name, remote_dir, local_dir));
     return ERR_OK;
 }
 
@@ -528,15 +529,12 @@ void replica_bulk_loader::download_files(const std::string &provider_name,
                   std::back_inserter(download_file_metas));
     }
     if (!download_file_metas.empty()) {
-        _download_files_task[download_file_metas.back().name] =
-            tasking::enqueue(LPC_BACKGROUND_BULK_LOAD,
-                             tracker(),
-                             std::bind(&replica_bulk_loader::download_sst_file,
-                                       this,
-                                       remote_dir,
-                                       local_dir,
-                                       download_file_metas,
-                                       fs));
+        _download_files_task[download_file_metas.back().name] = tasking::enqueue(
+            LPC_BACKGROUND_BULK_LOAD,
+            tracker(),
+            [this, remote_dir, local_dir, download_file_metas, fs]() mutable {
+                this->download_sst_file(remote_dir, local_dir, download_file_metas, fs);
+            });
     }
 }
 
@@ -610,12 +608,12 @@ void replica_bulk_loader::download_sst_file(
 
     // download next file
     if (!download_file_metas.empty()) {
-        _download_files_task[download_file_metas.back().name] =
-            tasking::enqueue(LPC_BACKGROUND_BULK_LOAD,
-                             tracker(),
-                             [this, remote_dir, local_dir, download_file_metas, fs] {
-                                 download_sst_file(remote_dir, local_dir, download_file_metas, fs);
-                             });
+        _download_files_task[download_file_metas.back().name] = tasking::enqueue(
+            LPC_BACKGROUND_BULK_LOAD,
+            tracker(),
+            [this, remote_dir, local_dir, download_file_metas, fs]() mutable {
+                this->download_sst_file(remote_dir, local_dir, download_file_metas, fs);
+            });
     }
 }
 

diff --git a/src/replica/bulk_load/replica_bulk_loader.h b/src/replica/bulk_load/replica_bulk_loader.h
@@ -22,6 +22,7 @@
 #include <map>
 #include <ostream>
 #include <string>
+#include <vector>
 
 #include "bulk_load_types.h"
 #include "common/replication_other_types.h"