Method removePendingTx

txnpool/proc/txnpool_server.go:260–298

removePendingTx removes a transaction from the pending list when it is handled. And if the submitter of the valid transaction is from http, broadcast it to the network. Meanwhile, check if it is in the block from consensus.

(hash common.Uint256,
	err errors.ErrCode)

// is from http, broadcast it to the network. Meanwhile, check if it
// is in the block from consensus.
func (s *TXPoolServer) removePendingTx(hash common.Uint256,
	err errors.ErrCode) {

	s.mu.Lock()

	pt, ok := s.allPendingTxs[hash]
	if !ok {
		s.mu.Unlock()
		return
	}

	if err == errors.ErrNoError && ((pt.sender == tc.HttpSender) ||
		(pt.sender == tc.NetSender && !s.disableBroadcastNetTx)) {
		pid := s.GetPID(tc.NetActor)
		if pid != nil {
			pid.Tell(pt.tx)
		}
	}

	if pt.sender == tc.HttpSender && pt.ch != nil {
		replyTxResult(pt.ch, hash, err, err.Error())
	}

	delete(s.allPendingTxs, hash)

	if len(s.allPendingTxs) < tc.MAX_LIMITATION {
		select {
		case s.slots <- struct{}{}:
		default:
			log.Debug("removePendingTx: slots is full")
		}
	}

	s.mu.Unlock()

	// Check if the tx is in the pending block and
	// the pending block is verified
	s.checkPendingBlockOk(hash, err)
}

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