import quincy beta 17.1.0

[ceph.git] / ceph / src / rocksdb / utilities / transactions / optimistic_transaction_db_impl.h

diff --git a/ceph/src/rocksdb/utilities/transactions/optimistic_transaction_db_impl.h b/ceph/src/rocksdb/utilities/transactions/optimistic_transaction_db_impl.h
index d895d49b89674b719d4ed6d0514d3e1805a1d0a4..a23d9a06d7c4d1ee342b365355c24c8777c0a9e2 100644 (file)
--- a/ceph/src/rocksdb/utilities/transactions/optimistic_transaction_db_impl.h
+++ b/ceph/src/rocksdb/utilities/transactions/optimistic_transaction_db_impl.h
@@ -46,6 +46,22 @@ class OptimisticTransactionDBImpl : public OptimisticTransactionDB {
                                 const OptimisticTransactionOptions& txn_options,
                                 Transaction* old_txn) override;
 
+  // Transactional `DeleteRange()` is not yet supported.
+  virtual Status DeleteRange(const WriteOptions&, ColumnFamilyHandle*,
+                             const Slice&, const Slice&) override {
+    return Status::NotSupported();
+  }
+
+  // Range deletions also must not be snuck into `WriteBatch`es as they are
+  // incompatible with `OptimisticTransactionDB`.
+  virtual Status Write(const WriteOptions& write_opts,
+                       WriteBatch* batch) override {
+    if (batch->HasDeleteRange()) {
+      return Status::NotSupported();
+    }
+    return OptimisticTransactionDB::Write(write_opts, batch);
+  }
+
   size_t GetLockBucketsSize() const { return bucketed_locks_.size(); }
 
   OccValidationPolicy GetValidatePolicy() const { return validate_policy_; }