X-Git-Url: https://git.proxmox.com/?a=blobdiff_plain;f=ceph%2Fsrc%2Frocksdb%2Fdb%2Fexternal_sst_file_ingestion_job.h;h=baa8e9f0f64b90f54a1dfecf473f8c9e8a71ffdf;hb=494da23a05e25ed98f5539f3b89e6af3cafe3fec;hp=0f14e3606824f3a444a74066b1d4f5b70fedc921;hpb=931c18d5142274109ebfaecd012da8e5a3ebc67e;p=ceph.git

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 0f14e3606..baa8e9f0f 100644
--- 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