@@ -2689,7 +2689,7 @@ def handler(signum, frame):
|
2689 | 2689 | conn.send('ready') |
2690 | 2690 | x = conn.recv() |
2691 | 2691 | conn.send(x) |
2692 | | -conn.send_bytes(b'x'*(1024*1024)) # sending 1 MB should block |
| 2692 | +conn.send_bytes(b'x' * test_support.PIPE_MAX_SIZE) |
2693 | 2693 | |
2694 | 2694 | @unittest.skipUnless(hasattr(signal, 'SIGUSR1'), 'requires SIGUSR1') |
2695 | 2695 | def test_ignore(self): |
@@ -2708,7 +2708,8 @@ def test_ignore(self):
|
2708 | 2708 | self.assertEqual(conn.recv(), 1234) |
2709 | 2709 | time.sleep(0.1) |
2710 | 2710 | os.kill(p.pid, signal.SIGUSR1) |
2711 | | -self.assertEqual(conn.recv_bytes(), b'x'*(1024*1024)) |
| 2711 | +self.assertEqual(conn.recv_bytes(), |
| 2712 | +b'x' * test_support.PIPE_MAX_SIZE) |
2712 | 2713 | time.sleep(0.1) |
2713 | 2714 | p.join() |
2714 | 2715 | finally: |
|