Browse Source

etcdserver: fix TestSnap

Xiang Li 9 years ago
parent
commit
3451623c71
1 changed files with 2 additions and 2 deletions
  1. 2 2
      etcdserver/server_test.go

+ 2 - 2
etcdserver/server_test.go

@@ -845,7 +845,7 @@ func TestSnapshot(t *testing.T) {
 	s := raft.NewMemoryStorage()
 	s := raft.NewMemoryStorage()
 	s.Append([]raftpb.Entry{{Index: 1}})
 	s.Append([]raftpb.Entry{{Index: 1}})
 	st := mockstore.NewRecorder()
 	st := mockstore.NewRecorder()
-	p := mockstorage.NewStorageRecorder("")
+	p := mockstorage.NewStorageRecorderStream("")
 	srv := &EtcdServer{
 	srv := &EtcdServer{
 		Cfg: &ServerConfig{},
 		Cfg: &ServerConfig{},
 		r: raftNode{
 		r: raftNode{
@@ -869,7 +869,7 @@ func TestSnapshot(t *testing.T) {
 	if !reflect.DeepEqual(gaction[1], testutil.Action{Name: "SaveNoCopy"}) {
 	if !reflect.DeepEqual(gaction[1], testutil.Action{Name: "SaveNoCopy"}) {
 		t.Errorf("action = %s, want SaveNoCopy", gaction[1])
 		t.Errorf("action = %s, want SaveNoCopy", gaction[1])
 	}
 	}
-	gaction = p.Action()
+	gaction, _ = p.Wait(1)
 	if len(gaction) != 1 {
 	if len(gaction) != 1 {
 		t.Fatalf("len(action) = %d, want 1", len(gaction))
 		t.Fatalf("len(action) = %d, want 1", len(gaction))
 	}
 	}