@@ -530,10 +530,8 @@ void replica_bulk_loader::download_files(const std::string &provider_name,
530
530
}
531
531
if (!download_file_metas.empty ()) {
532
532
_download_files_task[download_file_metas.back ().name ] = tasking::enqueue (
533
- LPC_BACKGROUND_BULK_LOAD,
534
- tracker (),
535
- [this , remote_dir, local_dir, download_file_metas, fs]() mutable {
536
- this ->download_sst_file (remote_dir, local_dir, download_file_metas, fs);
533
+ LPC_BACKGROUND_BULK_LOAD, tracker (), [=, file_metas = download_file_metas]() mutable {
534
+ this ->download_sst_file (remote_dir, local_dir, std::move (file_metas), fs);
537
535
});
538
536
}
539
537
}
@@ -542,7 +540,7 @@ void replica_bulk_loader::download_files(const std::string &provider_name,
542
540
void replica_bulk_loader::download_sst_file (
543
541
const std::string &remote_dir,
544
542
const std::string &local_dir,
545
- std::vector<::dsn::replication::file_meta> &download_file_metas,
543
+ std::vector<::dsn::replication::file_meta> && download_file_metas,
546
544
dist::block_service::block_filesystem *fs)
547
545
{
548
546
if (_status != bulk_load_status::BLS_DOWNLOADING) {
@@ -609,10 +607,8 @@ void replica_bulk_loader::download_sst_file(
609
607
// download next file
610
608
if (!download_file_metas.empty ()) {
611
609
_download_files_task[download_file_metas.back ().name ] = tasking::enqueue (
612
- LPC_BACKGROUND_BULK_LOAD,
613
- tracker (),
614
- [this , remote_dir, local_dir, download_file_metas, fs]() mutable {
615
- this ->download_sst_file (remote_dir, local_dir, download_file_metas, fs);
610
+ LPC_BACKGROUND_BULK_LOAD, tracker (), [=, file_metas = download_file_metas]() mutable {
611
+ this ->download_sst_file (remote_dir, local_dir, std::move (file_metas), fs);
616
612
});
617
613
}
618
614
}
0 commit comments