以太坊源码分析-同步之Syncing接口

在节点同步的过程当中，咱们常常须要执行eth.syncing来查看当前的同步状况，本篇博客带领你们看一下syncing api的源代码实现。

1

Syncing方法源代码

// Syncing returns false in case the node is currently not syncing with the network. It can be up to date or has not`

// yet received the latest block headers from its pears. In case it is synchronizing:`

// - startingBlock: block number this node started to synchronise from`

// - currentBlock:  block number this node is currently importing`

// - highestBlock:  block number of the highest block header this node has received from peers`

// - pulledStates:  number of state entries processed until now`

// - knownStates:   number of known state entries that still need to be pulled`

func (s *PublicEthereumAPI)  Syncing()  (interface{}, error)  {`

progress := s.b.Downloader().Progress()`

// Return not syncing if the synchronisation already completed`

if progress.CurrentBlock  >= progress.HighestBlock  {`

return  false,  nil`

}`

// Otherwise gather the block sync stats`

return map[string]interface{}{`

"startingBlock": hexutil.Uint64(progress.StartingBlock),`

"currentBlock": hexutil.Uint64(progress.CurrentBlock),`

"highestBlock": hexutil.Uint64(progress.HighestBlock),`

"pulledStates": hexutil.Uint64(progress.PulledStates),`

"knownStates": hexutil.Uint64(progress.KnownStates),`

},  nil`

}`

</pre>

Syncing方法的源代码很简单，注释说明也已经很清楚了。经过这段源代码咱们能够得知一下信息：

• 固然CurrentBlock大于等于HighestBlock时返回false，这也正是一般所说的同步完成以后，再执行eth.syncing()函数会返回false的缘由。

• startingBlock：开始同步的起始区块编号；

• currentBlock：当前正在导入的区块编号；

• highestBlock：经过所连接的节点得到的当前最高的区块高度；

• pulledStates：当前已经拉取的状态条目数；

• knownStates：当前已知的待拉取的总状态条目数。

2

对应的结构体代码

下面是同步信息对应的结构体的代码及注释。

1.  `// SyncProgress gives progress indications when the node is synchronising with`

2.  `// the Ethereum network.`

3.  `type SyncProgress  struct  {`

4.  `StartingBlock uint64 // Block number where sync began`

5.  `CurrentBlock uint64 // Current block number where sync is at`

6.  `HighestBlock uint64 // Highest alleged block number in the chain`

7.  `PulledStates uint64 // Number of state trie entries already downloaded`

8.  `KnownStates uint64 // Total number of state trie entries known about`

9.  `}`

</pre>

3

结构体信息计算

上面看到当执行eth.syncing返回结果信息的代码，再延伸一下看看这些数据从哪里来。进入下面Progress方法的内部实现：

progress := s.b.Downloader().Progress()

</pre>

能够看到以下代码：

1.  `// Progress retrieves the synchronisation boundaries, specifically the origin`

2.  `// block where synchronisation started at (may have failed/suspended); the block`

3.  `// or header sync is currently at; and the latest known block which the sync targets.`

4.  `//`

5.  `// In addition, during the state download phase of fast synchronisation the number`

6.  `// of processed and the total number of known states are also returned. Otherwise`

7.  `// these are zero.`

8.  `func (d *Downloader)  Progress() ethereum.SyncProgress  {`

9.  `// Lock the current stats and return the progress`

10.  `d.syncStatsLock.RLock()`

11.  `defer d.syncStatsLock.RUnlock()`

13.  `current := uint64(0)`

14.  `switch d.mode {`

15.  `case  FullSync:`

16.  `current = d.blockchain.CurrentBlock().NumberU64()`

17.  `case  FastSync:`

18.  `current = d.blockchain.CurrentFastBlock().NumberU64()`

19.  `case  LightSync:`

20.  `current = d.lightchain.CurrentHeader().Number.Uint64()`

21.  `}`

22.  `return ethereum.SyncProgress{`

23.  `StartingBlock: d.syncStatsChainOrigin,`

24.  `CurrentBlock: current,`

25.  `HighestBlock: d.syncStatsChainHeight,`

26.  `PulledStates: d.syncStatsState.processed,`

27.  `KnownStates: d.syncStatsState.processed + d.syncStatsState.pending,`

28.  `}`

29.  `}`

</pre>

从这端代码咱们能够分析得出，curren

• full模式：返回当前区块的高度；

• fast模式：返回fast区块的高度；

• light模式：返回当前的header编号；

• 而KnownStates又是由PulledStates的值加上当前处于pending装的值得到。

4

总  结

经过上面源代码分析，咱们已经能够明了的看到当咱们执行eth.sycing时返回不一样的结果信息所表明的含义。欢迎你们关注微信公众号，获取最新的相关技术分享。

内容来源：程序新视界

做者：二师兄

如下是咱们的社区介绍，欢迎各类合做、交流、学习：）