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

Merge pull request #3061 from yichengq/fix-stream-test

Browse Source 
rafthttp: fix TestStream uses outdated stream
This commit is contained in:
Yicheng Qin 2015-06-29 11:15:29 -07:00
commit bd84e678e6
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
rafthttp/stream_test.go
View File

@ -274,11 +274,8 @@ func TestStream(t *testing.T) {
h.sw = sw h.sw = sw
picker := mustNewURLPicker(t, []string{srv.URL}) picker := mustNewURLPicker(t, []string{srv.URL})
sr := startStreamReader(&http.Transport{}, picker, tt.t, types.ID(1), types.ID(2), types.ID(1), newPeerStatus(types.ID(1)), recvc, propc, nil, 1) sr := startStreamReader(&http.Transport{}, picker, tt.t, types.ID(1), types.ID(2), types.ID(1), newPeerStatus(types.ID(1)), recvc, propc, nil, tt.term)
defer sr.stop() defer sr.stop()
if tt.t == streamTypeMsgApp {
sr.updateMsgAppTerm(tt.term)
}
// wait for stream to work // wait for stream to work
var writec chan<- raftpb.Message var writec chan<- raftpb.Message
for { for {