Skip to content

Commit 5415282

Browse files
author
Hieu Pham
committed
revert InstallFiles
1 parent 036a35f commit 5415282

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

db/compaction/compaction_job.cc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1811,8 +1811,8 @@ void CompactionJob::RunRemote(PluggableCompactionService* service) {
18111811
}
18121812

18131813
// Install all remotely compacted file into local files.
1814-
auto statuses = service->InstallFiles(sources, destinations, file_options_,
1815-
env_, shutting_down_);
1814+
auto statuses =
1815+
service->InstallFiles(sources, destinations, file_options_, env_);
18161816
compaction_stats_.micros = env_->NowMicros() - start_micros;
18171817

18181818
for (uint32_t i = 0; i < statuses.size(); ++i) {

include/rocksdb/pluggable_compaction.h

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -82,8 +82,7 @@ class PluggableCompactionService {
8282
virtual std::vector<Status> InstallFiles(
8383
const std::vector<std::string>& remote_paths,
8484
const std::vector<std::string>& local_paths,
85-
const EnvOptions& env_options, Env* local_env,
86-
const std::atomic<bool>* shutting_down) = 0;
85+
const EnvOptions& env_options, Env* local_env) = 0;
8786

8887
virtual ~PluggableCompactionService() {}
8988
};

0 commit comments

Comments
 (0)