@@ -651,13 +651,17 @@ def check_forkserver_death(self, signum):
|
651 | 651 | from multiprocessing.forkserver import _forkserver |
652 | 652 | _forkserver.ensure_running() |
653 | 653 | |
| 654 | +# First process sleeps 500 ms |
| 655 | +delay = 0.5 |
| 656 | + |
654 | 657 | evt = self.Event() |
655 | | -proc = self.Process(target=self._sleep_and_set_event, args=(evt, 1.0)) |
| 658 | +proc = self.Process(target=self._sleep_and_set_event, args=(evt, delay)) |
656 | 659 | proc.start() |
657 | 660 | |
658 | 661 | pid = _forkserver._forkserver_pid |
659 | 662 | os.kill(pid, signum) |
660 | | -time.sleep(1.0) # give it time to die |
| 663 | +# give time to the fork server to die and time to proc to complete |
| 664 | +time.sleep(delay * 2.0) |
661 | 665 | |
662 | 666 | evt2 = self.Event() |
663 | 667 | proc2 = self.Process(target=self._sleep_and_set_event, args=(evt2,)) |
|