BTCD源码阅读笔记-netsync

// 该方法以map的方式将peer信息存储到SyncManager的peerStates里,
// 存储的内容包括该peer是否是合适的候选者，初始化该peer请求过的txns和blocks.

sm.peerStates[peer] = &peerSyncState{
        syncCandidate:   isSyncCandidate,
        requestedTxns:   make(map[chainhash.Hash]struct{}),
        requestedBlocks: make(map[chainhash.Hash]struct{}),
}


// 最后如果SyncManager的同步peer还没有，就开启同步:

if isSyncCandidate && sm.syncPeer == nil {
        sm.startSync()
}



// startSync方法从管理的peers里筛选block height高于目前已知最长链高度的peer
// 随机挑选一个发送getblock消息，并更新同步节点相关信息
// 如果存在nextcheckpoint,那么采用headersFirst模式，先发送getheaders消息，获取headers。

由btcd/server.go 下的 serverPeer struct的OnVersion方法调用，也就是当有version信息交换时。

// 该方法核心是通过SyncManger绑定内存池 (mempool.TxPool)的ProcessTransaction方法来处理收到的tx
acceptedTxs, err := sm.txMemPool.ProcessTransaction(tmsg.tx, true, true, mempool.Tag(peer.ID()))

// 如果处理出错，则向相应的peer发送reject消息
peer.PushRejectMsg(wire.CmdTx, code, reason, txHash, false)

// 如果成功处理，那么通过SyncManager绑定的peerNotifier接口来处理相应的新的tx加到内存池后应该做的事
sm.peerNotifier.AnnounceNewTransactions(acceptedTxs)

// 在btcd/server.go 下的 server struct的实现了AnnounceNewTransactions方法
// 该方法核心是转发交易消息
s.relayTransactions(txns)

由btcd/server.go 下的 serverPeer struct的OnTx方法调用，也就是当peer接收到tx消息时触发。

// 该方法核心是是调用chain.ProcessBlock来处理block. 如果失败了，返回reject消息
_, isOrphan, err := sm.chain.ProcessBlock(bmsg.block, behaviorFlags)



// 如果该block是Orphan区块，那么向该peer请求orphan区块的之前区块 (直到自己已知的)
orphanRoot := sm.chain.GetOrphanRoot(blockHash)
locator, err := sm.chain.LatestBlockLocator()
if err != nil {
        log.Warnf("Failed to get block locator for the "+
                "latest block: %v", err)
} else {
        peer.PushGetBlocksMsg(locator, orphanRoot)
}


// 除此之外，如果SyncManger处在headers-first mode下，有相应的处理方式 (TODO)

由btcd/server.go 下的 serverPeer struct的OnBlock方法调用，也就是当peer接收到block消息时触发。

该方法的主要处理逻辑:
1. 如果inv里有block信息，则先更新该peer最新的block相关消息
2. 处理inv消息里的每个Inventory Vector:
   1.加到该节点请求的队列requestQueue
   2.如果是MSG_BLOCK,则检查是不是我们已知的orphan, 如果是，则向节点请求orphan相关的父区块;
   3.当处理完InvVect里的最后一个MSG_BLOCK,则请求更多的Block，直到peer已知最新的
3. 对于处在请求队列requestQueue上的每个InvVect进行处理，构造getdata请求

由btcd/server.go 下的 serverPeer struct的OnInv方法调用，也就是当peer接收到inv消息时触发。

该方法定义了接收到返回的headers消息时如何处理.

主要逻辑如下:
首先检查返回的headers确保每个都能连上之前的header(检查逻辑TODO).

如果headers里有checkpoint header,那么去获取上次checkpoint之后的所有block
如果没有，那么继续发送getheaders请求来获取接下来的checkpoint之前的新的headers

// TODO 这里的header first mode的处理逻辑，和checkpoint等逻辑还需整理才能理清

由btcd/server.go 下的 serverPeer struct的OnHeaders方法调用，也就是当peer接收到headers消息时触发。

该方法做一些清理工作，包括删除存储的节点状态。
如果该节点是同步节点，那么更新同步的节点（重新找寻同步的节点）。

由btcd/server.go 下的 server struct的peerDoneHandler方法调用，用来处理节点断开