Skip to content

Commit 32fd791

Browse files
committed
Do not cap at DEFAULT_BUFFER_SIZE
1 parent 203749b commit 32fd791

3 files changed

Lines changed: 2 additions & 10 deletions

File tree

Lib/_pyio.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1001,7 +1001,7 @@ def peek(self, size=0):
10011001
raise ValueError("peek on closed file")
10021002
if size < 1:
10031003
return self._buffer[self._pos:self._pos + DEFAULT_BUFFER_SIZE]
1004-
return self._buffer[self._pos:self._pos + min(size, DEFAULT_BUFFER_SIZE)]
1004+
return self._buffer[self._pos:self._pos + size]
10051005

10061006
def truncate(self, pos=None):
10071007
if self.closed:

Lib/test/test_io/test_memoryio.py

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -609,12 +609,6 @@ def test_peek(self):
609609
self.assertEqual(memio.peek(len(abc) + 100), abc)
610610
self.assertEqual(memio.tell(), len(buf))
611611

612-
# Length of returned bytes object is capped to DEFAULT_BUFFER_SIZE
613-
buf = self.buftype("a" * (io.DEFAULT_BUFFER_SIZE + 10))
614-
with self.ioclass(buf) as memio:
615-
self.assertEqual(len(memio.peek()), io.DEFAULT_BUFFER_SIZE)
616-
self.assertEqual(len(memio.peek(io.DEFAULT_BUFFER_SIZE + 1)), io.DEFAULT_BUFFER_SIZE)
617-
618612
with self.ioclass(buf) as memio:
619613
memio.seek(len(buf))
620614
self.assertEqual(memio.peek(), self.EOF)

Modules/_io/bytesio.c

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -529,9 +529,7 @@ _io_BytesIO_peek_impl(bytesio *self, Py_ssize_t size)
529529

530530
/* adjust invalid sizes */
531531
Py_ssize_t n = self->string_size - self->pos;
532-
if (n > DEFAULT_BUFFER_SIZE) {
533-
n = DEFAULT_BUFFER_SIZE;
534-
}
532+
535533
if (size < 1 || size > n) {
536534
size = n;
537535
/* n can be negative after truncate() or seek() */

0 commit comments

Comments
 (0)