Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 1 | from contextlib import contextmanager |
Victor Stinner | c790a53 | 2011-04-08 13:39:59 +0200 | [diff] [blame] | 2 | import datetime |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 3 | import faulthandler |
Victor Stinner | 7e32f3a | 2011-06-29 13:44:05 +0200 | [diff] [blame] | 4 | import os |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 5 | import re |
| 6 | import signal |
| 7 | import subprocess |
| 8 | import sys |
| 9 | from test import support, script_helper |
Victor Stinner | d5698cb | 2012-07-31 02:55:49 +0200 | [diff] [blame] | 10 | from test.script_helper import assert_python_ok |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 11 | import tempfile |
| 12 | import unittest |
| 13 | |
Victor Stinner | ff4cd88 | 2011-04-07 11:50:25 +0200 | [diff] [blame] | 14 | try: |
| 15 | import threading |
| 16 | HAVE_THREADS = True |
| 17 | except ImportError: |
| 18 | HAVE_THREADS = False |
| 19 | |
Victor Stinner | 44378d4 | 2011-04-01 15:37:12 +0200 | [diff] [blame] | 20 | TIMEOUT = 0.5 |
| 21 | |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 22 | try: |
| 23 | from resource import setrlimit, RLIMIT_CORE, error as resource_error |
| 24 | except ImportError: |
| 25 | prepare_subprocess = None |
| 26 | else: |
| 27 | def prepare_subprocess(): |
| 28 | # don't create core file |
| 29 | try: |
| 30 | setrlimit(RLIMIT_CORE, (0, 0)) |
| 31 | except (ValueError, resource_error): |
| 32 | pass |
| 33 | |
Victor Stinner | 301f3f0 | 2011-06-01 13:49:12 +0200 | [diff] [blame] | 34 | def expected_traceback(lineno1, lineno2, header, min_count=1): |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 35 | regex = header |
Victor Stinner | 7ad24e9 | 2011-03-31 22:35:49 +0200 | [diff] [blame] | 36 | regex += ' File "<string>", line %s in func\n' % lineno1 |
| 37 | regex += ' File "<string>", line %s in <module>' % lineno2 |
Victor Stinner | 301f3f0 | 2011-06-01 13:49:12 +0200 | [diff] [blame] | 38 | if 1 < min_count: |
| 39 | return '^' + (regex + '\n') * (min_count - 1) + regex |
| 40 | else: |
| 41 | return '^' + regex + '$' |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 42 | |
| 43 | @contextmanager |
| 44 | def temporary_filename(): |
| 45 | filename = tempfile.mktemp() |
| 46 | try: |
| 47 | yield filename |
| 48 | finally: |
| 49 | support.unlink(filename) |
| 50 | |
| 51 | class FaultHandlerTests(unittest.TestCase): |
Victor Stinner | 05585cb | 2011-03-31 13:29:56 +0200 | [diff] [blame] | 52 | def get_output(self, code, filename=None): |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 53 | """ |
| 54 | Run the specified code in Python (in a new child process) and read the |
| 55 | output from the standard error or from a file (if filename is set). |
| 56 | Return the output lines as a list. |
| 57 | |
| 58 | Strip the reference count from the standard error for Python debug |
| 59 | build, and replace "Current thread 0x00007f8d8fbd9700" by "Current |
| 60 | thread XXX". |
| 61 | """ |
| 62 | options = {} |
| 63 | if prepare_subprocess: |
| 64 | options['preexec_fn'] = prepare_subprocess |
| 65 | process = script_helper.spawn_python('-c', code, **options) |
| 66 | stdout, stderr = process.communicate() |
| 67 | exitcode = process.wait() |
Victor Stinner | 1940233 | 2011-03-31 18:15:52 +0200 | [diff] [blame] | 68 | output = support.strip_python_stderr(stdout) |
| 69 | output = output.decode('ascii', 'backslashreplace') |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 70 | if filename: |
Victor Stinner | 1940233 | 2011-03-31 18:15:52 +0200 | [diff] [blame] | 71 | self.assertEqual(output, '') |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 72 | with open(filename, "rb") as fp: |
| 73 | output = fp.read() |
Victor Stinner | 1940233 | 2011-03-31 18:15:52 +0200 | [diff] [blame] | 74 | output = output.decode('ascii', 'backslashreplace') |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 75 | output = re.sub('Current thread 0x[0-9a-f]+', |
| 76 | 'Current thread XXX', |
| 77 | output) |
Victor Stinner | 05585cb | 2011-03-31 13:29:56 +0200 | [diff] [blame] | 78 | return output.splitlines(), exitcode |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 79 | |
| 80 | def check_fatal_error(self, code, line_number, name_regex, |
Victor Stinner | 7bba62f | 2011-05-07 12:43:00 +0200 | [diff] [blame] | 81 | filename=None, all_threads=True, other_regex=None): |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 82 | """ |
| 83 | Check that the fault handler for fatal errors is enabled and check the |
| 84 | traceback from the child process output. |
| 85 | |
| 86 | Raise an error if the output doesn't match the expected format. |
| 87 | """ |
| 88 | if all_threads: |
| 89 | header = 'Current thread XXX' |
| 90 | else: |
| 91 | header = 'Traceback (most recent call first)' |
| 92 | regex = """ |
| 93 | ^Fatal Python error: {name} |
| 94 | |
| 95 | {header}: |
Vinay Sajip | 3637123 | 2012-05-06 11:28:46 +0100 | [diff] [blame] | 96 | File "<string>", line {lineno} in <module> |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 97 | """.strip() |
| 98 | regex = regex.format( |
| 99 | lineno=line_number, |
| 100 | name=name_regex, |
| 101 | header=re.escape(header)) |
Victor Stinner | f048075 | 2011-03-31 11:34:08 +0200 | [diff] [blame] | 102 | if other_regex: |
| 103 | regex += '|' + other_regex |
Ezio Melotti | 25a4045 | 2013-03-05 20:26:17 +0200 | [diff] [blame] | 104 | with support.suppress_crash_popup(): |
Ezio Melotti | e1857d9 | 2013-03-05 20:31:34 +0200 | [diff] [blame] | 105 | output, exitcode = self.get_output(code, filename) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 106 | output = '\n'.join(output) |
| 107 | self.assertRegex(output, regex) |
Victor Stinner | 05585cb | 2011-03-31 13:29:56 +0200 | [diff] [blame] | 108 | self.assertNotEqual(exitcode, 0) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 109 | |
Victor Stinner | 330426c | 2013-07-03 22:29:42 +0200 | [diff] [blame] | 110 | @unittest.skipIf(sys.platform.startswith('aix'), |
| 111 | "the first page of memory is a mapped read-only on AIX") |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 112 | def test_read_null(self): |
| 113 | self.check_fatal_error(""" |
| 114 | import faulthandler |
| 115 | faulthandler.enable() |
| 116 | faulthandler._read_null() |
| 117 | """.strip(), |
| 118 | 3, |
Victor Stinner | a8db378 | 2011-08-08 22:43:45 +0200 | [diff] [blame] | 119 | # Issue #12700: Read NULL raises SIGILL on Mac OS X Lion |
| 120 | '(?:Segmentation fault|Bus error|Illegal instruction)') |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 121 | |
| 122 | def test_sigsegv(self): |
| 123 | self.check_fatal_error(""" |
| 124 | import faulthandler |
| 125 | faulthandler.enable() |
| 126 | faulthandler._sigsegv() |
| 127 | """.strip(), |
| 128 | 3, |
| 129 | 'Segmentation fault') |
| 130 | |
Victor Stinner | d727e23 | 2011-04-01 12:13:55 +0200 | [diff] [blame] | 131 | def test_sigabrt(self): |
| 132 | self.check_fatal_error(""" |
| 133 | import faulthandler |
| 134 | faulthandler.enable() |
| 135 | faulthandler._sigabrt() |
| 136 | """.strip(), |
| 137 | 3, |
| 138 | 'Aborted') |
| 139 | |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 140 | @unittest.skipIf(sys.platform == 'win32', |
| 141 | "SIGFPE cannot be caught on Windows") |
| 142 | def test_sigfpe(self): |
| 143 | self.check_fatal_error(""" |
| 144 | import faulthandler |
| 145 | faulthandler.enable() |
| 146 | faulthandler._sigfpe() |
| 147 | """.strip(), |
| 148 | 3, |
| 149 | 'Floating point exception') |
| 150 | |
| 151 | @unittest.skipIf(not hasattr(faulthandler, '_sigbus'), |
| 152 | "need faulthandler._sigbus()") |
| 153 | def test_sigbus(self): |
| 154 | self.check_fatal_error(""" |
| 155 | import faulthandler |
| 156 | faulthandler.enable() |
| 157 | faulthandler._sigbus() |
| 158 | """.strip(), |
| 159 | 3, |
| 160 | 'Bus error') |
| 161 | |
| 162 | @unittest.skipIf(not hasattr(faulthandler, '_sigill'), |
| 163 | "need faulthandler._sigill()") |
| 164 | def test_sigill(self): |
| 165 | self.check_fatal_error(""" |
| 166 | import faulthandler |
| 167 | faulthandler.enable() |
| 168 | faulthandler._sigill() |
| 169 | """.strip(), |
| 170 | 3, |
| 171 | 'Illegal instruction') |
| 172 | |
| 173 | def test_fatal_error(self): |
| 174 | self.check_fatal_error(""" |
| 175 | import faulthandler |
| 176 | faulthandler._fatal_error(b'xyz') |
| 177 | """.strip(), |
| 178 | 2, |
| 179 | 'xyz') |
| 180 | |
Charles-François Natali | 3391e64 | 2011-09-01 23:08:21 +0200 | [diff] [blame] | 181 | @unittest.skipIf(sys.platform.startswith('openbsd') and HAVE_THREADS, |
| 182 | "Issue #12868: sigaltstack() doesn't work on " |
| 183 | "OpenBSD if Python is compiled with pthread") |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 184 | @unittest.skipIf(not hasattr(faulthandler, '_stack_overflow'), |
| 185 | 'need faulthandler._stack_overflow()') |
| 186 | def test_stack_overflow(self): |
| 187 | self.check_fatal_error(""" |
| 188 | import faulthandler |
| 189 | faulthandler.enable() |
| 190 | faulthandler._stack_overflow() |
| 191 | """.strip(), |
| 192 | 3, |
Victor Stinner | f048075 | 2011-03-31 11:34:08 +0200 | [diff] [blame] | 193 | '(?:Segmentation fault|Bus error)', |
| 194 | other_regex='unable to raise a stack overflow') |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 195 | |
| 196 | def test_gil_released(self): |
| 197 | self.check_fatal_error(""" |
| 198 | import faulthandler |
| 199 | faulthandler.enable() |
| 200 | faulthandler._read_null(True) |
| 201 | """.strip(), |
| 202 | 3, |
Victor Stinner | a8db378 | 2011-08-08 22:43:45 +0200 | [diff] [blame] | 203 | '(?:Segmentation fault|Bus error|Illegal instruction)') |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 204 | |
| 205 | def test_enable_file(self): |
| 206 | with temporary_filename() as filename: |
| 207 | self.check_fatal_error(""" |
| 208 | import faulthandler |
| 209 | output = open({filename}, 'wb') |
| 210 | faulthandler.enable(output) |
Victor Stinner | 5678539 | 2013-06-17 23:37:59 +0200 | [diff] [blame] | 211 | faulthandler._sigsegv() |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 212 | """.strip().format(filename=repr(filename)), |
| 213 | 4, |
Victor Stinner | 5678539 | 2013-06-17 23:37:59 +0200 | [diff] [blame] | 214 | 'Segmentation fault', |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 215 | filename=filename) |
| 216 | |
Victor Stinner | 7bba62f | 2011-05-07 12:43:00 +0200 | [diff] [blame] | 217 | def test_enable_single_thread(self): |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 218 | self.check_fatal_error(""" |
| 219 | import faulthandler |
Victor Stinner | 7bba62f | 2011-05-07 12:43:00 +0200 | [diff] [blame] | 220 | faulthandler.enable(all_threads=False) |
Victor Stinner | 5678539 | 2013-06-17 23:37:59 +0200 | [diff] [blame] | 221 | faulthandler._sigsegv() |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 222 | """.strip(), |
| 223 | 3, |
Victor Stinner | 5678539 | 2013-06-17 23:37:59 +0200 | [diff] [blame] | 224 | 'Segmentation fault', |
Victor Stinner | 7bba62f | 2011-05-07 12:43:00 +0200 | [diff] [blame] | 225 | all_threads=False) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 226 | |
| 227 | def test_disable(self): |
| 228 | code = """ |
| 229 | import faulthandler |
| 230 | faulthandler.enable() |
| 231 | faulthandler.disable() |
Victor Stinner | 5678539 | 2013-06-17 23:37:59 +0200 | [diff] [blame] | 232 | faulthandler._sigsegv() |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 233 | """.strip() |
| 234 | not_expected = 'Fatal Python error' |
Ezio Melotti | 25a4045 | 2013-03-05 20:26:17 +0200 | [diff] [blame] | 235 | with support.suppress_crash_popup(): |
| 236 | stderr, exitcode = self.get_output(code) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 237 | stder = '\n'.join(stderr) |
| 238 | self.assertTrue(not_expected not in stderr, |
| 239 | "%r is present in %r" % (not_expected, stderr)) |
Victor Stinner | 05585cb | 2011-03-31 13:29:56 +0200 | [diff] [blame] | 240 | self.assertNotEqual(exitcode, 0) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 241 | |
| 242 | def test_is_enabled(self): |
Victor Stinner | 7e32f3a | 2011-06-29 13:44:05 +0200 | [diff] [blame] | 243 | orig_stderr = sys.stderr |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 244 | try: |
Victor Stinner | 7e32f3a | 2011-06-29 13:44:05 +0200 | [diff] [blame] | 245 | # regrtest may replace sys.stderr by io.StringIO object, but |
| 246 | # faulthandler.enable() requires that sys.stderr has a fileno() |
| 247 | # method |
Victor Stinner | 7248850 | 2011-06-29 23:24:31 +0200 | [diff] [blame] | 248 | sys.stderr = sys.__stderr__ |
Victor Stinner | 7e32f3a | 2011-06-29 13:44:05 +0200 | [diff] [blame] | 249 | |
| 250 | was_enabled = faulthandler.is_enabled() |
| 251 | try: |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 252 | faulthandler.enable() |
Victor Stinner | 7e32f3a | 2011-06-29 13:44:05 +0200 | [diff] [blame] | 253 | self.assertTrue(faulthandler.is_enabled()) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 254 | faulthandler.disable() |
Victor Stinner | 7e32f3a | 2011-06-29 13:44:05 +0200 | [diff] [blame] | 255 | self.assertFalse(faulthandler.is_enabled()) |
| 256 | finally: |
| 257 | if was_enabled: |
| 258 | faulthandler.enable() |
| 259 | else: |
| 260 | faulthandler.disable() |
| 261 | finally: |
| 262 | sys.stderr = orig_stderr |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 263 | |
Victor Stinner | d5698cb | 2012-07-31 02:55:49 +0200 | [diff] [blame] | 264 | def test_disabled_by_default(self): |
| 265 | # By default, the module should be disabled |
| 266 | code = "import faulthandler; print(faulthandler.is_enabled())" |
| 267 | rc, stdout, stderr = assert_python_ok("-c", code) |
| 268 | stdout = (stdout + stderr).strip() |
| 269 | self.assertEqual(stdout, b"False") |
| 270 | |
| 271 | def test_sys_xoptions(self): |
| 272 | # Test python -X faulthandler |
| 273 | code = "import faulthandler; print(faulthandler.is_enabled())" |
| 274 | rc, stdout, stderr = assert_python_ok("-X", "faulthandler", "-c", code) |
| 275 | stdout = (stdout + stderr).strip() |
| 276 | self.assertEqual(stdout, b"True") |
| 277 | |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 278 | def check_dump_traceback(self, filename): |
| 279 | """ |
| 280 | Explicitly call dump_traceback() function and check its output. |
| 281 | Raise an error if the output doesn't match the expected format. |
| 282 | """ |
| 283 | code = """ |
| 284 | import faulthandler |
| 285 | |
| 286 | def funcB(): |
| 287 | if {has_filename}: |
| 288 | with open({filename}, "wb") as fp: |
Victor Stinner | 7bba62f | 2011-05-07 12:43:00 +0200 | [diff] [blame] | 289 | faulthandler.dump_traceback(fp, all_threads=False) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 290 | else: |
Victor Stinner | 7bba62f | 2011-05-07 12:43:00 +0200 | [diff] [blame] | 291 | faulthandler.dump_traceback(all_threads=False) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 292 | |
| 293 | def funcA(): |
| 294 | funcB() |
| 295 | |
| 296 | funcA() |
| 297 | """.strip() |
| 298 | code = code.format( |
| 299 | filename=repr(filename), |
| 300 | has_filename=bool(filename), |
| 301 | ) |
| 302 | if filename: |
| 303 | lineno = 6 |
| 304 | else: |
| 305 | lineno = 8 |
| 306 | expected = [ |
| 307 | 'Traceback (most recent call first):', |
| 308 | ' File "<string>", line %s in funcB' % lineno, |
| 309 | ' File "<string>", line 11 in funcA', |
| 310 | ' File "<string>", line 13 in <module>' |
| 311 | ] |
Victor Stinner | 05585cb | 2011-03-31 13:29:56 +0200 | [diff] [blame] | 312 | trace, exitcode = self.get_output(code, filename) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 313 | self.assertEqual(trace, expected) |
Victor Stinner | 05585cb | 2011-03-31 13:29:56 +0200 | [diff] [blame] | 314 | self.assertEqual(exitcode, 0) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 315 | |
| 316 | def test_dump_traceback(self): |
| 317 | self.check_dump_traceback(None) |
Victor Stinner | 1940233 | 2011-03-31 18:15:52 +0200 | [diff] [blame] | 318 | |
| 319 | def test_dump_traceback_file(self): |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 320 | with temporary_filename() as filename: |
| 321 | self.check_dump_traceback(filename) |
| 322 | |
Victor Stinner | 53386d8 | 2012-08-01 19:45:34 +0200 | [diff] [blame] | 323 | def test_truncate(self): |
| 324 | maxlen = 500 |
| 325 | func_name = 'x' * (maxlen + 50) |
| 326 | truncated = 'x' * maxlen + '...' |
| 327 | code = """ |
| 328 | import faulthandler |
| 329 | |
| 330 | def {func_name}(): |
| 331 | faulthandler.dump_traceback(all_threads=False) |
| 332 | |
| 333 | {func_name}() |
| 334 | """.strip() |
| 335 | code = code.format( |
| 336 | func_name=func_name, |
| 337 | ) |
| 338 | expected = [ |
| 339 | 'Traceback (most recent call first):', |
| 340 | ' File "<string>", line 4 in %s' % truncated, |
| 341 | ' File "<string>", line 6 in <module>' |
| 342 | ] |
| 343 | trace, exitcode = self.get_output(code) |
| 344 | self.assertEqual(trace, expected) |
| 345 | self.assertEqual(exitcode, 0) |
| 346 | |
Victor Stinner | ff4cd88 | 2011-04-07 11:50:25 +0200 | [diff] [blame] | 347 | @unittest.skipIf(not HAVE_THREADS, 'need threads') |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 348 | def check_dump_traceback_threads(self, filename): |
| 349 | """ |
| 350 | Call explicitly dump_traceback(all_threads=True) and check the output. |
| 351 | Raise an error if the output doesn't match the expected format. |
| 352 | """ |
| 353 | code = """ |
| 354 | import faulthandler |
| 355 | from threading import Thread, Event |
| 356 | import time |
| 357 | |
| 358 | def dump(): |
| 359 | if {filename}: |
| 360 | with open({filename}, "wb") as fp: |
| 361 | faulthandler.dump_traceback(fp, all_threads=True) |
| 362 | else: |
| 363 | faulthandler.dump_traceback(all_threads=True) |
| 364 | |
| 365 | class Waiter(Thread): |
| 366 | # avoid blocking if the main thread raises an exception. |
| 367 | daemon = True |
| 368 | |
| 369 | def __init__(self): |
| 370 | Thread.__init__(self) |
| 371 | self.running = Event() |
| 372 | self.stop = Event() |
| 373 | |
| 374 | def run(self): |
| 375 | self.running.set() |
| 376 | self.stop.wait() |
| 377 | |
| 378 | waiter = Waiter() |
| 379 | waiter.start() |
| 380 | waiter.running.wait() |
| 381 | dump() |
| 382 | waiter.stop.set() |
| 383 | waiter.join() |
| 384 | """.strip() |
| 385 | code = code.format(filename=repr(filename)) |
Victor Stinner | 05585cb | 2011-03-31 13:29:56 +0200 | [diff] [blame] | 386 | output, exitcode = self.get_output(code, filename) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 387 | output = '\n'.join(output) |
| 388 | if filename: |
| 389 | lineno = 8 |
| 390 | else: |
| 391 | lineno = 10 |
| 392 | regex = """ |
| 393 | ^Thread 0x[0-9a-f]+: |
Victor Stinner | 1b3241f | 2011-04-03 18:41:22 +0200 | [diff] [blame] | 394 | (?: File ".*threading.py", line [0-9]+ in [_a-z]+ |
| 395 | ){{1,3}} File "<string>", line 23 in run |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 396 | File ".*threading.py", line [0-9]+ in _bootstrap_inner |
| 397 | File ".*threading.py", line [0-9]+ in _bootstrap |
| 398 | |
| 399 | Current thread XXX: |
| 400 | File "<string>", line {lineno} in dump |
| 401 | File "<string>", line 28 in <module>$ |
| 402 | """.strip() |
| 403 | regex = regex.format(lineno=lineno) |
| 404 | self.assertRegex(output, regex) |
Victor Stinner | 05585cb | 2011-03-31 13:29:56 +0200 | [diff] [blame] | 405 | self.assertEqual(exitcode, 0) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 406 | |
| 407 | def test_dump_traceback_threads(self): |
| 408 | self.check_dump_traceback_threads(None) |
Victor Stinner | 1940233 | 2011-03-31 18:15:52 +0200 | [diff] [blame] | 409 | |
| 410 | def test_dump_traceback_threads_file(self): |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 411 | with temporary_filename() as filename: |
| 412 | self.check_dump_traceback_threads(filename) |
| 413 | |
Georg Brandl | deb92b5 | 2012-09-22 08:58:55 +0200 | [diff] [blame] | 414 | def _check_dump_traceback_later(self, repeat, cancel, filename, loops): |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 415 | """ |
| 416 | Check how many times the traceback is written in timeout x 2.5 seconds, |
| 417 | or timeout x 3.5 seconds if cancel is True: 1, 2 or 3 times depending |
| 418 | on repeat and cancel options. |
| 419 | |
| 420 | Raise an error if the output doesn't match the expect format. |
| 421 | """ |
Victor Stinner | c790a53 | 2011-04-08 13:39:59 +0200 | [diff] [blame] | 422 | timeout_str = str(datetime.timedelta(seconds=TIMEOUT)) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 423 | code = """ |
| 424 | import faulthandler |
| 425 | import time |
| 426 | |
Victor Stinner | de10f40 | 2011-04-08 12:57:06 +0200 | [diff] [blame] | 427 | def func(timeout, repeat, cancel, file, loops): |
| 428 | for loop in range(loops): |
Georg Brandl | deb92b5 | 2012-09-22 08:58:55 +0200 | [diff] [blame] | 429 | faulthandler.dump_traceback_later(timeout, repeat=repeat, file=file) |
Victor Stinner | de10f40 | 2011-04-08 12:57:06 +0200 | [diff] [blame] | 430 | if cancel: |
Georg Brandl | deb92b5 | 2012-09-22 08:58:55 +0200 | [diff] [blame] | 431 | faulthandler.cancel_dump_traceback_later() |
Victor Stinner | 301f3f0 | 2011-06-01 13:49:12 +0200 | [diff] [blame] | 432 | time.sleep(timeout * 5) |
Georg Brandl | deb92b5 | 2012-09-22 08:58:55 +0200 | [diff] [blame] | 433 | faulthandler.cancel_dump_traceback_later() |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 434 | |
Victor Stinner | 44378d4 | 2011-04-01 15:37:12 +0200 | [diff] [blame] | 435 | timeout = {timeout} |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 436 | repeat = {repeat} |
| 437 | cancel = {cancel} |
Victor Stinner | de10f40 | 2011-04-08 12:57:06 +0200 | [diff] [blame] | 438 | loops = {loops} |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 439 | if {has_filename}: |
| 440 | file = open({filename}, "wb") |
| 441 | else: |
| 442 | file = None |
Victor Stinner | de10f40 | 2011-04-08 12:57:06 +0200 | [diff] [blame] | 443 | func(timeout, repeat, cancel, file, loops) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 444 | if file is not None: |
| 445 | file.close() |
| 446 | """.strip() |
| 447 | code = code.format( |
Victor Stinner | de10f40 | 2011-04-08 12:57:06 +0200 | [diff] [blame] | 448 | timeout=TIMEOUT, |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 449 | repeat=repeat, |
| 450 | cancel=cancel, |
Victor Stinner | de10f40 | 2011-04-08 12:57:06 +0200 | [diff] [blame] | 451 | loops=loops, |
| 452 | has_filename=bool(filename), |
| 453 | filename=repr(filename), |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 454 | ) |
Victor Stinner | 05585cb | 2011-03-31 13:29:56 +0200 | [diff] [blame] | 455 | trace, exitcode = self.get_output(code, filename) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 456 | trace = '\n'.join(trace) |
| 457 | |
Victor Stinner | f77ccc6 | 2011-04-03 18:45:42 +0200 | [diff] [blame] | 458 | if not cancel: |
Victor Stinner | de10f40 | 2011-04-08 12:57:06 +0200 | [diff] [blame] | 459 | count = loops |
Victor Stinner | f77ccc6 | 2011-04-03 18:45:42 +0200 | [diff] [blame] | 460 | if repeat: |
Victor Stinner | de10f40 | 2011-04-08 12:57:06 +0200 | [diff] [blame] | 461 | count *= 2 |
Victor Stinner | c790a53 | 2011-04-08 13:39:59 +0200 | [diff] [blame] | 462 | header = r'Timeout \(%s\)!\nThread 0x[0-9a-f]+:\n' % timeout_str |
Victor Stinner | 301f3f0 | 2011-06-01 13:49:12 +0200 | [diff] [blame] | 463 | regex = expected_traceback(9, 20, header, min_count=count) |
Victor Stinner | f77ccc6 | 2011-04-03 18:45:42 +0200 | [diff] [blame] | 464 | self.assertRegex(trace, regex) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 465 | else: |
Victor Stinner | f77ccc6 | 2011-04-03 18:45:42 +0200 | [diff] [blame] | 466 | self.assertEqual(trace, '') |
Victor Stinner | 05585cb | 2011-03-31 13:29:56 +0200 | [diff] [blame] | 467 | self.assertEqual(exitcode, 0) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 468 | |
Georg Brandl | deb92b5 | 2012-09-22 08:58:55 +0200 | [diff] [blame] | 469 | @unittest.skipIf(not hasattr(faulthandler, 'dump_traceback_later'), |
| 470 | 'need faulthandler.dump_traceback_later()') |
| 471 | def check_dump_traceback_later(self, repeat=False, cancel=False, |
Victor Stinner | de10f40 | 2011-04-08 12:57:06 +0200 | [diff] [blame] | 472 | file=False, twice=False): |
| 473 | if twice: |
| 474 | loops = 2 |
| 475 | else: |
| 476 | loops = 1 |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 477 | if file: |
| 478 | with temporary_filename() as filename: |
Georg Brandl | deb92b5 | 2012-09-22 08:58:55 +0200 | [diff] [blame] | 479 | self._check_dump_traceback_later(repeat, cancel, |
Victor Stinner | de10f40 | 2011-04-08 12:57:06 +0200 | [diff] [blame] | 480 | filename, loops) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 481 | else: |
Georg Brandl | deb92b5 | 2012-09-22 08:58:55 +0200 | [diff] [blame] | 482 | self._check_dump_traceback_later(repeat, cancel, None, loops) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 483 | |
Georg Brandl | deb92b5 | 2012-09-22 08:58:55 +0200 | [diff] [blame] | 484 | def test_dump_traceback_later(self): |
| 485 | self.check_dump_traceback_later() |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 486 | |
Georg Brandl | deb92b5 | 2012-09-22 08:58:55 +0200 | [diff] [blame] | 487 | def test_dump_traceback_later_repeat(self): |
| 488 | self.check_dump_traceback_later(repeat=True) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 489 | |
Georg Brandl | deb92b5 | 2012-09-22 08:58:55 +0200 | [diff] [blame] | 490 | def test_dump_traceback_later_cancel(self): |
| 491 | self.check_dump_traceback_later(cancel=True) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 492 | |
Georg Brandl | deb92b5 | 2012-09-22 08:58:55 +0200 | [diff] [blame] | 493 | def test_dump_traceback_later_file(self): |
| 494 | self.check_dump_traceback_later(file=True) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 495 | |
Georg Brandl | deb92b5 | 2012-09-22 08:58:55 +0200 | [diff] [blame] | 496 | def test_dump_traceback_later_twice(self): |
| 497 | self.check_dump_traceback_later(twice=True) |
Victor Stinner | de10f40 | 2011-04-08 12:57:06 +0200 | [diff] [blame] | 498 | |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 499 | @unittest.skipIf(not hasattr(faulthandler, "register"), |
| 500 | "need faulthandler.register") |
Victor Stinner | a01ca12 | 2011-04-01 12:56:17 +0200 | [diff] [blame] | 501 | def check_register(self, filename=False, all_threads=False, |
Victor Stinner | a9a9dab | 2011-07-13 23:39:53 +0200 | [diff] [blame] | 502 | unregister=False, chain=False): |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 503 | """ |
| 504 | Register a handler displaying the traceback on a user signal. Raise the |
| 505 | signal and check the written traceback. |
| 506 | |
Victor Stinner | a9a9dab | 2011-07-13 23:39:53 +0200 | [diff] [blame] | 507 | If chain is True, check that the previous signal handler is called. |
| 508 | |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 509 | Raise an error if the output doesn't match the expected format. |
| 510 | """ |
Victor Stinner | a01ca12 | 2011-04-01 12:56:17 +0200 | [diff] [blame] | 511 | signum = signal.SIGUSR1 |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 512 | code = """ |
| 513 | import faulthandler |
| 514 | import os |
| 515 | import signal |
Victor Stinner | a9a9dab | 2011-07-13 23:39:53 +0200 | [diff] [blame] | 516 | import sys |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 517 | |
| 518 | def func(signum): |
| 519 | os.kill(os.getpid(), signum) |
| 520 | |
Victor Stinner | a9a9dab | 2011-07-13 23:39:53 +0200 | [diff] [blame] | 521 | def handler(signum, frame): |
| 522 | handler.called = True |
| 523 | handler.called = False |
| 524 | |
| 525 | exitcode = 0 |
Victor Stinner | a01ca12 | 2011-04-01 12:56:17 +0200 | [diff] [blame] | 526 | signum = {signum} |
| 527 | unregister = {unregister} |
Victor Stinner | a9a9dab | 2011-07-13 23:39:53 +0200 | [diff] [blame] | 528 | chain = {chain} |
| 529 | |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 530 | if {has_filename}: |
| 531 | file = open({filename}, "wb") |
| 532 | else: |
| 533 | file = None |
Victor Stinner | a9a9dab | 2011-07-13 23:39:53 +0200 | [diff] [blame] | 534 | if chain: |
| 535 | signal.signal(signum, handler) |
| 536 | faulthandler.register(signum, file=file, |
| 537 | all_threads={all_threads}, chain={chain}) |
Victor Stinner | a01ca12 | 2011-04-01 12:56:17 +0200 | [diff] [blame] | 538 | if unregister: |
| 539 | faulthandler.unregister(signum) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 540 | func(signum) |
Victor Stinner | a9a9dab | 2011-07-13 23:39:53 +0200 | [diff] [blame] | 541 | if chain and not handler.called: |
| 542 | if file is not None: |
| 543 | output = file |
| 544 | else: |
| 545 | output = sys.stderr |
| 546 | print("Error: signal handler not called!", file=output) |
| 547 | exitcode = 1 |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 548 | if file is not None: |
| 549 | file.close() |
Victor Stinner | a9a9dab | 2011-07-13 23:39:53 +0200 | [diff] [blame] | 550 | sys.exit(exitcode) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 551 | """.strip() |
| 552 | code = code.format( |
| 553 | filename=repr(filename), |
| 554 | has_filename=bool(filename), |
| 555 | all_threads=all_threads, |
Victor Stinner | a01ca12 | 2011-04-01 12:56:17 +0200 | [diff] [blame] | 556 | signum=signum, |
| 557 | unregister=unregister, |
Victor Stinner | a9a9dab | 2011-07-13 23:39:53 +0200 | [diff] [blame] | 558 | chain=chain, |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 559 | ) |
Victor Stinner | 05585cb | 2011-03-31 13:29:56 +0200 | [diff] [blame] | 560 | trace, exitcode = self.get_output(code, filename) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 561 | trace = '\n'.join(trace) |
Victor Stinner | a01ca12 | 2011-04-01 12:56:17 +0200 | [diff] [blame] | 562 | if not unregister: |
| 563 | if all_threads: |
| 564 | regex = 'Current thread XXX:\n' |
| 565 | else: |
| 566 | regex = 'Traceback \(most recent call first\):\n' |
Victor Stinner | a9a9dab | 2011-07-13 23:39:53 +0200 | [diff] [blame] | 567 | regex = expected_traceback(7, 28, regex) |
Victor Stinner | a01ca12 | 2011-04-01 12:56:17 +0200 | [diff] [blame] | 568 | self.assertRegex(trace, regex) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 569 | else: |
Victor Stinner | a01ca12 | 2011-04-01 12:56:17 +0200 | [diff] [blame] | 570 | self.assertEqual(trace, '') |
| 571 | if unregister: |
| 572 | self.assertNotEqual(exitcode, 0) |
| 573 | else: |
| 574 | self.assertEqual(exitcode, 0) |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 575 | |
| 576 | def test_register(self): |
| 577 | self.check_register() |
| 578 | |
Victor Stinner | a01ca12 | 2011-04-01 12:56:17 +0200 | [diff] [blame] | 579 | def test_unregister(self): |
| 580 | self.check_register(unregister=True) |
| 581 | |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 582 | def test_register_file(self): |
| 583 | with temporary_filename() as filename: |
| 584 | self.check_register(filename=filename) |
| 585 | |
| 586 | def test_register_threads(self): |
| 587 | self.check_register(all_threads=True) |
| 588 | |
Victor Stinner | a9a9dab | 2011-07-13 23:39:53 +0200 | [diff] [blame] | 589 | def test_register_chain(self): |
| 590 | self.check_register(chain=True) |
| 591 | |
Victor Stinner | 024e37a | 2011-03-31 01:31:06 +0200 | [diff] [blame] | 592 | |
| 593 | def test_main(): |
| 594 | support.run_unittest(FaultHandlerTests) |
| 595 | |
| 596 | if __name__ == "__main__": |
| 597 | test_main() |