mirror of
https://github.com/python/cpython.git
synced 2025-09-26 18:29:57 +00:00
Fix a bug in nested() - if one of the sub-context-managers swallows the
exception, it should not be propagated up. With unit tests.
This commit is contained in:
parent
6db0e00d57
commit
a9f068726f
2 changed files with 58 additions and 1 deletions
|
@ -91,7 +91,6 @@ def nested(*contexts):
|
||||||
"""
|
"""
|
||||||
exits = []
|
exits = []
|
||||||
vars = []
|
vars = []
|
||||||
exc = (None, None, None)
|
|
||||||
try:
|
try:
|
||||||
try:
|
try:
|
||||||
for context in contexts:
|
for context in contexts:
|
||||||
|
@ -103,6 +102,8 @@ def nested(*contexts):
|
||||||
yield vars
|
yield vars
|
||||||
except:
|
except:
|
||||||
exc = sys.exc_info()
|
exc = sys.exc_info()
|
||||||
|
else:
|
||||||
|
exc = (None, None, None)
|
||||||
finally:
|
finally:
|
||||||
while exits:
|
while exits:
|
||||||
exit = exits.pop()
|
exit = exits.pop()
|
||||||
|
@ -110,6 +111,8 @@ def nested(*contexts):
|
||||||
exit(*exc)
|
exit(*exc)
|
||||||
except:
|
except:
|
||||||
exc = sys.exc_info()
|
exc = sys.exc_info()
|
||||||
|
else:
|
||||||
|
exc = (None, None, None)
|
||||||
if exc != (None, None, None):
|
if exc != (None, None, None):
|
||||||
raise
|
raise
|
||||||
|
|
||||||
|
|
|
@ -107,6 +107,60 @@ class NestedTestCase(unittest.TestCase):
|
||||||
else:
|
else:
|
||||||
self.fail("Didn't raise ZeroDivisionError")
|
self.fail("Didn't raise ZeroDivisionError")
|
||||||
|
|
||||||
|
def test_nested_b_swallows(self):
|
||||||
|
@contextmanager
|
||||||
|
def a():
|
||||||
|
yield
|
||||||
|
@contextmanager
|
||||||
|
def b():
|
||||||
|
try:
|
||||||
|
yield
|
||||||
|
except:
|
||||||
|
# Swallow the exception
|
||||||
|
pass
|
||||||
|
try:
|
||||||
|
with nested(a(), b()):
|
||||||
|
1/0
|
||||||
|
except ZeroDivisionError:
|
||||||
|
self.fail("Didn't swallow ZeroDivisionError")
|
||||||
|
|
||||||
|
def test_nested_break(self):
|
||||||
|
@contextmanager
|
||||||
|
def a():
|
||||||
|
yield
|
||||||
|
state = 0
|
||||||
|
while True:
|
||||||
|
state += 1
|
||||||
|
with nested(a(), a()):
|
||||||
|
break
|
||||||
|
state += 10
|
||||||
|
self.assertEqual(state, 1)
|
||||||
|
|
||||||
|
def test_nested_continue(self):
|
||||||
|
@contextmanager
|
||||||
|
def a():
|
||||||
|
yield
|
||||||
|
state = 0
|
||||||
|
while state < 3:
|
||||||
|
state += 1
|
||||||
|
with nested(a(), a()):
|
||||||
|
continue
|
||||||
|
state += 10
|
||||||
|
self.assertEqual(state, 3)
|
||||||
|
|
||||||
|
def test_nested_return(self):
|
||||||
|
@contextmanager
|
||||||
|
def a():
|
||||||
|
try:
|
||||||
|
yield
|
||||||
|
except:
|
||||||
|
pass
|
||||||
|
def foo():
|
||||||
|
with nested(a(), a()):
|
||||||
|
return 1
|
||||||
|
return 10
|
||||||
|
self.assertEqual(foo(), 1)
|
||||||
|
|
||||||
class ClosingTestCase(unittest.TestCase):
|
class ClosingTestCase(unittest.TestCase):
|
||||||
|
|
||||||
# XXX This needs more work
|
# XXX This needs more work
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue