Skip to content

Commit

Permalink
bpo-32228: Reset raw_pos after unwinding the raw stream (#4858)
Browse files Browse the repository at this point in the history
Ensure that ``truncate()`` preserves the file position (as reported by ``tell()``) after writes longer than the buffer size.
  • Loading branch information
nitishch authored and pitrou committed Jan 28, 2018
1 parent 79db11c commit 059f58c
Show file tree
Hide file tree
Showing 3 changed files with 28 additions and 4 deletions.
17 changes: 17 additions & 0 deletions Lib/test/test_io.py
Original file line number Diff line number Diff line change
Expand Up @@ -1723,6 +1723,23 @@ def test_truncate(self):
with self.open(support.TESTFN, "rb", buffering=0) as f:
self.assertEqual(f.read(), b"abc")

def test_truncate_after_write(self):
# Ensure that truncate preserves the file position after
# writes longer than the buffer size.
# Issue: https://bugs.python.org/issue32228
with self.open(support.TESTFN, "wb") as f:
# Fill with some buffer
f.write(b'\x00' * 10000)
buffer_sizes = [8192, 4096, 200]
for buffer_size in buffer_sizes:
with self.open(support.TESTFN, "r+b", buffering=buffer_size) as f:
f.write(b'\x00' * (buffer_size + 1))
# After write write_pos and write_end are set to 0
f.read(1)
# read operation makes sure that pos != raw_pos
f.truncate()
self.assertEqual(f.tell(), buffer_size + 2)

@support.requires_resource('cpu')
def test_threads(self):
try:
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
Ensure that ``truncate()`` preserves the file position (as reported by ``tell()``) after writes longer than the buffer size.
14 changes: 10 additions & 4 deletions Modules/_io/bufferedio.c
Original file line number Diff line number Diff line change
Expand Up @@ -1292,7 +1292,6 @@ _io__Buffered_seek_impl(buffered *self, PyObject *targetobj, int whence)
if (res == NULL)
goto end;
Py_CLEAR(res);
_bufferedwriter_reset_buf(self);
}

/* TODO: align on block boundary and read buffer if needed? */
Expand Down Expand Up @@ -1852,8 +1851,6 @@ _bufferedwriter_raw_write(buffered *self, char *start, Py_ssize_t len)
return n;
}

/* `restore_pos` is 1 if we need to restore the raw stream position at
the end, 0 otherwise. */
static PyObject *
_bufferedwriter_flush_unlocked(buffered *self)
{
Expand Down Expand Up @@ -1894,9 +1891,18 @@ _bufferedwriter_flush_unlocked(buffered *self)
goto error;
}

_bufferedwriter_reset_buf(self);

end:
/* This ensures that after return from this function,
VALID_WRITE_BUFFER(self) returns false.
This is a required condition because when a tell() is called
after flushing and if VALID_READ_BUFFER(self) is false, we need
VALID_WRITE_BUFFER(self) to be false to have
RAW_OFFSET(self) == 0.
Issue: https://bugs.python.org/issue32228 */
_bufferedwriter_reset_buf(self);
Py_RETURN_NONE;

error:
Expand Down

0 comments on commit 059f58c

Please sign in to comment.