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

handle unknown packet

Browse Source
This commit is contained in:
Robert Habermeier 2016-11-04 17:35:31 +01:00
parent 5d011fe577
commit 90a2c37977
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
sync/src/light/mod.rs
View File

@ -148,22 +148,22 @@ impl Chain {
let mut stream = RlpStream::new_list(6); let mut stream = RlpStream::new_list(6);
stream stream
.begin_list(2) .begin_list(2)
.append("protocolVersion") .append(&"protocolVersion")
.append(&PROTOCOL_VERSION) .append(&PROTOCOL_VERSION)
.begin_list(2) .begin_list(2)
.append("networkId") .append(&"networkId")
.append(&(self.mainnet as u8)) .append(&(self.mainnet as u8))
.begin_list(2) .begin_list(2)
.append("headTd") .append(&"headTd")
.append(&chain_info.total_difficulty) .append(&chain_info.total_difficulty)
.begin_list(2) .begin_list(2)
.append("headHash") .append(&"headHash")
.append(&chain_info.best_block_hash) .append(&chain_info.best_block_hash)
.begin_list(2) .begin_list(2)
.append("headNum") .append(&"headNum")
.append(&chain_info.best_block_number) .append(&chain_info.best_block_number)
.begin_list(2) .begin_list(2)
.append("genesisHash") .append(&"genesisHash")
.append(&self.genesis_hash); .append(&self.genesis_hash);
io.send(peer, packet::STATUS, stream.out()) io.send(peer, packet::STATUS, stream.out())
@ -315,6 +315,11 @@ impl NetworkProtocolHandler for Chain {
packet::GET_TRANSACTION_PROOFS => self.get_transaction_proofs(peer, io, rlp), packet::GET_TRANSACTION_PROOFS => self.get_transaction_proofs(peer, io, rlp),
packet::TRANSACTION_PROOFS => self.transaction_proofs(peer, io, rlp), packet::TRANSACTION_PROOFS => self.transaction_proofs(peer, io, rlp),
other => {
debug!(target: "les", "Disconnecting peer {} on unexpected packet {}", peer, other);
io.disconnect_peer(*peer);
}
} }
} }
@ -330,7 +335,6 @@ impl NetworkProtocolHandler for Chain {
match timer { match timer {
TIMEOUT => { TIMEOUT => {
// broadcast transactions to peers. // broadcast transactions to peers.
// update buffer flow.
} }
_ => warn!(target: "les", "received timeout on unknown token {}", timer), _ => warn!(target: "les", "received timeout on unknown token {}", timer),
} }