YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

// 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.

//

// The following only applies to changes made to this file as part of YugaByte development.

//

// Portions Copyright (c) YugaByte, Inc.

//

// Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except

// in compliance with the License.  You may obtain a copy of the License at

//

// http://www.apache.org/licenses/LICENSE-2.0

//

// Unless required by applicable law or agreed to in writing, software distributed under the License

// is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express

// or implied.  See the License for the specific language governing permissions and limitations

// under the License.

//

#pragma once

#ifndef ROCKSDB_LITE

#include <stack>

#include <string>

#include <unordered_map>

#include <vector>

#include "yb/rocksdb/db/write_callback.h"

#include "yb/rocksdb/db.h"

#include "yb/util/slice.h"

#include "yb/rocksdb/snapshot.h"

#include "yb/rocksdb/status.h"

#include "yb/rocksdb/types.h"

#include "yb/rocksdb/utilities/transaction.h"

#include "yb/rocksdb/utilities/optimistic_transaction_db.h"

#include "yb/rocksdb/utilities/write_batch_with_index.h"

#include "yb/rocksdb/utilities/transactions/transaction_base.h"

#include "yb/rocksdb/utilities/transactions/transaction_util.h"

namespace rocksdb {

class OptimisticTransactionImpl : public TransactionBaseImpl {

 public:

  OptimisticTransactionImpl(OptimisticTransactionDB* db,

                            const WriteOptions& write_options,

                            const OptimisticTransactionOptions& txn_options);

  virtual ~OptimisticTransactionImpl();

  void Reinitialize(OptimisticTransactionDB* txn_db,

                    const WriteOptions& write_options,

                    const OptimisticTransactionOptions& txn_options);

  Status Commit() override;

  void Rollback() override;

 protected:

  Status TryLock(ColumnFamilyHandle* column_family, const Slice& key,

                 bool read_only, bool untracked = false) override;

 private:

  OptimisticTransactionDB* const txn_db_;

  friend class OptimisticTransactionCallback;

  void Initialize(const OptimisticTransactionOptions& txn_options);

  // Returns OK if it is safe to commit this transaction.  Returns Status::Busy

  // if there are read or write conflicts that would prevent us from committing

  // OR if we can not determine whether there would be any such conflicts.

  //

  // Should only be called on writer thread.

  Status CheckTransactionForConflicts(DB* db);

  void Clear() override;

  void UnlockGetForUpdate(ColumnFamilyHandle* column_family,

                          const Slice& key) override {

    // Nothing to unlock.

  }

  // No copying allowed

  OptimisticTransactionImpl(const OptimisticTransactionImpl&);

  void operator=(const OptimisticTransactionImpl&);

};

// Used at commit time to trigger transaction validation

class OptimisticTransactionCallback : public WriteCallback {

 public:

  explicit OptimisticTransactionCallback(OptimisticTransactionImpl* txn)

      : txn_(txn) {}

  Status Callback(DB* db) override {

    return txn_->CheckTransactionForConflicts(db);

  }

  bool AllowWriteBatching() override { return false; }

 private:

  OptimisticTransactionImpl* txn_;

};

}  // namespace rocksdb

#endif  // ROCKSDB_LITE