summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAntoine Pitrou <solipsis@pitrou.net>2010-05-15 20:33:07 (GMT)
committerAntoine Pitrou <solipsis@pitrou.net>2010-05-15 20:33:07 (GMT)
commitc400610321dcd16bff1e45ecb72a51244d43fbac (patch)
tree07a476a4be7d7eacf4fd8d25bb4d3faa96cf9a0a
parent6f1cfc1c12ce2bad4241dae14860acba7d4b294b (diff)
downloadcpython-c400610321dcd16bff1e45ecb72a51244d43fbac.zip
cpython-c400610321dcd16bff1e45ecb72a51244d43fbac.tar.gz
cpython-c400610321dcd16bff1e45ecb72a51244d43fbac.tar.bz2
Issue #7640: In the new `io` module, fix relative seek() for buffered
readable streams when the internal buffer isn't empty. Patch by Pascal Chambon.
-rw-r--r--Lib/io.py4
-rw-r--r--Lib/test/test_io.py17
-rw-r--r--Misc/NEWS4
3 files changed, 24 insertions, 1 deletions
diff --git a/Lib/io.py b/Lib/io.py
index 54de504..1458b47 100644
--- a/Lib/io.py
+++ b/Lib/io.py
@@ -1199,6 +1199,10 @@ class BufferedRandom(BufferedWriter, BufferedReader):
self.flush()
# First do the raw seek, then empty the read buffer, so that
# if the raw seek fails, we don't lose buffered data forever.
+ if self._read_buf and whence == 1:
+ # Undo read ahead.
+ with self._read_lock:
+ self.raw.seek(self._read_pos - len(self._read_buf), 1)
pos = self.raw.seek(pos, whence)
with self._read_lock:
self._reset_read_buf()
diff --git a/Lib/test/test_io.py b/Lib/test/test_io.py
index c732b1f..aebe67b 100644
--- a/Lib/test/test_io.py
+++ b/Lib/test/test_io.py
@@ -107,6 +107,10 @@ class IOTest(unittest.TestCase):
self.assertEqual(f.truncate(12), 12)
self.assertEqual(f.tell(), 13)
+ self.assertEqual(f.write(b"hij"), 3)
+ self.assertEqual(f.seek(0,1), 16)
+ self.assertEqual(f.tell(), 16)
+ self.assertEqual(f.truncate(12), 12)
self.assertRaises(TypeError, f.seek, 0.0)
def read_ops(self, f, buffered=False):
@@ -129,6 +133,10 @@ class IOTest(unittest.TestCase):
self.assertEqual(f.seek(-6, 1), 5)
self.assertEqual(f.read(5), b" worl")
self.assertEqual(f.tell(), 10)
+ f.seek(0)
+ f.read(2)
+ f.seek(0, 1)
+ self.assertEqual(f.tell(), 2)
self.assertRaises(TypeError, f.seek, 0.0)
if buffered:
f.seek(0)
@@ -182,6 +190,13 @@ class IOTest(unittest.TestCase):
self.assertEqual(f.writable(), False)
self.assertEqual(f.seekable(), True)
self.read_ops(f, True)
+ f = io.open(test_support.TESTFN, "r+b")
+ self.assertEqual(f.readable(), True)
+ self.assertEqual(f.writable(), True)
+ self.assertEqual(f.seekable(), True)
+ self.write_ops(f)
+ f.seek(0)
+ self.read_ops(f, True)
f.close()
def test_readline(self):
@@ -513,7 +528,7 @@ class BufferedWriterTest(unittest.TestCase):
self.assertEquals(b"abcdefghijkl", writer._write_stack[0])
def testWriteNonBlocking(self):
- raw = MockNonBlockWriterIO((9, 2, 22, -6, 10, 12, 12))
+ raw = MockNonBlockWriterIO((9, 2, 10, -6, 10, 8, 12))
bufio = io.BufferedWriter(raw, 8, 16)
bufio.write(b"asdf")
diff --git a/Misc/NEWS b/Misc/NEWS
index 17a657a..e219439 100644
--- a/Misc/NEWS
+++ b/Misc/NEWS
@@ -39,6 +39,10 @@ Core and Builtins
Library
-------
+- Issue #7640: In the new `io` module, fix relative seek() for buffered
+ readable streams when the internal buffer isn't empty. Patch by Pascal
+ Chambon.
+
- Issue #5099: subprocess.Popen.__del__ no longer references global objects,
leading to issues during interpreter shutdown.