Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Expand conditions for recognizing main process #252

Open
wants to merge 6 commits into
base: master
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
2 changes: 1 addition & 1 deletion py/_process/forkedfunc.py
Original file line number Diff line number Diff line change
Expand Up @@ -107,7 +107,7 @@ def _removetemp(self):
self.tempdir.remove()

def __del__(self):
if self.pid is not None: # only clean up in main process
if getattr(self, "pid", None) is not None: # only clean up in main process
self._removetemp()


Expand Down
14 changes: 14 additions & 0 deletions testing/process/test_forkedfunc.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
import gc

import pytest
import py, sys, os

Expand All @@ -16,6 +18,18 @@ def test_tempdir_gets_gc_collected(monkeypatch):
assert ff.tempdir.check()
ff.__del__()
assert not ff.tempdir.check()

def test_no_second_exception_if_fork_fails(monkeypatch):
def raise_oserror():
# BlockingIOError on py3k
raise OSError("Resource temporarily unavailable")
monkeypatch.setattr(os, "fork", raise_oserror)
with pytest.raises(OSError, match="Resource temporarily unavailable"):
py.process.ForkedFunc(boxf1)
# Make sure the ForkedFunc is collected
# That may be triggered by refcounting while exiting the with statement,
# but gc.collect() should work even on PyPy.
gc.collect()

def test_basic_forkedfunc():
result = py.process.ForkedFunc(boxf1).waitfinish()
Expand Down