|
@@ -146,10 +146,9 @@ func TestTransportErrorc(t *testing.T) {
|
|
|
}
|
|
}
|
|
|
tr.peers[1].send(raftpb.Message{})
|
|
tr.peers[1].send(raftpb.Message{})
|
|
|
|
|
|
|
|
- testutil.WaitSchedule()
|
|
|
|
|
select {
|
|
select {
|
|
|
case <-errorc:
|
|
case <-errorc:
|
|
|
- default:
|
|
|
|
|
|
|
+ case <-time.After(1 * time.Second):
|
|
|
t.Fatalf("cannot receive error from errorc")
|
|
t.Fatalf("cannot receive error from errorc")
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|