import 14.2.4 nautilus point release

[ceph.git] / ceph / src / rocksdb / db / external_sst_file_ingestion_job.h

diff --git a/ceph/src/rocksdb/db/external_sst_file_ingestion_job.h b/ceph/src/rocksdb/db/external_sst_file_ingestion_job.h
index 0f14e3606824f3a444a74066b1d4f5b70fedc921..baa8e9f0f64b90f54a1dfecf473f8c9e8a71ffdf 100644 (file)
--- a/ceph/src/rocksdb/db/external_sst_file_ingestion_job.h
+++ b/ceph/src/rocksdb/db/external_sst_file_ingestion_job.h
@@ -85,7 +85,8 @@ class ExternalSstFileIngestionJob {
         env_options_(env_options),
         db_snapshots_(db_snapshots),
         ingestion_options_(ingestion_options),
-        job_start_time_(env_->NowMicros()) {}
+        job_start_time_(env_->NowMicros()),
+        consumed_seqno_(false) {}
 
   // Prepare the job by copying external files into the DB.
   Status Prepare(const std::vector<std::string>& external_files_paths,
@@ -118,6 +119,9 @@ class ExternalSstFileIngestionJob {
     return files_to_ingest_;
   }
 
+  // Whether to increment VersionSet's seqno after this job runs
+  bool ShouldIncrementLastSequence() const { return consumed_seqno_; }
+
  private:
   // Open the external file and populate `file_to_ingest` with all the
   // external information we need to ingest this file.
@@ -159,6 +163,7 @@ class ExternalSstFileIngestionJob {
   const IngestExternalFileOptions& ingestion_options_;
   VersionEdit edit_;
   uint64_t job_start_time_;
+  bool consumed_seqno_;
 };
 
 }  // namespace rocksdb