btcd中对端发送的网络报文都在该处理函数:
func (p *Peer) inHandler() {

比特币节点收到交易的处理流程

   OnTx是一个函数接口,在初识化的时候注册的,注册代码如下:

比特币节点收到交易的处理流程

在改函数func (sp *serverPeer) OnTx(_ *peer.Peer, msg *wire.MsgTx)中,把收到的交易消息放入msgchan消息队列

func (sm *SyncManager) QueueTx(tx *btcutil.Tx, peer *peerpkg.Peer, done chan struct{}) {
	// Don't accept more transactions if we're shutting down.
	if atomic.LoadInt32(&sm.shutdown) != 0 {
		done <- struct{}{}
		return
	}

	sm.msgChan <- &txMsg{tx: tx, peer: peer, reply: done}
}

  从channel读取报文后,对消息的处理函数如下:

func (sm *SyncManager) handleTxMsg(tmsg *txMsg)

  

  

 

相关文章:

  • 2021-06-09
  • 2021-11-26
  • 2021-05-08
  • 2021-10-18
  • 2021-06-21
  • 2021-05-28
  • 2022-12-23
  • 2021-12-04
猜你喜欢
  • 2021-12-10
  • 2021-11-24
  • 2021-08-04
  • 2021-09-03
  • 2021-09-11
  • 2022-12-23
  • 2021-12-29
相关资源
相似解决方案