fluencelabs/tendermint
1
0
Fork 0
mirror of https://github.com/fluencelabs/tendermint synced 2025-06-13 05:11:21 +00:00
Code Issues Projects Releases Wiki Activity

Conform to go-wire new TypeByte behavior for broadcasts

Browse Source
This commit is contained in:
Jae Kwon
2015-12-21 15:18:16 -08:00
parent b9519391c2
commit d87667a0c2
3 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
blockchain/reactor.go
View File

@ -253,12 +253,12 @@ FOR_LOOP:
} }
func (bcR *BlockchainReactor) BroadcastStatusResponse() error { func (bcR *BlockchainReactor) BroadcastStatusResponse() error {
bcR.Switch.Broadcast(BlockchainChannel, &bcStatusResponseMessage{bcR.store.Height()}) bcR.Switch.Broadcast(BlockchainChannel, struct{ BlockchainMessage }{&bcStatusResponseMessage{bcR.store.Height()}})
return nil return nil
} }
func (bcR *BlockchainReactor) BroadcastStatusRequest() error { func (bcR *BlockchainReactor) BroadcastStatusRequest() error {
bcR.Switch.Broadcast(BlockchainChannel, &bcStatusRequestMessage{bcR.store.Height()}) bcR.Switch.Broadcast(BlockchainChannel, struct{ BlockchainMessage }{&bcStatusRequestMessage{bcR.store.Height()}})
return nil return nil
} }

6
consensus/reactor.go
View File

@ -249,10 +249,10 @@ func (conR *ConsensusReactor) broadcastNewRoundStep(rs *RoundState) {
nrsMsg, csMsg := makeRoundStepMessages(rs) nrsMsg, csMsg := makeRoundStepMessages(rs)
if nrsMsg != nil { if nrsMsg != nil {
conR.Switch.Broadcast(StateChannel, nrsMsg) conR.Switch.Broadcast(StateChannel, struct{ ConsensusMessage }{nrsMsg})
} }
if csMsg != nil { if csMsg != nil {
conR.Switch.Broadcast(StateChannel, csMsg) conR.Switch.Broadcast(StateChannel, struct{ ConsensusMessage }{csMsg})
} }
} }
@ -264,7 +264,7 @@ func (conR *ConsensusReactor) broadcastHasVoteMessage(vote *types.Vote, index in
Type: vote.Type, Type: vote.Type,
Index: index, Index: index,
} }
conR.Switch.Broadcast(StateChannel, msg) conR.Switch.Broadcast(StateChannel, struct{ ConsensusMessage }{msg})
/* /*
// TODO: Make this broadcast more selective. // TODO: Make this broadcast more selective.
for _, peer := range conR.Switch.Peers().List() { for _, peer := range conR.Switch.Peers().List() {

2
consensus/state.go
View File

@ -1245,7 +1245,7 @@ func (cs *ConsensusState) tryAddVote(valIndex int, vote *types.Vote, peerKey str
VoteA: *errDupe.VoteA, VoteA: *errDupe.VoteA,
VoteB: *errDupe.VoteB, VoteB: *errDupe.VoteB,
} }
cs.mempool.BroadcastTx(evidenceTx) // shouldn't need to check returned err cs.mempool.BroadcastTx(struct{???}{evidenceTx}) // shouldn't need to check returned err
*/ */
return err return err
} else { } else {