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