Function WasmTxGenerator

src/rpc/rpcblockchain.cpp:708–771

void static WasmTxGenerator(TpsTester *tpsTester, wasm::inline_transaction &inlineTx) {
    RenameThread("coin-gentxwasm");
    SetThreadPriority(THREAD_PRIORITY_NORMAL);

    CCoinSecret vchSecret;
    vchSecret.SetString("Y6J4aK6Wcs4A3Ex4HXdfjJ6ZsHpNZfjaS4B9w7xqEnmFEYMqQd13");
    CKey key = vchSecret.GetKey();

    // remove key from wallet first.
    {
        LOCK2(cs_main, pWalletMain->cs_wallet);
        if (!pWalletMain->RemoveKey(key))
            throw boost::thread_interrupted();
    }
    shared_ptr<CCacheWrapper> spCw;
    uint64_t minFees         = 0;
    {
        LOCK(cs_main);
        spCw = make_shared<CCacheWrapper>(pCdMan);
        GetTxMinFee(*spCw, BCOIN_TRANSFER_TX, chainActive.Height(), SYMB::WICC, minFees);
    }
    CRegID txUid("0-1");
    auto payer      = wasm::regid(txUid.GetIntValue());

    inlineTx.authorization = std::vector<permission>{{payer.value, wasmio_owner}};

    int32_t lastHeight = 0;
    uint64_t fees = minFees;
    while (true) {
        // add interruption point
        boost::this_thread::interruption_point();

        int64_t nStart      = GetTimeMillis();
        int32_t validHeight = chainActive.Height();
        if (lastHeight != validHeight) {
            fees = minFees;
            lastHeight = validHeight;
        }

        for (int64_t i = 0; i < tpsTester->batchSize; ++i) {
            shared_ptr<CUniversalTx> tx = std::make_shared<CUniversalTx>();
            tx->txUid        = txUid;
            tx->fee_symbol   = SYMB::WICC;
            tx->llFees       = fees;
            tx->valid_height = validHeight;

            tx->inline_transactions.push_back(inlineTx);
            // sign transaction
            key.Sign(tx->GetHash(), tx->signature);

            tpsTester->generationQueue->Push(tx);
            fees++;
        }

        int64_t elapseTime = GetTimeMillis() - nStart;
        LogPrint(BCLog::DEBUG, "batch generate transaction(s): %ld, elapse time: %ld ms.\n", tpsTester->batchSize, elapseTime);

        if (elapseTime < tpsTester->period) {