Method prepare

bcos-executor/src/executor/TransactionExecutor.cpp:1782–1844

}

void TransactionExecutor::prepare(
    const TwoPCParams& params, std::function<void(bcos::Error::Ptr)> callback)
{
    EXECUTOR_NAME_LOG(DEBUG) << BLOCK_NUMBER(params.number) << "Prepare request";

    if (!m_isRunning)
    {
        EXECUTOR_NAME_LOG(WARNING) << "TransactionExecutor is not running";
        callback(
            BCOS_ERROR_UNIQUE_PTR(ExecuteError::STOPPED, "TransactionExecutor is not running"));
        return;
    }

    auto first = m_stateStorages.begin();
    if (first == m_stateStorages.end())
    {
        const auto* errorMessage = "Prepare failed: empty stateStorages";
        EXECUTOR_NAME_LOG(WARNING) << errorMessage;
        callback(BCOS_ERROR_PTR(-1, errorMessage));

        return;
    }

    if (first->number != params.number)
    {
        auto errorMessage =
            "Prepare failed: Request blockNumber: " +
            boost::lexical_cast<std::string>(params.number) +
            " not equal to last blockNumber: " + boost::lexical_cast<std::string>(first->number) +
            " trigger switch";

        EXECUTOR_NAME_LOG(WARNING) << errorMessage;
        callback(BCOS_ERROR_PTR(ExecuteError::SCHEDULER_TERM_ID_ERROR, errorMessage));

        return;
    }

    bcos::protocol::TwoPCParams storageParams{params.number, params.primaryKey, params.timestamp};

    m_backendStorage->asyncPrepare(storageParams, *(first->storage),
        [this, callback = std::move(callback), blockNumber = params.number](
            auto&& error, uint64_t, const std::string&) {
            if (!m_isRunning)
            {
                callback(BCOS_ERROR_UNIQUE_PTR(
                    ExecuteError::STOPPED, "TransactionExecutor is not running"));
                return;
            }

            if (error)
            {
                auto errorMessage = "Prepare failed: " + error->errorMessage();

                EXECUTOR_NAME_LOG(ERROR) << BLOCK_NUMBER(blockNumber) << errorMessage;
                callback(
                    BCOS_ERROR_WITH_PREV_PTR(ExecuteError::PREPARE_ERROR, errorMessage, *error));
                return;
            }