1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
# Copyright 2018-2019 Gentoo Authors
# Distributed under the terms of the GNU General Public License v2
import os
import subprocess
import portage
from portage.const import PORTAGE_PYM_PATH
from portage.tests import TestCase
class WakeupFdSigchldTestCase(TestCase):
def testWakeupFdSigchld(self):
"""
This is expected to trigger a bunch of messages like the following
unless the fix for bug 655656 works as intended:
Exception ignored when trying to write to the signal wakeup fd:
BlockingIOError: [Errno 11] Resource temporarily unavailable
"""
script = """
import os
import signal
import sys
import portage
# In order to avoid potential interference with API consumers, wakeup
# fd handling is enabled only when portage._interal_caller is True.
portage._internal_caller = True
from portage.util.futures import asyncio
loop = asyncio._wrap_loop()
# Cause the loop to register a child watcher.
proc = loop.run_until_complete(asyncio.create_subprocess_exec('sleep', '0', loop=loop))
loop.run_until_complete(proc.wait())
for i in range(8192):
os.kill(portage.getpid(), signal.SIGCHLD)
# Verify that the child watcher still works correctly
# (this will hang if it doesn't).
proc = loop.run_until_complete(asyncio.create_subprocess_exec('sleep', '0', loop=loop))
loop.run_until_complete(proc.wait())
loop.close()
sys.stdout.write('success')
sys.exit(os.EX_OK)
"""
pythonpath = os.environ.get("PYTHONPATH", "").strip().split(":")
if not pythonpath or pythonpath[0] != PORTAGE_PYM_PATH:
pythonpath = [PORTAGE_PYM_PATH] + pythonpath
pythonpath = ":".join(filter(None, pythonpath))
proc = subprocess.Popen(
[portage._python_interpreter, "-c", script],
stdout=subprocess.PIPE,
stderr=subprocess.STDOUT,
env=dict(os.environ, PYTHONPATH=pythonpath),
)
out, err = proc.communicate()
try:
self.assertEqual(out[:100], b"success")
except Exception:
portage.writemsg(
"".join(
f"{line}\n"
for line in out.decode(errors="replace").splitlines()[:50]
),
noiselevel=-1,
)
raise
self.assertEqual(proc.wait(), os.EX_OK)
|
GitWeb