YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

//

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

//

//

#ifndef YB_CLIENT_TRANSACTION_H

#define YB_CLIENT_TRANSACTION_H

#include <future>

#include <memory>

#include <unordered_map>

#include <unordered_set>

#include "yb/common/consistent_read_point.h"

#include "yb/common/read_hybrid_time.h"

#include "yb/common/transaction.h"

#include "yb/client/client_fwd.h"

#include "yb/client/in_flight_op.h"

#include "yb/util/status_fwd.h"

namespace yb {

class HybridTime;

class Trace;

enum TxnPriorityRequirement {

  kLowerPriorityRange,

  kHigherPriorityRange,

  kHighestPriority

};

namespace client {

using Waiter = boost::function<void(const Status&)>;

using PrepareChildCallback = std::function<void(const Result<ChildTransactionDataPB>&)>;

struct ChildTransactionData {

  TransactionMetadata metadata;

  ReadHybridTime read_time;

  ConsistentReadPoint::HybridTimeMap local_limits;

  static Result<ChildTransactionData> FromPB(const ChildTransactionDataPB& data);

};

// SealOnly is a special commit mode.

// I.e. sealed transaction will be committed after seal record and all write batches are replicated.

YB_STRONGLY_TYPED_BOOL(SealOnly);

// YBTransaction is a representation of a single transaction.

// After YBTransaction is created, it could be used during construction of YBSession,

// to indicate that this session will send commands related to this transaction.

class YBTransaction : public std::enable_shared_from_this<YBTransaction> {

 private:

  class PrivateOnlyTag {};

 public:

  explicit YBTransaction(TransactionManager* manager,

                         TransactionLocality locality = TransactionLocality::GLOBAL);

  // Trick to allow std::make_shared with this ctor only from methods of this class.

  YBTransaction(TransactionManager* manager, const TransactionMetadata& metadata, PrivateOnlyTag);

  // Creates "child" transaction.

  // Child transaction shares same metadata as parent transaction, so all writes are done

  // as part of parent transaction.

  // But lifetime is controlled by parent transaction.

  // I.e. only parent transaction could be committed or aborted, also only parent transaction

  // sends heartbeats.

  YBTransaction(TransactionManager* manager, ChildTransactionData data);

  ~YBTransaction();

  Trace *trace();

  void SetPriority(uint64_t priority);

  uint64_t GetPriority() const;

  // Should be invoked to complete transaction creation.

  // Transaction is unusable before Init is called.

  CHECKED_STATUS Init(

      IsolationLevel isolation, const ReadHybridTime& read_time = ReadHybridTime());

  // Allows starting a transaction that reuses an existing read point.

  void InitWithReadPoint(IsolationLevel isolation, ConsistentReadPoint&& read_point);

  internal::TxnBatcherIf& batcher_if();

  // Commits this transaction.

  void Commit(CoarseTimePoint deadline, SealOnly seal_only, CommitCallback callback);

  void Commit(CoarseTimePoint deadline, CommitCallback callback);

  void Commit(CommitCallback callback);

  // Utility function for Commit.

  std::future<Status> CommitFuture(

      CoarseTimePoint deadline = CoarseTimePoint(), SealOnly seal_only = SealOnly::kFalse);

  // Aborts this transaction.

  void Abort(CoarseTimePoint deadline = CoarseTimePoint());

  // Returns transaction ID.

  const TransactionId& id() const;

  const ConsistentReadPoint& read_point() const;

  ConsistentReadPoint& read_point();

  bool IsRestartRequired() const;

  // Creates restarted transaction, this transaction should be in the "restart required" state.

  Result<YBTransactionPtr> CreateRestartedTransaction();

  // Setup precreated transaction to be restarted version of this transaction.

  CHECKED_STATUS FillRestartedTransaction(const YBTransactionPtr& dest);

  // Prepares child data, so child transaction could be started in another server.

  // Should be async because status tablet could be not ready yet.

  void PrepareChild(

      ForceConsistentRead force_consistent_read, CoarseTimePoint deadline,

      PrepareChildCallback callback);

  std::future<Result<ChildTransactionDataPB>> PrepareChildFuture(

      ForceConsistentRead force_consistent_read, CoarseTimePoint deadline = CoarseTimePoint());

  // After we finish all child operations, we should finish child and send result to parent.

  Result<ChildTransactionResultPB> FinishChild();

  // Apply results from child to this parent transaction.

  // `result` should be prepared with FinishChild of child transaction.

  CHECKED_STATUS ApplyChildResult(const ChildTransactionResultPB& result);

  std::shared_future<Result<TransactionMetadata>> GetMetadata(CoarseTimePoint deadline) const;

  std::string ToString() const;

  IsolationLevel isolation() const;

  // Releases this transaction object returning its metadata.

  // So this transaction could be used by some other application instance.

  Result<TransactionMetadata> Release();

  // Creates transaction by metadata, could be used in pair with release to transfer transaction

  // between application instances.

  static YBTransactionPtr Take(TransactionManager* manager, const TransactionMetadata& metadata);

  void SetActiveSubTransaction(SubTransactionId id);

  CHECKED_STATUS RollbackSubTransaction(SubTransactionId id);

  bool HasSubTransactionState();

 private:

  class Impl;

  std::unique_ptr<Impl> impl_;

};

class YBSubTransaction {

 public:

  bool active() const {

    return highest_subtransaction_id_ >= kMinSubTransactionId;

  }

  void SetActiveSubTransaction(SubTransactionId id);

  CHECKED_STATUS RollbackSubTransaction(SubTransactionId id);

  const SubTransactionMetadata& get();

 private:

  SubTransactionMetadata sub_txn_;

  // Tracks the highest observed subtransaction_id. Used during "ROLLBACK TO s" to abort from s to

  // the highest live subtransaction_id.

  SubTransactionId highest_subtransaction_id_ = 0;

};

} // namespace client

} // namespace yb

#endif // YB_CLIENT_TRANSACTION_H