summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorChristian Heimes <christian@cheimes.de>2007-12-24 08:52:31 (GMT)
committerChristian Heimes <christian@cheimes.de>2007-12-24 08:52:31 (GMT)
commit5fb7c2ad0b59b670898c8b1622ddc37331b5cb9e (patch)
treeea76cdd3ad8729a67920f7bdb0feee56a1600007
parent81f1130908d0bccdaa701887676688e1ca3bc723 (diff)
downloadcpython-5fb7c2ad0b59b670898c8b1622ddc37331b5cb9e.zip
cpython-5fb7c2ad0b59b670898c8b1622ddc37331b5cb9e.tar.gz
cpython-5fb7c2ad0b59b670898c8b1622ddc37331b5cb9e.tar.bz2
Merged revisions 59565-59594 via svnmerge from
svn+ssh://pythondev@svn.python.org/python/trunk ........ r59568 | facundo.batista | 2007-12-19 13:53:01 +0100 (Wed, 19 Dec 2007) | 3 lines Some minor cleanups. Thanks Mark Dickinson. ........ r59573 | raymond.hettinger | 2007-12-19 19:13:31 +0100 (Wed, 19 Dec 2007) | 1 line Fix issue 1661: Flags argument silently ignored in re functions with compiled regexes. ........ r59574 | guido.van.rossum | 2007-12-19 20:41:06 +0100 (Wed, 19 Dec 2007) | 7 lines Patch #1583 by Adam Olsen. This adds signal.set_wakeup_fd(fd) which sets a file descriptor to which a zero byte will be written whenever a C exception handler runs. I added a simple C API as well, PySignal_SetWakeupFd(fd). ........ r59575 | raymond.hettinger | 2007-12-19 23:14:34 +0100 (Wed, 19 Dec 2007) | 1 line Bigger range for non-extended opargs. ........ r59576 | guido.van.rossum | 2007-12-19 23:51:13 +0100 (Wed, 19 Dec 2007) | 5 lines Patch #1549 by Thomas Herve. This changes the rules for when __hash__ is inherited slightly, by allowing it to be inherited when one or more of __lt__, __le__, __gt__, __ge__ are overridden, as long as __eq__ and __ne__ aren't. ........ r59577 | raymond.hettinger | 2007-12-20 02:25:05 +0100 (Thu, 20 Dec 2007) | 1 line Add comments ........ r59578 | brett.cannon | 2007-12-20 11:09:52 +0100 (Thu, 20 Dec 2007) | 3 lines Add tests for the warnings module; specifically formatwarning and showwarning. Still need tests for warn_explicit and simplefilter. ........ r59582 | guido.van.rossum | 2007-12-20 18:28:10 +0100 (Thu, 20 Dec 2007) | 2 lines Patch #1672 by Joseph Armbruster. Use tempdir() to get a temporary directory. ........ r59584 | georg.brandl | 2007-12-20 22:03:02 +0100 (Thu, 20 Dec 2007) | 2 lines Fix refleak introduced in r59576. ........ r59586 | guido.van.rossum | 2007-12-21 00:48:28 +0100 (Fri, 21 Dec 2007) | 4 lines Improve performance of built-in any()/all() by avoiding PyIter_Next() -- using a trick found in ifilter(). Feel free to backport to 2.5. ........ r59591 | andrew.kuchling | 2007-12-22 18:27:02 +0100 (Sat, 22 Dec 2007) | 1 line Add item ........
-rw-r--r--Doc/c-api/exceptions.rst10
-rw-r--r--Doc/library/signal.rst14
-rw-r--r--Doc/whatsnew/2.6.rst28
-rw-r--r--Include/pyerrors.h3
-rw-r--r--Lib/decimal.py53
-rw-r--r--Lib/re.py2
-rw-r--r--Lib/test/test_re.py8
-rw-r--r--Lib/test/test_richcmp.py62
-rw-r--r--Lib/test/test_signal.py49
-rw-r--r--Lib/test/test_subprocess.py2
-rw-r--r--Lib/test/test_warnings.py33
-rw-r--r--Modules/signalmodule.c53
-rw-r--r--Python/bltinmodule.c36
-rw-r--r--Python/compile.c8
14 files changed, 307 insertions, 54 deletions
diff --git a/Doc/c-api/exceptions.rst b/Doc/c-api/exceptions.rst
index 2148463..9413762 100644
--- a/Doc/c-api/exceptions.rst
+++ b/Doc/c-api/exceptions.rst
@@ -355,6 +355,16 @@ in various ways. There is a separate error indicator for each thread.
.. % thread.interrupt_main() (used from IDLE), so it's still needed.
+.. cfunction:: int PySignal_SetWakeupFd(int fd)
+
+ This utility function specifies a file descriptor to which a ``'\0'`` byte will
+ be written whenever a signal is received. It returns the previous such file
+ descriptor. The value ``-1`` disables the feature; this is the initial state.
+ This is equivalent to :func:`signal.set_wakeup_fd` in Python, but without any
+ error checking. *fd* should be a valid file descriptor. The function should
+ only be called from the main thread.
+
+
.. cfunction:: PyObject* PyErr_NewException(char *name, PyObject *base, PyObject *dict)
This utility function creates and returns a new exception object. The *name*
diff --git a/Doc/library/signal.rst b/Doc/library/signal.rst
index d3c498d..920752b 100644
--- a/Doc/library/signal.rst
+++ b/Doc/library/signal.rst
@@ -110,6 +110,20 @@ The :mod:`signal` module defines the following functions:
:manpage:`signal(2)`.)
+.. function:: set_wakeup_fd(fd)
+
+ Set the wakeup fd to *fd*. When a signal is received, a ``'\0'`` byte is
+ written to the fd. This can be used by a library to wakeup a poll or select
+ call, allowing the signal to be fully processed.
+
+ The old wakeup fd is returned. *fd* must be non-blocking. It is up to the
+ library to remove any bytes before calling poll or select again.
+
+ When threads are enabled, this function can only be called from the main thread;
+ attempting to call it from other threads will cause a :exc:`ValueError`
+ exception to be raised.
+
+
.. function:: signal(signalnum, handler)
Set the handler for signal *signalnum* to the function *handler*. *handler* can
diff --git a/Doc/whatsnew/2.6.rst b/Doc/whatsnew/2.6.rst
index e5a8d22..b29cb7b 100644
--- a/Doc/whatsnew/2.6.rst
+++ b/Doc/whatsnew/2.6.rst
@@ -147,15 +147,16 @@ for processing the documentation.
The input format is reStructured Text,
a markup commonly used in the Python community that supports
custom extensions and directives. Sphinx concentrates
-on its HTML output, producing attractively styled
-and modern HTML. (XXX finish this -- mention new search feature)
+on HTML output, producing attractively styled
+and modern HTML, but printed output is still supported through
+conversion to LaTeX as an output format.
.. seealso::
`Docutils <http://docutils.sf.net>`__: The fundamental
reStructured Text parser and toolset.
- `Documenting Python <XXX>`__: Describes how to write for
+ `Documenting Python <http://docs.python.org/dev/documenting/>`__: Describes how to write for
Python's documentation.
@@ -839,6 +840,27 @@ complete list of changes, or look through the CVS logs for all the details.
* The :mod:`sets` module has been deprecated; it's better to
use the built-in :class:`set` and :class:`frozenset` types.
+* Integrating signal handling with GUI handling event loops
+ like those used by Tkinter or GTk+ has long been a problem; most
+ software ends up polling, waking up every fraction of a second. Thi
+ The :mod:`signal` module can now make this more efficient.
+ Calling ``signal.set_wakeup_fd(fd)`` sets a file descriptor
+ to be used; when a signal is received, a byte is written to that
+ file descriptor. There's also a C-level function,
+ :cfunc:`PySignal_SetWakeupFd`, for setting the descriptor.
+
+ Event loops will use this by opening a pipe to create two descriptors,
+ one for reading and one for writing. The writeable descriptor
+ will be passed to :func:`set_wakeup_fd`, and the readable descriptor
+ will be added to the list of descriptors monitored by the event loop via
+ :cfunc:`select` or :cfunc:`poll`.
+ On receiving a signal, a byte will be written and the main event loop
+ will be woken up, without the need to poll.
+
+ Contributed by Adam Olsen.
+
+ .. % Patch 1583
+
* The :mod:`smtplib` module now supports SMTP over SSL thanks to the
addition of the :class:`SMTP_SSL` class. This class supports an
interface identical to the existing :class:`SMTP` class. Both
diff --git a/Include/pyerrors.h b/Include/pyerrors.h
index b499778..ecbb059 100644
--- a/Include/pyerrors.h
+++ b/Include/pyerrors.h
@@ -227,6 +227,9 @@ PyAPI_FUNC(int) PyErr_WarnExplicit(PyObject *, const char *,
PyAPI_FUNC(int) PyErr_CheckSignals(void);
PyAPI_FUNC(void) PyErr_SetInterrupt(void);
+/* In signalmodule.c */
+int PySignal_SetWakeupFd(int fd);
+
/* Support for adding program text to SyntaxErrors */
PyAPI_FUNC(void) PyErr_SyntaxLocation(const char *, int);
PyAPI_FUNC(PyObject *) PyErr_ProgramText(const char *, int);
diff --git a/Lib/decimal.py b/Lib/decimal.py
index b25f6e6..54e8cb4 100644
--- a/Lib/decimal.py
+++ b/Lib/decimal.py
@@ -184,7 +184,6 @@ class Clamped(DecimalException):
number of zero digits are appended to the coefficient ("fold-down").
"""
-
class InvalidOperation(DecimalException):
"""An invalid operation was performed.
@@ -210,14 +209,10 @@ class InvalidOperation(DecimalException):
"""
def handle(self, context, *args):
if args:
- if args[0] == 1: # sNaN, must drop 's' but keep diagnostics
- ans = _dec_from_triple(args[1]._sign, args[1]._int, 'n', True)
- return ans._fix_nan(context)
- elif args[0] == 2:
- return _dec_from_triple(args[1], args[2], 'n', True)
+ ans = _dec_from_triple(args[0]._sign, args[0]._int, 'n', True)
+ return ans._fix_nan(context)
return NaN
-
class ConversionSyntax(InvalidOperation):
"""Trying to convert badly formed string.
@@ -277,7 +272,6 @@ class Inexact(DecimalException):
The inexact signal may be tested (or trapped) to determine if a given
operation (or sequence of operations) was inexact.
"""
- pass
class InvalidContext(InvalidOperation):
"""Invalid context. Unknown rounding, for example.
@@ -304,7 +298,6 @@ class Rounded(DecimalException):
The rounded signal may be tested (or trapped) to determine if a given
operation (or sequence of operations) caused a loss of precision.
"""
- pass
class Subnormal(DecimalException):
"""Exponent < Emin before rounding.
@@ -316,7 +309,6 @@ class Subnormal(DecimalException):
The subnormal signal may be tested (or trapped) to determine if a given
or operation (or sequence of operations) yielded a subnormal result.
"""
- pass
class Overflow(Inexact, Rounded):
"""Numerical overflow.
@@ -338,7 +330,7 @@ class Overflow(Inexact, Rounded):
the result is the same as for round-down if the sign of the intermediate
result is 0, or is [1,inf] otherwise. In all cases, Inexact and Rounded
will also be raised.
- """
+ """
def handle(self, context, sign, *args):
if context.rounding in (ROUND_HALF_UP, ROUND_HALF_EVEN,
@@ -662,7 +654,7 @@ class Decimal(_numbers.Real, _numbers.Inexact):
"""Returns whether the number is not actually one.
0 if a number
- 1 if NaN (it could be a normal quiet NaN or a phantom one)
+ 1 if NaN
2 if sNaN
"""
if self._is_special:
@@ -708,10 +700,10 @@ class Decimal(_numbers.Real, _numbers.Inexact):
if self_is_nan == 2:
return context._raise_error(InvalidOperation, 'sNaN',
- 1, self)
+ self)
if other_is_nan == 2:
return context._raise_error(InvalidOperation, 'sNaN',
- 1, other)
+ other)
if self_is_nan:
return self._fix_nan(context)
@@ -922,7 +914,7 @@ class Decimal(_numbers.Real, _numbers.Inexact):
if not self:
# -Decimal('0') is Decimal('0'), not Decimal('-0')
- ans = self.copy_sign(Dec_0)
+ ans = self.copy_abs()
else:
ans = self.copy_negate()
@@ -942,7 +934,7 @@ class Decimal(_numbers.Real, _numbers.Inexact):
if not self:
# + (-0) = 0
- ans = self.copy_sign(Dec_0)
+ ans = self.copy_abs()
else:
ans = Decimal(self)
@@ -1465,9 +1457,6 @@ class Decimal(_numbers.Real, _numbers.Inexact):
context - context used.
"""
- if context is None:
- context = getcontext()
-
if self._is_special:
if self._isnan():
# decapitate payload if necessary
@@ -1631,11 +1620,9 @@ class Decimal(_numbers.Real, _numbers.Inexact):
if context is None:
context = getcontext()
if self._exp == 'N':
- return context._raise_error(InvalidOperation, 'sNaN',
- 1, self)
+ return context._raise_error(InvalidOperation, 'sNaN', self)
if other._exp == 'N':
- return context._raise_error(InvalidOperation, 'sNaN',
- 1, other)
+ return context._raise_error(InvalidOperation, 'sNaN', other)
if self._exp == 'n':
product = self
elif other._exp == 'n':
@@ -1678,13 +1665,13 @@ class Decimal(_numbers.Real, _numbers.Inexact):
if self_is_nan or other_is_nan or modulo_is_nan:
if self_is_nan == 2:
return context._raise_error(InvalidOperation, 'sNaN',
- 1, self)
+ self)
if other_is_nan == 2:
return context._raise_error(InvalidOperation, 'sNaN',
- 1, other)
+ other)
if modulo_is_nan == 2:
return context._raise_error(InvalidOperation, 'sNaN',
- 1, modulo)
+ modulo)
if self_is_nan:
return self._fix_nan(context)
if other_is_nan:
@@ -2555,16 +2542,16 @@ class Decimal(_numbers.Real, _numbers.Inexact):
other_is_nan = other._isnan()
if self_is_nan == 2:
return context._raise_error(InvalidOperation, 'sNaN',
- 1, self)
+ self)
if other_is_nan == 2:
return context._raise_error(InvalidOperation, 'sNaN',
- 1, other)
+ other)
if self_is_nan:
return context._raise_error(InvalidOperation, 'NaN in compare_signal',
- 1, self)
+ self)
if other_is_nan:
return context._raise_error(InvalidOperation, 'NaN in compare_signal',
- 1, other)
+ other)
return self.compare(other, context=context)
def compare_total(self, other):
@@ -3208,8 +3195,8 @@ class Decimal(_numbers.Real, _numbers.Inexact):
"""Returns an indication of the class of self.
The class is one of the following strings:
- -sNaN
- -NaN
+ sNaN
+ NaN
-Infinity
-Normal
-Subnormal
@@ -5173,8 +5160,6 @@ NaN = Decimal('NaN')
Dec_0 = Decimal(0)
Dec_p1 = Decimal(1)
Dec_n1 = Decimal(-1)
-Dec_p2 = Decimal(2)
-Dec_n2 = Decimal(-2)
# Infsign[sign] is infinity w/ that sign
Infsign = (Inf, negInf)
diff --git a/Lib/re.py b/Lib/re.py
index 4c5622b..1e0c468 100644
--- a/Lib/re.py
+++ b/Lib/re.py
@@ -224,6 +224,8 @@ def _compile(*key):
return p
pattern, flags = key
if isinstance(pattern, _pattern_type):
+ if flags:
+ raise ValueError('Cannot process flags argument with a compiled pattern')
return pattern
if not sre_compile.isstring(pattern):
raise TypeError("first argument must be string or compiled pattern")
diff --git a/Lib/test/test_re.py b/Lib/test/test_re.py
index f935e1d..88fecbf 100644
--- a/Lib/test/test_re.py
+++ b/Lib/test/test_re.py
@@ -111,6 +111,14 @@ class ReTests(unittest.TestCase):
# self.assertEqual(z, y)
# self.assertEqual(type(z), type(y))
+ def test_bug_1661(self):
+ # Verify that flags do not get silently ignored with compiled patterns
+ pattern = re.compile('.')
+ self.assertRaises(ValueError, re.match, pattern, 'A', re.I)
+ self.assertRaises(ValueError, re.search, pattern, 'A', re.I)
+ self.assertRaises(ValueError, re.findall, pattern, 'A', re.I)
+ self.assertRaises(ValueError, re.compile, pattern, re.I)
+
def test_sub_template_numeric_escape(self):
# bug 776311 and friends
self.assertEqual(re.sub('x', r'\0', 'x'), '\0')
diff --git a/Lib/test/test_richcmp.py b/Lib/test/test_richcmp.py
index efe6923..3f97ece 100644
--- a/Lib/test/test_richcmp.py
+++ b/Lib/test/test_richcmp.py
@@ -85,6 +85,35 @@ class Vector:
raise ValueError("Cannot compare vectors of different length")
return other
+
+class SimpleOrder(object):
+ """
+ A simple class that defines order but not full comparison.
+ """
+
+ def __init__(self, value):
+ self.value = value
+
+ def __lt__(self, other):
+ if not isinstance(other, SimpleOrder):
+ return True
+ return self.value < other.value
+
+ def __gt__(self, other):
+ if not isinstance(other, SimpleOrder):
+ return False
+ return self.value > other.value
+
+
+class DumbEqualityWithoutHash(object):
+ """
+ A class that define __eq__, but no __hash__: it shouldn't be hashable.
+ """
+
+ def __eq__(self, other):
+ return False
+
+
opmap = {
"lt": (lambda a,b: a< b, operator.lt, operator.__lt__),
"le": (lambda a,b: a<=b, operator.le, operator.__le__),
@@ -330,8 +359,39 @@ class ListTest(unittest.TestCase):
for op in opmap["lt"]:
self.assertIs(op(x, y), True)
+
+class HashableTest(unittest.TestCase):
+ """
+ Test hashability of classes with rich operators defined.
+ """
+
+ def test_simpleOrderHashable(self):
+ """
+ A class that only defines __gt__ and/or __lt__ should be hashable.
+ """
+ a = SimpleOrder(1)
+ b = SimpleOrder(2)
+ self.assert_(a < b)
+ self.assert_(b > a)
+ self.assert_(a.__hash__ is not None)
+
+ def test_notHashableException(self):
+ """
+ If a class is not hashable, it should raise a TypeError with an
+ understandable message.
+ """
+ a = DumbEqualityWithoutHash()
+ try:
+ hash(a)
+ except TypeError as e:
+ self.assertEquals(str(e),
+ "unhashable type: 'DumbEqualityWithoutHash'")
+ else:
+ raise test_support.TestFailed("Should not be here")
+
+
def test_main():
- test_support.run_unittest(VectorTest, NumberTest, MiscTest, DictTest, ListTest)
+ test_support.run_unittest(VectorTest, NumberTest, MiscTest, DictTest, ListTest, HashableTest)
if __name__ == "__main__":
test_main()
diff --git a/Lib/test/test_signal.py b/Lib/test/test_signal.py
index c1df51e..80a0bb2 100644
--- a/Lib/test/test_signal.py
+++ b/Lib/test/test_signal.py
@@ -166,12 +166,59 @@ class BasicSignalTests(unittest.TestCase):
self.assertRaises(TypeError, signal.signal,
signal.SIGUSR1, None)
+class WakeupSignalTests(unittest.TestCase):
+ TIMEOUT_FULL = 10
+ TIMEOUT_HALF = 5
+
+ def test_wakeup_fd_early(self):
+ import select
+
+ signal.alarm(1)
+ before_time = time.time()
+ # We attempt to get a signal during the sleep,
+ # before select is called
+ time.sleep(self.TIMEOUT_FULL)
+ mid_time = time.time()
+ self.assert_(mid_time - before_time < self.TIMEOUT_HALF)
+ select.select([self.read], [], [], self.TIMEOUT_FULL)
+ after_time = time.time()
+ self.assert_(after_time - mid_time < self.TIMEOUT_HALF)
+
+ def test_wakeup_fd_during(self):
+ import select
+
+ signal.alarm(1)
+ before_time = time.time()
+ # We attempt to get a signal during the select call
+ self.assertRaises(select.error, select.select,
+ [self.read], [], [], self.TIMEOUT_FULL)
+ after_time = time.time()
+ self.assert_(after_time - before_time < self.TIMEOUT_HALF)
+
+ def setUp(self):
+ import fcntl
+
+ self.alrm = signal.signal(signal.SIGALRM, lambda x,y:None)
+ self.read, self.write = os.pipe()
+ flags = fcntl.fcntl(self.write, fcntl.F_GETFL, 0)
+ flags = flags | os.O_NONBLOCK
+ fcntl.fcntl(self.write, fcntl.F_SETFL, flags)
+ self.old_wakeup = signal.set_wakeup_fd(self.write)
+
+ def tearDown(self):
+ signal.set_wakeup_fd(self.old_wakeup)
+ os.close(self.read)
+ os.close(self.write)
+ signal.signal(signal.SIGALRM, self.alrm)
+
+
def test_main():
if sys.platform[:3] in ('win', 'os2'):
raise test_support.TestSkipped("Can't test signal on %s" % \
sys.platform)
- test_support.run_unittest(BasicSignalTests, InterProcessSignalTests)
+ test_support.run_unittest(BasicSignalTests, InterProcessSignalTests,
+ WakeupSignalTests)
if __name__ == "__main__":
diff --git a/Lib/test/test_subprocess.py b/Lib/test/test_subprocess.py
index 806791b..a46bc38 100644
--- a/Lib/test/test_subprocess.py
+++ b/Lib/test/test_subprocess.py
@@ -242,7 +242,7 @@ class ProcessTestCase(unittest.TestCase):
self.assertEquals(rc, 2)
def test_cwd(self):
- tmpdir = os.getenv("TEMP", "/tmp")
+ tmpdir = tempfile.gettempdir()
# We cannot use os.path.realpath to canonicalize the path,
# since it doesn't expand Tru64 {memb} strings. See bug 1063571.
cwd = os.getcwd()
diff --git a/Lib/test/test_warnings.py b/Lib/test/test_warnings.py
index 6889e3f..8206202 100644
--- a/Lib/test/test_warnings.py
+++ b/Lib/test/test_warnings.py
@@ -1,5 +1,7 @@
import warnings
+import linecache
import os
+from io import StringIO
import sys
import unittest
from test import test_support
@@ -36,6 +38,8 @@ class TestModule(unittest.TestCase):
self.assert_(w.category is category)
def test_filtering(self):
+ # Test filterwarnings().
+ # Implicitly also tests resetwarnings().
with test_support.catch_warning() as w:
warnings.filterwarnings("error", "", Warning, "", 0)
self.assertRaises(UserWarning, warnings.warn, 'convert to error')
@@ -97,6 +101,33 @@ class TestModule(unittest.TestCase):
self.assertEqual(os.path.basename(w.filename), "sys")
+class WarningsDisplayTests(unittest.TestCase):
+
+ def test_formatwarning(self):
+ message = "msg"
+ category = Warning
+ file_name = os.path.splitext(warning_tests.__file__)[0] + '.py'
+ line_num = 3
+ file_line = linecache.getline(file_name, line_num).strip()
+ expect = "%s:%s: %s: %s\n %s\n" % (file_name, line_num, category.__name__,
+ message, file_line)
+ self.failUnlessEqual(warnings.formatwarning(message, category,
+ file_name, line_num),
+ expect)
+
+ def test_showwarning(self):
+ file_name = os.path.splitext(warning_tests.__file__)[0] + '.py'
+ line_num = 3
+ expected_file_line = linecache.getline(file_name, line_num).strip()
+ message = 'msg'
+ category = Warning
+ file_object = StringIO()
+ expect = warnings.formatwarning(message, category, file_name, line_num)
+ warnings.showwarning(message, category, file_name, line_num,
+ file_object)
+ self.failUnlessEqual(file_object.getvalue(), expect)
+
+
def test_main(verbose=None):
# Obscure hack so that this test passes after reloads or repeated calls
# to test_main (regrtest -R).
@@ -106,7 +137,7 @@ def test_main(verbose=None):
del warning_tests.__warningregistry__
if hasattr(sys, '__warningregistry__'):
del sys.__warningregistry__
- test_support.run_unittest(TestModule)
+ test_support.run_unittest(TestModule, WarningsDisplayTests)
if __name__ == "__main__":
test_main(verbose=True)
diff --git a/Modules/signalmodule.c b/Modules/signalmodule.c
index 76c8198..fbb7b4f 100644
--- a/Modules/signalmodule.c
+++ b/Modules/signalmodule.c
@@ -12,6 +12,8 @@
#include <signal.h>
+#include <sys/stat.h>
+
#ifndef SIG_ERR
#define SIG_ERR ((PyOS_sighandler_t)(-1))
#endif
@@ -75,6 +77,8 @@ static struct {
PyObject *func;
} Handlers[NSIG];
+static sig_atomic_t wakeup_fd = -1;
+
/* Speed up sigcheck() when none tripped */
static volatile sig_atomic_t is_tripped = 0;
@@ -128,6 +132,8 @@ signal_handler(int sig_num)
cleared in PyErr_CheckSignals() before .tripped. */
is_tripped = 1;
Py_AddPendingCall(checksignals_witharg, NULL);
+ if (wakeup_fd != -1)
+ write(wakeup_fd, "\0", 1);
#ifdef WITH_THREAD
}
#endif
@@ -267,6 +273,50 @@ None -- if an unknown handler is in effect\n\
anything else -- the callable Python object used as a handler");
+static PyObject *
+signal_set_wakeup_fd(PyObject *self, PyObject *args)
+{
+ struct stat buf;
+ int fd, old_fd;
+ if (!PyArg_ParseTuple(args, "i:set_wakeup_fd", &fd))
+ return NULL;
+#ifdef WITH_THREAD
+ if (PyThread_get_thread_ident() != main_thread) {
+ PyErr_SetString(PyExc_ValueError,
+ "set_wakeup_fd only works in main thread");
+ return NULL;
+ }
+#endif
+ if (fd != -1 && fstat(fd, &buf) != 0) {
+ PyErr_SetString(PyExc_ValueError, "invalid fd");
+ return NULL;
+ }
+ old_fd = wakeup_fd;
+ wakeup_fd = fd;
+ return PyLong_FromLong(old_fd);
+}
+
+PyDoc_STRVAR(set_wakeup_fd_doc,
+"set_wakeup_fd(fd) -> fd\n\
+\n\
+Sets the fd to be written to (with '\\0') when a signal\n\
+comes in. A library can use this to wakeup select or poll.\n\
+The previous fd is returned.\n\
+\n\
+The fd must be non-blocking.");
+
+/* C API for the same, without all the error checking */
+int
+PySignal_SetWakeupFd(int fd)
+{
+ int old_fd = wakeup_fd;
+ if (fd < 0)
+ fd = -1;
+ wakeup_fd = fd;
+ return old_fd;
+}
+
+
/* List of functions defined in the module */
static PyMethodDef signal_methods[] = {
#ifdef HAVE_ALARM
@@ -274,11 +324,12 @@ static PyMethodDef signal_methods[] = {
#endif
{"signal", signal_signal, METH_VARARGS, signal_doc},
{"getsignal", signal_getsignal, METH_VARARGS, getsignal_doc},
+ {"set_wakeup_fd", signal_set_wakeup_fd, METH_VARARGS, set_wakeup_fd_doc},
#ifdef HAVE_PAUSE
{"pause", (PyCFunction)signal_pause,
METH_NOARGS,pause_doc},
#endif
- {"default_int_handler", signal_default_int_handler,
+ {"default_int_handler", signal_default_int_handler,
METH_VARARGS, default_int_handler_doc},
{NULL, NULL} /* sentinel */
};
diff --git a/Python/bltinmodule.c b/Python/bltinmodule.c
index 3e2f2a1..98285b9 100644
--- a/Python/bltinmodule.c
+++ b/Python/bltinmodule.c
@@ -184,13 +184,19 @@ static PyObject *
builtin_all(PyObject *self, PyObject *v)
{
PyObject *it, *item;
+ PyObject *(*iternext)(PyObject *);
+ int cmp;
it = PyObject_GetIter(v);
if (it == NULL)
return NULL;
+ iternext = *Py_TYPE(it)->tp_iternext;
- while ((item = PyIter_Next(it)) != NULL) {
- int cmp = PyObject_IsTrue(item);
+ for (;;) {
+ item = iternext(it);
+ if (item == NULL)
+ break;
+ cmp = PyObject_IsTrue(item);
Py_DECREF(item);
if (cmp < 0) {
Py_DECREF(it);
@@ -202,8 +208,12 @@ builtin_all(PyObject *self, PyObject *v)
}
}
Py_DECREF(it);
- if (PyErr_Occurred())
- return NULL;
+ if (PyErr_Occurred()) {
+ if (PyErr_ExceptionMatches(PyExc_StopIteration))
+ PyErr_Clear();
+ else
+ return NULL;
+ }
Py_RETURN_TRUE;
}
@@ -216,13 +226,19 @@ static PyObject *
builtin_any(PyObject *self, PyObject *v)
{
PyObject *it, *item;
+ PyObject *(*iternext)(PyObject *);
+ int cmp;
it = PyObject_GetIter(v);
if (it == NULL)
return NULL;
+ iternext = *Py_TYPE(it)->tp_iternext;
- while ((item = PyIter_Next(it)) != NULL) {
- int cmp = PyObject_IsTrue(item);
+ for (;;) {
+ item = iternext(it);
+ if (item == NULL)
+ break;
+ cmp = PyObject_IsTrue(item);
Py_DECREF(item);
if (cmp < 0) {
Py_DECREF(it);
@@ -234,8 +250,12 @@ builtin_any(PyObject *self, PyObject *v)
}
}
Py_DECREF(it);
- if (PyErr_Occurred())
- return NULL;
+ if (PyErr_Occurred()) {
+ if (PyErr_ExceptionMatches(PyExc_StopIteration))
+ PyErr_Clear();
+ else
+ return NULL;
+ }
Py_RETURN_FALSE;
}
diff --git a/Python/compile.c b/Python/compile.c
index c3ef67a..e1f2a55 100644
--- a/Python/compile.c
+++ b/Python/compile.c
@@ -3172,7 +3172,7 @@ compiler_visit_expr(struct compiler *c, expr_ty e)
return compiler_ifexp(c, e);
case Dict_kind:
n = asdl_seq_LEN(e->v.Dict.values);
- ADDOP_I(c, BUILD_MAP, (n>255 ? 255 : n));
+ ADDOP_I(c, BUILD_MAP, (n>0xFFFF ? 0xFFFF : n));
for (i = 0; i < n; i++) {
VISIT(c, expr,
(expr_ty)asdl_seq_GET(e->v.Dict.values, i));
@@ -3648,10 +3648,10 @@ static int
instrsize(struct instr *instr)
{
if (!instr->i_hasarg)
- return 1;
+ return 1; /* 1 byte for the opcode*/
if (instr->i_oparg > 0xffff)
- return 6;
- return 3;
+ return 6; /* 1 (opcode) + 1 (EXTENDED_ARG opcode) + 2 (oparg) + 2(oparg extended) */
+ return 3; /* 1 (opcode) + 2 (oparg) */
}
static int