@@ -673,7 +673,7 @@ func TestClient(t *testing.T) {
673
673
SetHeartbeatInterval (reducedHeartbeatInterval ).
674
674
SetTimeout (0 ))
675
675
676
- // Assert that RTT90s are eventually >300ms .
676
+ // Assert that RTT90s are eventually >275ms .
677
677
topo := getTopologyFromClient (mt .Client )
678
678
assert .Soon (mt , func (ctx context.Context ) {
679
679
for {
@@ -686,12 +686,12 @@ func TestClient(t *testing.T) {
686
686
687
687
time .Sleep (100 * time .Millisecond )
688
688
689
- // Wait for all of the server's RTT90s to be >300ms .
689
+ // Wait for all of the server's RTT90s to be >275ms .
690
690
done := true
691
691
for _ , desc := range topo .Description ().Servers {
692
692
server , err := topo .FindServer (desc )
693
693
assert .Nil (mt , err , "FindServer error: %v" , err )
694
- if server .RTT90 () <= 300 * time .Millisecond {
694
+ if server .RTT90 () <= 275 * time .Millisecond {
695
695
done = false
696
696
}
697
697
}
@@ -701,10 +701,10 @@ func TestClient(t *testing.T) {
701
701
}
702
702
}, 10 * time .Second )
703
703
704
- // Once we've waited for the RTT90 for the servers to be >300ms , run 10 Ping operations
705
- // with a timeout of 300ms and expect that they return timeout errors.
704
+ // Once we've waited for the RTT90 for the servers to be >275ms , run 10 Ping operations
705
+ // with a timeout of 275ms and expect that they return timeout errors.
706
706
for i := 0 ; i < 10 ; i ++ {
707
- ctx , cancel = context .WithTimeout (context .Background (), 300 * time .Millisecond )
707
+ ctx , cancel = context .WithTimeout (context .Background (), 275 * time .Millisecond )
708
708
err := mt .Client .Ping (ctx , nil )
709
709
cancel ()
710
710
assert .NotNil (mt , err , "expected Ping to return an error" )
0 commit comments