update sources to ceph Nautilus 14.2.1

[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 e426a21bec294eb25fdb4941c89c2e4537fdd4b5..49240a98c2d9cb0ea82b5346f5beab7b00f4b842 100644 (file)
--- a/ceph/src/rocksdb/utilities/transactions/optimistic_transaction_db_impl.h
+++ b/ceph/src/rocksdb/utilities/transactions/optimistic_transaction_db_impl.h
@@ -1,7 +1,7 @@
 //  Copyright (c) 2011-present, Facebook, Inc.  All rights reserved.
-//  This source code is licensed under the BSD-style license found in the
-//  LICENSE file in the root directory of this source tree. An additional grant
-//  of patent rights can be found in the PATENTS file in the same directory.
+//  This source code is licensed under both the GPLv2 (found in the
+//  COPYING file in the root directory) and Apache 2.0 License
+//  (found in the LICENSE.Apache file in the root directory).
 
 #pragma once
 #ifndef ROCKSDB_LITE
@@ -14,19 +14,24 @@ namespace rocksdb {
 
 class OptimisticTransactionDBImpl : public OptimisticTransactionDB {
  public:
-  explicit OptimisticTransactionDBImpl(DB* db)
-      : OptimisticTransactionDB(db), db_(db) {}
+  explicit OptimisticTransactionDBImpl(DB* db, bool take_ownership = true)
+      : OptimisticTransactionDB(db), db_owner_(take_ownership) {}
 
-  ~OptimisticTransactionDBImpl() {}
+  ~OptimisticTransactionDBImpl() {
+    // Prevent this stackable from destroying
+    // base db
+    if (!db_owner_) {
+      db_ = nullptr;
+    }
+  }
 
   Transaction* BeginTransaction(const WriteOptions& write_options,
                                 const OptimisticTransactionOptions& txn_options,
                                 Transaction* old_txn) override;
 
-  DB* GetBaseDB() override { return db_.get(); }
-
  private:
-  std::unique_ptr<DB> db_;
+
+   bool db_owner_;
 
   void ReinitializeTransaction(Transaction* txn,
                                const WriteOptions& write_options,