在第二个测试点中
{From: 1, To: 2, MsgType: pb.MessageType_MsgHup},
{From: 1, To: 2, MsgType: pb.MessageType_MsgPropose, Entries: []*pb.Entry{{Data []byte(“somedata”)}}},
这两条消息种类不是本地消息么,其他节点发送过来的不是直接忽略么,按照wantcommit的结果是需要转发给leader吗
这是个模拟测试,通过send模拟处理消息。
按照下面代码的逻辑,只是考虑了 To
这个参数。
感觉是有问题的,考虑提pr改一下?将From设置为和To一样?
func (nw *network) send(msgs ...pb.Message) {
for len(msgs) > 0 {
m := msgs[0]
p := nw.peers[m.To]
p.Step(m)
msgs = append(msgs[1:], nw.filter(p.readMessages())...)
}
}
1 个赞
此话题已在最后回复的 1 分钟后被自动关闭。不再允许新回复。