diff options
author | Serhiy Storchaka <storchaka@gmail.com> | 2019-03-30 06:25:19 (GMT) |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-03-30 06:25:19 (GMT) |
commit | 2524fdefc9bb2a97b99319190aeb23703079ad4c (patch) | |
tree | 502ab9f93daadc1828810c5e13ca49faeb6397ff /Lib/test/test_zipfile.py | |
parent | 7a465cb5ee7e298cae626ace1fc3e7d97df79f2e (diff) | |
download | cpython-2524fdefc9bb2a97b99319190aeb23703079ad4c.zip cpython-2524fdefc9bb2a97b99319190aeb23703079ad4c.tar.gz cpython-2524fdefc9bb2a97b99319190aeb23703079ad4c.tar.bz2 |
bpo-36434: Properly handle writing errors in ZIP files. (GH-12559)
Errors during writing no longer prevent to properly close
the ZIP file.
Diffstat (limited to 'Lib/test/test_zipfile.py')
-rw-r--r-- | Lib/test/test_zipfile.py | 37 |
1 files changed, 37 insertions, 0 deletions
diff --git a/Lib/test/test_zipfile.py b/Lib/test/test_zipfile.py index 7b8922f..14e1e08 100644 --- a/Lib/test/test_zipfile.py +++ b/Lib/test/test_zipfile.py @@ -402,6 +402,43 @@ class AbstractTestsWithSourceFile: self.assertEqual(one_info._compresslevel, 1) self.assertEqual(nine_info._compresslevel, 9) + def test_writing_errors(self): + class BrokenFile(io.BytesIO): + def write(self, data): + nonlocal count + if count is not None: + if count == stop: + raise OSError + count += 1 + super().write(data) + + stop = 0 + while True: + testfile = BrokenFile() + count = None + with zipfile.ZipFile(testfile, 'w', self.compression) as zipfp: + with zipfp.open('file1', 'w') as f: + f.write(b'data1') + count = 0 + try: + with zipfp.open('file2', 'w') as f: + f.write(b'data2') + except OSError: + stop += 1 + else: + break + finally: + count = None + with zipfile.ZipFile(io.BytesIO(testfile.getvalue())) as zipfp: + self.assertEqual(zipfp.namelist(), ['file1']) + self.assertEqual(zipfp.read('file1'), b'data1') + + with zipfile.ZipFile(io.BytesIO(testfile.getvalue())) as zipfp: + self.assertEqual(zipfp.namelist(), ['file1', 'file2']) + self.assertEqual(zipfp.read('file1'), b'data1') + self.assertEqual(zipfp.read('file2'), b'data2') + + def tearDown(self): unlink(TESTFN) unlink(TESTFN2) |