Method verifyStateful

txnpool/proc/txnpool_worker.go:269–299

verifyStateful prepares a check request and sends it to the stateful validator

(tx *tx.Transaction)

// verifyStateful prepares a check request and sends it to the
// stateful validator
func (worker *txPoolWorker) verifyStateful(tx *tx.Transaction) {
	req := &types.CheckTx{
		WorkerId: worker.workId,
		Tx:       tx,
	}

	// Construct the pending transaction
	pt := &pendingTx{
		tx:      tx,
		req:     req,
		retries: 0,
		valTime: time.Now(),
	}

	retAttr := &tc.TXAttr{
		Height:  0,
		Type:    types.Stateless,
		ErrCode: errors.ErrNoError,
	}

	pt.ret = append(pt.ret, retAttr)
	// Since the signature has been already verified, mark stateless as true
	pt.flag |= tc.STATELESS_MASK

	// Add it to the pending transaction list
	worker.mu.Lock()
	worker.pendingTxList[tx.Hash()] = pt
	worker.mu.Unlock()

	worker.sendReq2StatefulV(req)
}

// Start is the main event loop.
func (worker *txPoolWorker) start() {