Method SendTransactions

protocols/cpc/peer.go:191–197

SendTransactions sends transactions to the peer and includes the hashes in its transaction hash set for future reference.

(txs types.Transactions)

// SendTransactions sends transactions to the peer and includes the hashes
// in its transaction hash set for future reference.
func (p *peer) SendTransactions(txs types.Transactions) error {
	for _, tx := range txs {
		log.Debug("send tx", "tx", tx.Hash().Hex(), "remoteAddr", p.RemoteAddr().String())
		p.knownTxs.Add(tx.Hash())
	}
	return p2p.Send(p.rw, TxMsg, txs)
}

// AsyncSendTransactions queues list of transactions propagation to a remote
// peer. If the peer's broadcast queue is full, the event is silently dropped.