Fixed bug #44607 (stream_get_line unable to correctly identify the

"ending" in the stream content)

diff --git a/ext/standard/tests/file/bug44607.phpt b/ext/standard/tests/file/bug44607.phpt
new file mode 100644 (file)
index 0000000..9eb6d5f
--- /dev/null
+++ b/ext/standard/tests/file/bug44607.phpt
@@ -0,0 +1,22 @@
+--TEST--
+Bug #44607 (stream_get_line unable to correctly identify the "ending" in the stream content)
+--FILE--
+<?php
+$eol = '<EOL>';
+$tempnam = tempnam(sys_get_temp_dir(), 'php');
+$data = str_repeat('.', 14000);
+$data .= $eol;
+$data .= $data;
+file_put_contents($tempnam, $data);
+$fd = fopen($tempnam, 'r');
+var_dump(strlen(stream_get_line($fd, 15000, $eol)));
+var_dump(strlen(stream_get_line($fd, 15000, $eol)));
+fseek($fd, 1, SEEK_SET);
+var_dump(strlen(stream_get_line($fd, 15000, $eol)));
+var_dump(strlen(stream_get_line($fd, 15000, $eol)));
+?>
+--EXPECT--
+int(14000)
+int(14000)
+int(13999)
+int(14000)

diff --git a/main/streams/streams.c b/main/streams/streams.c
index 40989bbde8f8c92ff05ec7e65c12bc64a608702c..15b39947881e38fda30606d0d680f5869127773d 100755 (executable)
--- a/main/streams/streams.c
+++ b/main/streams/streams.c
@@ -551,16 +551,16 @@ static void php_stream_fill_read_buffer(php_stream *stream, size_t size TSRMLS_D
 
                efree(chunk_buf);
        } else {        /* Unfiltered Binary stream */
+               /* reduce buffer memory consumption if possible, to avoid a realloc */
+               if (stream->readbuf.s && stream->readbuflen - stream->writepos < stream->chunk_size) {
+                       memmove(stream->readbuf.s, stream->readbuf.s + stream->readpos, stream->writepos - stream->readpos);
+                       stream->writepos -= stream->readpos;
+                       stream->readpos = 0;
+               }
                /* is there enough data in the buffer ? */
-               if (stream->writepos - stream->readpos < (off_t)size) {
+               while (stream->writepos - stream->readpos < (off_t)size) {
                        size_t justread = 0;
-
-                       /* reduce buffer memory consumption if possible, to avoid a realloc */
-                       if (stream->readbuf.s && stream->readbuflen - stream->writepos < stream->chunk_size) {
-                               memmove(stream->readbuf.s, stream->readbuf.s + stream->readpos, stream->writepos - stream->readpos);
-                               stream->writepos -= stream->readpos;
-                               stream->readpos = 0;
-                       }
+                       size_t toread;
 
                        /* grow the buffer if required
                         * TODO: this can fail for persistent streams */
@@ -569,10 +569,15 @@ static void php_stream_fill_read_buffer(php_stream *stream, size_t size TSRMLS_D
                                stream->readbuf.s = (char*)perealloc(stream->readbuf.s, stream->readbuflen, stream->is_persistent);
                        }
 
-                       justread = stream->ops->read(stream, stream->readbuf.s + stream->writepos, stream->readbuflen - stream->writepos TSRMLS_CC);
-                       if (justread != (size_t)-1 && justread != 0) {
+                       toread = stream->readbuflen - stream->writepos;
+                       justread = stream->ops->read(stream, stream->readbuf.s + stream->writepos, toread TSRMLS_CC);
+
+                       if (justread != (size_t)-1) {
                                stream->writepos += justread;
                        }
+                       if (stream->eof || justread != toread) {
+                               break;
+                       }
                }
        }
 }