Reduce flakiness of test_keepalive.

Author: aaugustin

tests/asyncio/test_connection.py

@@ -1051,14 +1051,14 @@ async def test_pong_unsupported_type(self):
     async def test_keepalive(self, getrandbits):
         """keepalive sends pings at ping_interval and measures latency."""
         getrandbits.side_effect = itertools.count(1918987876)
-        self.connection.ping_interval = 3 * MS
+        self.connection.ping_interval = 4 * MS
         self.connection.start_keepalive()
         self.assertIsNotNone(self.connection.keepalive_task)
         self.assertEqual(self.connection.latency, 0)
-        # 3 ms: keepalive() sends a ping frame.
-        # 3.x ms: a pong frame is received.
-        await asyncio.sleep(5 * MS)
-        # 5 ms: check that the ping frame was sent.
+        # 4 ms: keepalive() sends a ping frame.
+        # 4.x ms: a pong frame is received.
+        await asyncio.sleep(6 * MS)
+        # 6 ms: check that the ping frame was sent.
         await self.assertFrameSent(Frame(PING, b"rand"))
         self.assertGreater(self.connection.latency, 0)
         self.assertLess(self.connection.latency, MS)

tests/sync/test_connection.py

@@ -787,14 +787,14 @@ def test_pong_unsupported_type(self):
     def test_keepalive(self, getrandbits):
         """keepalive sends pings at ping_interval and measures latency."""
         getrandbits.side_effect = itertools.count(1918987876)
-        self.connection.ping_interval = 3 * MS
+        self.connection.ping_interval = 4 * MS
         self.connection.start_keepalive()
         self.assertIsNotNone(self.connection.keepalive_thread)
         self.assertEqual(self.connection.latency, 0)
-        # 3 ms: keepalive() sends a ping frame.
-        # 3.x ms: a pong frame is received.
-        time.sleep(5 * MS)
-        # 5 ms: check that the ping frame was sent.
+        # 4 ms: keepalive() sends a ping frame.
+        # 4.x ms: a pong frame is received.
+        time.sleep(6 * MS)
+        # 6 ms: check that the ping frame was sent.
         self.assertFrameSent(Frame(PING, b"rand"))
         self.assertGreater(self.connection.latency, 0)
         self.assertLess(self.connection.latency, MS)

tests/trio/test_connection.py

@@ -978,14 +978,14 @@ def keepalive_task_is_running(self):
     async def test_keepalive(self, getrandbits):
         """keepalive sends pings at ping_interval and measures latency."""
         getrandbits.side_effect = itertools.count(1918987876)
-        self.connection.ping_interval = 3 * MS
+        self.connection.ping_interval = 4 * MS
         self.connection.start_keepalive()
         self.assertTrue(self.keepalive_task_is_running())
         self.assertEqual(self.connection.latency, 0)
-        # 3 ms: keepalive() sends a ping frame.
-        # 3.x ms: a pong frame is received.
-        await trio.sleep(5 * MS)
-        # 5 ms: check that the ping frame was sent.
+        # 4 ms: keepalive() sends a ping frame.
+        # 4.x ms: a pong frame is received.
+        await trio.sleep(6 * MS)
+        # 6 ms: check that the ping frame was sent.
         await self.assertFrameSent(Frame(PING, b"rand"))
         self.assertGreater(self.connection.latency, 0)
         self.assertLess(self.connection.latency, MS)