diff --git a/rafthttp/functional_test.go b/rafthttp/functional_test.go index ae348564e..f2c80ffaf 100644 --- a/rafthttp/functional_test.go +++ b/rafthttp/functional_test.go @@ -131,8 +131,8 @@ func TestSendMessageWhenStreamIsBroken(t *testing.T) { n++ tr.Send([]raftpb.Message{{Type: raftpb.MsgHeartbeat, From: 1, To: 2, Term: 1, Commit: 3}}) case <-recvc: - if n > 10 { - t.Errorf("disconnection time = %dms, want < 10ms", n) + if n > 50 { + t.Errorf("disconnection time = %dms, want < 50ms", n) } return }