diff -r 8c2635afbfe1 Lib/_pyio.py --- a/Lib/_pyio.py Tue Dec 18 21:27:37 2012 +0200 +++ b/Lib/_pyio.py Thu Dec 20 20:24:32 2012 +0200 @@ -340,8 +340,10 @@ This method has no effect if the file is already closed. """ if not self.__closed: - self.flush() - self.__closed = True + try: + self.flush() + finally: + self.__closed = True def __del__(self): """Destructor. Calls close().""" @@ -1568,8 +1570,10 @@ def close(self): if self.buffer is not None and not self.closed: - self.flush() - self.buffer.close() + try: + self.flush() + finally: + self.buffer.close() @property def closed(self): diff -r 8c2635afbfe1 Lib/test/test_io.py --- a/Lib/test/test_io.py Tue Dec 18 21:27:37 2012 +0200 +++ b/Lib/test/test_io.py Thu Dec 20 20:24:32 2012 +0200 @@ -573,6 +573,7 @@ raise IOError() f.flush = bad_flush self.assertRaises(IOError, f.close) # exception not swallowed + self.assertTrue(f.closed) def test_multi_close(self): f = self.open(support.TESTFN, "wb", buffering=0) @@ -732,6 +733,21 @@ raw.flush = bad_flush b = self.tp(raw) self.assertRaises(IOError, b.close) # exception not swallowed + self.assertTrue(b.closed) + + def test_close_error_on_close(self): + raw = self.MockRawIO() + def bad_flush(): + raise IOError('flush') + def bad_close(): + raise IOError('close') + raw.close = bad_close + b = self.tp(raw) + b.flush = bad_flush + with self.assertRaises(IOError) as err: # exception not swallowed + b.close() + self.assertEqual(err.exception.args, ('close',)) + self.assertFalse(b.closed) def test_multi_close(self): raw = self.MockRawIO() @@ -1230,6 +1246,16 @@ DeprecationWarning)): self.tp(self.MockRawIO(), 8, 12) + def test_write_error_on_close(self): + raw = self.MockRawIO() + def bad_write(b): + raise IOError() + raw.write = bad_write + b = self.tp(raw) + b.write(b'spam') + self.assertRaises(IOError, b.close) # exception not swallowed + self.assertTrue(b.closed) + class CBufferedWriterTest(BufferedWriterTest, SizeofTest): tp = io.BufferedWriter @@ -2378,6 +2404,7 @@ raise IOError() txt.flush = bad_flush self.assertRaises(IOError, txt.close) # exception not swallowed + self.assertTrue(txt.closed) def test_multi_close(self): txt = self.TextIOWrapper(self.BytesIO(self.testdata), encoding="ascii") diff -r 8c2635afbfe1 Modules/_io/bufferedio.c --- a/Modules/_io/bufferedio.c Tue Dec 18 21:27:37 2012 +0200 +++ b/Modules/_io/bufferedio.c Thu Dec 20 20:24:32 2012 +0200 @@ -455,7 +455,7 @@ static PyObject * buffered_close(buffered *self, PyObject *args) { - PyObject *res = NULL; + PyObject *res = NULL, *exc = NULL, *val, *tb; int r; CHECK_INITIALIZED(self) @@ -475,13 +475,25 @@ res = PyObject_CallMethodObjArgs((PyObject *)self, _PyIO_str_flush, NULL); if (!ENTER_BUFFERED(self)) return NULL; - if (res == NULL) { - goto end; - } - Py_XDECREF(res); + if (res == NULL) + PyErr_Fetch(&exc, &val, &tb); + else + Py_DECREF(res); res = PyObject_CallMethodObjArgs(self->raw, _PyIO_str_close, NULL); + if (exc != NULL) { + if (res != NULL) { + Py_CLEAR(res); + PyErr_Restore(exc, val, tb); + } + else { + Py_DECREF(exc); + Py_XDECREF(val); + Py_XDECREF(tb); + } + } + end: LEAVE_BUFFERED(self) return res; diff -r 8c2635afbfe1 Modules/_io/textio.c --- a/Modules/_io/textio.c Tue Dec 18 21:27:37 2012 +0200 +++ b/Modules/_io/textio.c Thu Dec 20 20:24:32 2012 +0200 @@ -2442,14 +2442,26 @@ Py_RETURN_NONE; /* stream already closed */ } else { + PyObject *exc = NULL, *val, *tb; res = PyObject_CallMethod((PyObject *)self, "flush", NULL); - if (res == NULL) { - return NULL; - } + if (res == NULL) + PyErr_Fetch(&exc, &val, &tb); else Py_DECREF(res); - return PyObject_CallMethod(self->buffer, "close", NULL); + res = PyObject_CallMethod(self->buffer, "close", NULL); + if (exc != NULL) { + if (res != NULL) { + Py_CLEAR(res); + PyErr_Restore(exc, val, tb); + } + else { + Py_DECREF(exc); + Py_XDECREF(val); + Py_XDECREF(tb); + } + } + return res; } }