grassrootseconomics/openethereum
5
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

documentation

Browse Source
This commit is contained in:
Nikolay Volf 2016-02-08 00:52:56 +03:00
parent efef36b5e8
commit 69a4349ee2
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
sync/src/chain.rs
View File

@ -1051,6 +1051,7 @@ impl ChainSync {
} }
} }
/// creates rlp to send for the tree defined by 'from' and 'to' hashes
fn create_new_hashes_rlp(chain: &BlockChainClient, from: &H256, to: &H256) -> Option<Bytes> { fn create_new_hashes_rlp(chain: &BlockChainClient, from: &H256, to: &H256) -> Option<Bytes> {
match chain.tree_route(from, to) { match chain.tree_route(from, to) {
Some(route) => { Some(route) => {
@ -1065,10 +1066,12 @@ impl ChainSync {
} }
} }
/// creates latest block rlp for the given client
fn create_latest_block_rlp(chain: &BlockChainClient) -> Bytes { fn create_latest_block_rlp(chain: &BlockChainClient) -> Bytes {
chain.block(&chain.chain_info().best_block_hash).expect("Creating latest block when there is none") chain.block(&chain.chain_info().best_block_hash).expect("Creating latest block when there is none")
} }
/// returns peer ids that have less blocks than our chain
fn get_lagging_peers(&self, io: &SyncIo) -> Vec<PeerId> { fn get_lagging_peers(&self, io: &SyncIo) -> Vec<PeerId> {
let chain = io.chain(); let chain = io.chain();
let chain_info = chain.chain_info(); let chain_info = chain.chain_info();
@ -1087,6 +1090,7 @@ impl ChainSync {
.cloned().collect::<Vec<PeerId>>() .cloned().collect::<Vec<PeerId>>()
} }
/// propagades latest block to lagging peers
fn propagade_blocks(&mut self, io: &mut SyncIo) -> usize { fn propagade_blocks(&mut self, io: &mut SyncIo) -> usize {
let updated_peers = { let updated_peers = {
let lagging_peers = self.get_lagging_peers(io); let lagging_peers = self.get_lagging_peers(io);
@ -1113,6 +1117,7 @@ impl ChainSync {
sent sent
} }
/// propagades new known hashes to all peers
fn propagade_new_hashes(&mut self, io: &mut SyncIo) -> usize { fn propagade_new_hashes(&mut self, io: &mut SyncIo) -> usize {
let updated_peers = self.get_lagging_peers(io); let updated_peers = self.get_lagging_peers(io);
let mut sent = 0; let mut sent = 0;
@ -1141,6 +1146,7 @@ impl ChainSync {
trace!(target: "sync", "Sent new hashes to peers: {:?}", peers); trace!(target: "sync", "Sent new hashes to peers: {:?}", peers);
} }
/// should be called once chain has new block, triggers the latest block propagation
pub fn chain_blocks_verified(&mut self, io: &mut SyncIo) { pub fn chain_blocks_verified(&mut self, io: &mut SyncIo) {
let peers = self.propagade_blocks(io); let peers = self.propagade_blocks(io);
trace!(target: "sync", "Sent latest block to peers: {:?}", peers); trace!(target: "sync", "Sent latest block to peers: {:?}", peers);