[Python-checkins] cpython (3.4): asyncio: sync with Tulip
victor.stinner
python-checkins at python.org
Wed Jul 23 18:25:25 CEST 2014
http://hg.python.org/cpython/rev/80b62cb19a67
changeset: 91781:80b62cb19a67
branch: 3.4
parent: 91779:09746dc1a3b4
user: Victor Stinner <victor.stinner at gmail.com>
date: Wed Jul 23 18:21:45 2014 +0200
summary:
asyncio: sync with Tulip
* Tulip issue 194: Don't use sys.getrefcount() in unit tests
* signal.set_wakeup_fd() can now raise an OSError on Python 3.5
files:
Lib/asyncio/unix_events.py | 6 +-
Lib/test/test_asyncio/test_selector_events.py | 4 +-
Lib/test/test_asyncio/test_unix_events.py | 17 ++++-----
3 files changed, 13 insertions(+), 14 deletions(-)
diff --git a/Lib/asyncio/unix_events.py b/Lib/asyncio/unix_events.py
--- a/Lib/asyncio/unix_events.py
+++ b/Lib/asyncio/unix_events.py
@@ -74,7 +74,7 @@
# event loop running in another thread cannot add a signal
# handler.
signal.set_wakeup_fd(self._csock.fileno())
- except ValueError as exc:
+ except (ValueError, OSError) as exc:
raise RuntimeError(str(exc))
handle = events.Handle(callback, args, self)
@@ -93,7 +93,7 @@
if not self._signal_handlers:
try:
signal.set_wakeup_fd(-1)
- except ValueError as nexc:
+ except (ValueError, OSError) as nexc:
logger.info('set_wakeup_fd(-1) failed: %s', nexc)
if exc.errno == errno.EINVAL:
@@ -138,7 +138,7 @@
if not self._signal_handlers:
try:
signal.set_wakeup_fd(-1)
- except ValueError as exc:
+ except (ValueError, OSError) as exc:
logger.info('set_wakeup_fd(-1) failed: %s', exc)
return True
diff --git a/Lib/test/test_asyncio/test_selector_events.py b/Lib/test/test_asyncio/test_selector_events.py
--- a/Lib/test/test_asyncio/test_selector_events.py
+++ b/Lib/test/test_asyncio/test_selector_events.py
@@ -672,6 +672,8 @@
def test_connection_lost(self):
exc = OSError()
tr = _SelectorTransport(self.loop, self.sock, self.protocol, None)
+ self.assertIsNotNone(tr._protocol)
+ self.assertIsNotNone(tr._loop)
tr._call_connection_lost(exc)
self.protocol.connection_lost.assert_called_with(exc)
@@ -679,8 +681,6 @@
self.assertIsNone(tr._sock)
self.assertIsNone(tr._protocol)
- self.assertEqual(2, sys.getrefcount(self.protocol),
- pprint.pformat(gc.get_referrers(self.protocol)))
self.assertIsNone(tr._loop)
diff --git a/Lib/test/test_asyncio/test_unix_events.py b/Lib/test/test_asyncio/test_unix_events.py
--- a/Lib/test/test_asyncio/test_unix_events.py
+++ b/Lib/test/test_asyncio/test_unix_events.py
@@ -435,6 +435,8 @@
def test__call_connection_lost(self):
tr = unix_events._UnixReadPipeTransport(
self.loop, self.pipe, self.protocol)
+ self.assertIsNotNone(tr._protocol)
+ self.assertIsNotNone(tr._loop)
err = None
tr._call_connection_lost(err)
@@ -442,13 +444,13 @@
self.pipe.close.assert_called_with()
self.assertIsNone(tr._protocol)
- self.assertEqual(2, sys.getrefcount(self.protocol),
- pprint.pformat(gc.get_referrers(self.protocol)))
self.assertIsNone(tr._loop)
def test__call_connection_lost_with_err(self):
tr = unix_events._UnixReadPipeTransport(
self.loop, self.pipe, self.protocol)
+ self.assertIsNotNone(tr._protocol)
+ self.assertIsNotNone(tr._loop)
err = OSError()
tr._call_connection_lost(err)
@@ -456,9 +458,6 @@
self.pipe.close.assert_called_with()
self.assertIsNone(tr._protocol)
-
- self.assertEqual(2, sys.getrefcount(self.protocol),
- pprint.pformat(gc.get_referrers(self.protocol)))
self.assertIsNone(tr._loop)
@@ -717,6 +716,8 @@
def test__call_connection_lost(self):
tr = unix_events._UnixWritePipeTransport(
self.loop, self.pipe, self.protocol)
+ self.assertIsNotNone(tr._protocol)
+ self.assertIsNotNone(tr._loop)
err = None
tr._call_connection_lost(err)
@@ -724,13 +725,13 @@
self.pipe.close.assert_called_with()
self.assertIsNone(tr._protocol)
- self.assertEqual(2, sys.getrefcount(self.protocol),
- pprint.pformat(gc.get_referrers(self.protocol)))
self.assertIsNone(tr._loop)
def test__call_connection_lost_with_err(self):
tr = unix_events._UnixWritePipeTransport(
self.loop, self.pipe, self.protocol)
+ self.assertIsNotNone(tr._protocol)
+ self.assertIsNotNone(tr._loop)
err = OSError()
tr._call_connection_lost(err)
@@ -738,8 +739,6 @@
self.pipe.close.assert_called_with()
self.assertIsNone(tr._protocol)
- self.assertEqual(2, sys.getrefcount(self.protocol),
- pprint.pformat(gc.get_referrers(self.protocol)))
self.assertIsNone(tr._loop)
def test_close(self):
--
Repository URL: http://hg.python.org/cpython
More information about the Python-checkins
mailing list