Method precommit

src/Transaction/CnchServerTransaction.cpp:189–240

}

void CnchServerTransaction::precommit()
{
    LOG_DEBUG(log, "Transaction {} starts pre commit\n", txn_record.txnID().toUInt64());
    Stopwatch watch(CLOCK_MONOTONIC_COARSE);
    SCOPE_EXIT({ ProfileEvents::increment(ProfileEvents::CnchTxnPrecommitElapsedMilliseconds, watch.elapsedMilliseconds()); });

    {
        auto lock = getLock();
        if (auto status = getStatus(); status != CnchTransactionStatus::Running)
            throw Exception("Transaction is not in running status, but in " + String(txnStatusToString(status)), ErrorCodes::LOGICAL_ERROR);

        for (auto & action : actions)
            action->executeV2();

        txn_record.prepared = true;
        action_size_before_dedup = actions.size();
    }

    auto retry_time = getContext()->getSettingsRef().max_dedup_retry_time.value;
    do
    {
        try
        {
            executeDedupStage();
            assertLockAcquired();
        }
        catch  (...)
        {
            if (retry_time == 0)
                throw;
            else if (action_size_before_dedup < actions.size())
            {
                /// TODO: Impl retry in this case, especially handle undo buffer
                LOG_WARNING(
                    log,
                    "Dedup stage failed, but result is not empty({}/{}), unable to retry, retry time: {}",
                    actions.size(),
                    action_size_before_dedup,
                    retry_time);
                throw;
            }
            else
            {
                LOG_WARNING(log, "Dedup stage failed, retry time: {}, reason: {}", retry_time, getCurrentExceptionMessage(false));
                retry_time--;
                dedup_stage_flag = false;
                continue;
            }
        }
        break;
    } while (true);
}

void CnchServerTransaction::executeDedupStage()
{