Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

TestNodePropose{,Config}

Browse Source 
This test now observes the `MsgAppResp` injected in `(*raft).advance`.

Signed-off-by: Tobias Grieger <tobias.b.grieger@gmail.com>
This commit is contained in:
Tobias Grieger 2022-09-06 09:11:15 +02:00
parent 87a9b80d7b
commit 1a81b27bed
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
raft/node_test.go
View File

@ -132,6 +132,10 @@ func TestNodeStepUnblock(t *testing.T) {
func TestNodePropose(t *testing.T) { func TestNodePropose(t *testing.T) {
var msgs []raftpb.Message var msgs []raftpb.Message
appendStep := func(r *raft, m raftpb.Message) error { appendStep := func(r *raft, m raftpb.Message) error {
t.Log(DescribeMessage(m, nil))
if m.Type == raftpb.MsgAppResp {
return nil // injected by (*raft).advance
}
msgs = append(msgs, m) msgs = append(msgs, m)
return nil return nil
} }
@ -314,6 +318,9 @@ func TestNodeReadIndexToOldLeader(t *testing.T) {
func TestNodeProposeConfig(t *testing.T) { func TestNodeProposeConfig(t *testing.T) {
var msgs []raftpb.Message var msgs []raftpb.Message
appendStep := func(r *raft, m raftpb.Message) error { appendStep := func(r *raft, m raftpb.Message) error {
if m.Type == raftpb.MsgAppResp {
return nil // injected by (*raft).advance
}
msgs = append(msgs, m) msgs = append(msgs, m)
return nil return nil
} }