Method commitV1

src/Transaction/CnchServerTransaction.cpp:105–139

TxnTimestamp CnchServerTransaction::commitV1()
{
    LOG_DEBUG(log, "Transaction {} starts commit (v1 api)\n", txn_record.txnID().toUInt64());

    if (isReadOnly())
        throw Exception("Invalid commit operation for read only transaction", ErrorCodes::LOGICAL_ERROR);

    Stopwatch watch(CLOCK_MONOTONIC_COARSE);
    SCOPE_EXIT({
        ProfileEvents::increment((getStatus() == CnchTransactionStatus::Finished ? ProfileEvents::CnchTxnCommitted : ProfileEvents::CnchTxnCommitV1Failed));
        ProfileEvents::increment(ProfileEvents::CnchTxnCommitV1ElapsedMilliseconds, watch.elapsedMilliseconds());
    });

    auto commit_ts = global_context->getTimestamp();

    try
    {
        auto lock = getLock();
        for (const auto & action : actions)
        {
            action->executeV1(commit_ts);
        }

        setStatus(CnchTransactionStatus::Finished);
        setCommitTime(commit_ts);
        LOG_DEBUG(log, "Successfully committed transaction (v1 api): {}\n", txn_record.txnID().toUInt64());
        commitModifiedCount(this->modified_counter);
        return commit_ts;
    }
    catch (...)
    {
        rollbackV1(commit_ts);
        throw;
    }
}

void CnchServerTransaction::rollbackV1(const TxnTimestamp & ts)
{