mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-06-05 22:02:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

use switch x := y.(type) form

Browse Source
This commit is contained in:
Jae Kwon
2015-03-22 03:29:28 -07:00
parent b25915ee41
commit 06a440d9b2
2 changed files with 8 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
consensus/reactor.go
View File

@@ -123,32 +123,24 @@ func (conR *ConsensusReactor) Receive(chId byte, peer *p2p.Peer, msgBytes []byte
switch chId {
case StateCh:
switch msg_.(type) {
switch msg := msg_.(type) {
case *NewRoundStepMessage:
msg := msg_.(*NewRoundStepMessage)
ps.ApplyNewRoundStepMessage(msg, rs)
case *CommitStepMessage:
msg := msg_.(*CommitStepMessage)
ps.ApplyCommitStepMessage(msg)
case *HasVoteMessage:
msg := msg_.(*HasVoteMessage)
ps.ApplyHasVoteMessage(msg)
default:
// Ignore unknown message
}
case DataCh:
switch msg_.(type) {
switch msg := msg_.(type) {
case *Proposal:
proposal := msg_.(*Proposal)
ps.SetHasProposal(proposal)
err = conR.conS.SetProposal(proposal)
ps.SetHasProposal(msg)
err = conR.conS.SetProposal(msg)
case *PartMessage:
msg := msg_.(*PartMessage)
if msg.Type == partTypeProposalBlock {
ps.SetHasProposalBlockPart(msg.Height, msg.Round, msg.Part.Index)
_, err = conR.conS.AddProposalBlockPart(msg.Height, msg.Round, msg.Part)
@@ -164,14 +156,13 @@ func (conR *ConsensusReactor) Receive(chId byte, peer *p2p.Peer, msgBytes []byte
}
case VoteCh:
switch msg_.(type) {
switch msg := msg_.(type) {
case *VoteMessage:
voteMessage := msg_.(*VoteMessage)
vote := voteMessage.Vote
vote := msg.Vote
if rs.Height != vote.Height {
return // Wrong height. Not necessarily a bad peer.
}
validatorIndex := voteMessage.ValidatorIndex
validatorIndex := msg.ValidatorIndex
address, _ := rs.Validators.GetByIndex(validatorIndex)
added, index, err := conR.conS.AddVote(address, vote)
if err != nil {

3
mempool/reactor.go
View File

@@ -75,9 +75,8 @@ func (memR *MempoolReactor) Receive(chId byte, src *p2p.Peer, msgBytes []byte) {
}
log.Info("MempoolReactor received message", "msg", msg_)
switch msg_.(type) {
switch msg := msg_.(type) {
case *TxMessage:
msg := msg_.(*TxMessage)
err := memR.Mempool.AddTx(msg.Tx)
if err != nil {
// Bad, seen, or conflicting tx.