Method setPendingTx

txnpool/proc/txnpool_server.go:302–321

setPendingTx adds a transaction to the pending list, if the transaction is already in the pending list, just return false.

(tx *tx.Transaction,
	sender tc.SenderType, txResultCh chan *tc.TxResult)

// setPendingTx adds a transaction to the pending list, if the
// transaction is already in the pending list, just return false.
func (s *TXPoolServer) setPendingTx(tx *tx.Transaction,
	sender tc.SenderType, txResultCh chan *tc.TxResult) bool {

	s.mu.Lock()
	defer s.mu.Unlock()
	if ok := s.allPendingTxs[tx.Hash()]; ok != nil {
		log.Debugf("setPendingTx: transaction %x already in the verifying process",
			tx.Hash())
		return false
	}

	pt := &serverPendingTx{
		tx:     tx,
		sender: sender,
		ch:     txResultCh,
	}

	s.allPendingTxs[tx.Hash()] = pt
	return true
}

// assignTxToWorker assigns a new transaction to a worker by LB
func (s *TXPoolServer) assignTxToWorker(tx *tx.Transaction,