kcenon::monitoring::transaction Class Reference

Transaction containing multiple operations. More...

#include <data_consistency.h>

Collaboration diagram for kcenon::monitoring::transaction:

Public Member Functions
	transaction (const std::string &id, const transaction_config &config)
std::string	id () const
transaction_state	state () const
size_t	operation_count () const
bool	add_operation (std::unique_ptr< transaction_operation > op)
bool	commit ()
bool	abort ()
std::chrono::steady_clock::time_point	creation_time () const

Private Attributes
std::string	id_
transaction_config	config_
transaction_state	state_
std::chrono::steady_clock::time_point	creation_time_
std::vector< std::unique_ptr< transaction_operation > >	operations_

Detailed Description

Transaction containing multiple operations.

Definition at line 166 of file data_consistency.h.

Constructor & Destructor Documentation

transaction()

kcenon::monitoring::transaction::transaction ( const std::string & id, const transaction_config & config )

inline

Definition at line 168 of file data_consistency.h.

        : id_(id)
        , config_(config)
        , state_(transaction_state::active)
        , creation_time_(std::chrono::steady_clock::now()) {}

Member Function Documentation

abort()

bool kcenon::monitoring::transaction::abort ( )

inline

Definition at line 218 of file data_consistency.h.

                 {
        if (state_ != transaction_state::active) {
            return false;
        }
        state_ = transaction_state::aborted;
        return true;
    }

References kcenon::monitoring::aborted, kcenon::monitoring::active, and state_.

Referenced by commit(), and TEST_F().

Here is the caller graph for this function:

add_operation()

bool kcenon::monitoring::transaction::add_operation ( std::unique_ptr< transaction_operation > op )

inline

Definition at line 178 of file data_consistency.h.

                                                                {
        if (state_ != transaction_state::active) {
            return false;
        }
        operations_.push_back(std::move(op));
        return true;
    }

References kcenon::monitoring::active, operations_, and state_.

Referenced by TEST_F(), TEST_F(), TEST_F(), and TEST_F().

Here is the caller graph for this function:

commit()

bool kcenon::monitoring::transaction::commit ( )

inline

Definition at line 186 of file data_consistency.h.

                  {
        if (state_ != transaction_state::active) {
            return false;
        }
 
        // Check for timeout
        auto now = std::chrono::steady_clock::now();
        auto elapsed = std::chrono::duration_cast<std::chrono::milliseconds>(now - creation_time_);
        if (elapsed > config_.timeout) {
            abort();
            return false;
        }
 
        // Execute all operations
        size_t executed_count = 0;
        for (auto& op : operations_) {
            auto result = op->execute();
            if (!result.is_ok()) {
                // Rollback executed operations in reverse order
                for (size_t i = executed_count; i > 0; --i) {
                    operations_[i - 1]->rollback();
                }
                state_ = transaction_state::aborted;
                return false;
            }
            ++executed_count;
        }
 
        state_ = transaction_state::committed;
        return true;
    }

References abort(), kcenon::monitoring::aborted, kcenon::monitoring::active, kcenon::monitoring::committed, config_, creation_time_, operations_, state_, and kcenon::monitoring::transaction_config::timeout.

Referenced by TEST_F(), TEST_F(), and TEST_F().

Here is the call graph for this function:

Here is the caller graph for this function:

creation_time()

std::chrono::steady_clock::time_point kcenon::monitoring::transaction::creation_time ( ) const

inline

Definition at line 226 of file data_consistency.h.

                                                          {
        return creation_time_;
    }

References creation_time_.

id()

std::string kcenon::monitoring::transaction::id ( ) const

inline

Definition at line 174 of file data_consistency.h.

{ return id_; }

References id_.

operation_count()

size_t kcenon::monitoring::transaction::operation_count ( ) const

inline

Definition at line 176 of file data_consistency.h.

{ return operations_.size(); }

References operations_.

Referenced by TEST_F().

Here is the caller graph for this function:

state()

transaction_state kcenon::monitoring::transaction::state ( ) const

inline

Definition at line 175 of file data_consistency.h.

{ return state_; }

References state_.

Referenced by TEST_F(), TEST_F(), TEST_F(), and TEST_F().

Here is the caller graph for this function:

Member Data Documentation

config_

transaction_config kcenon::monitoring::transaction::config_

private

Definition at line 232 of file data_consistency.h.

Referenced by commit().

creation_time_

std::chrono::steady_clock::time_point kcenon::monitoring::transaction::creation_time_

private

Definition at line 234 of file data_consistency.h.

Referenced by commit(), and creation_time().

id_

std::string kcenon::monitoring::transaction::id_

private

Definition at line 231 of file data_consistency.h.

Referenced by id().

operations_

std::vector<std::unique_ptr<transaction_operation> > kcenon::monitoring::transaction::operations_

private

Definition at line 235 of file data_consistency.h.

Referenced by add_operation(), commit(), and operation_count().

state_

transaction_state kcenon::monitoring::transaction::state_

private

Definition at line 233 of file data_consistency.h.

Referenced by abort(), add_operation(), commit(), and state().

---

The documentation for this class was generated from the following file:

• include/kcenon/monitoring/reliability/data_consistency.h