TestLogReplication2AB中MsgHup与MsgPropose的问题


在第二个测试点中
{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 分钟后被自动关闭。不再允许新回复。