(rs *cstypes.RoundState)
| 466 | } |
| 467 | |
| 468 | func (conR *Reactor) broadcastNewValidBlockMessage(rs *cstypes.RoundState) { |
| 469 | psh := rs.ProposalBlockParts.Header() |
| 470 | csMsg := &tmcons.NewValidBlock{ |
| 471 | Height: rs.Height, |
| 472 | Round: rs.Round, |
| 473 | BlockPartSetHeader: psh.ToProto(), |
| 474 | BlockParts: rs.ProposalBlockParts.BitArray().ToProto(), |
| 475 | IsCommit: rs.Step == cstypes.RoundStepCommit, |
| 476 | } |
| 477 | conR.Switch.BroadcastEnvelope(p2p.Envelope{ |
| 478 | ChannelID: StateChannel, |
| 479 | Message: csMsg, |
| 480 | }) |
| 481 | } |
| 482 | |
| 483 | // Broadcasts HasVoteMessage to peers that care. |
| 484 | func (conR *Reactor) broadcastHasVoteMessage(vote *types.Vote) { |
no test coverage detected