# HG changeset patch
# User Timo Sirainen <tss@iki.fi>
# Date 1227104902 -7200
# Node ID 1baa595093f502c910db479d0be55d3f6b50ace2
# Parent  8f41c9f3f392786eab31fcff7ac6cc85f30e766a
Added i_stream_set_return_partial_line().

diff -r 8f41c9f3f392 -r 1baa595093f5 src/lib/istream-internal.h
--- a/src/lib/istream-internal.h	Wed Nov 19 16:11:01 2008 +0200
+++ b/src/lib/istream-internal.h	Wed Nov 19 16:28:22 2008 +0200
@@ -34,6 +34,7 @@
 	uoff_t parent_start_offset;
 
 	string_t *line_str; /* for i_stream_next_line() if w_buffer == NULL */
+	unsigned int return_nolf_line:1;
 };
 
 struct istream *
diff -r 8f41c9f3f392 -r 1baa595093f5 src/lib/istream.c
--- a/src/lib/istream.c	Wed Nov 19 16:11:01 2008 +0200
+++ b/src/lib/istream.c	Wed Nov 19 16:28:22 2008 +0200
@@ -59,6 +59,11 @@
 	io_stream_set_max_buffer_size(&stream->real_stream->iostream, max_size);
 }
 
+void i_stream_set_return_partial_line(struct istream *stream, bool set)
+{
+	stream->real_stream->return_nolf_line = set;
+}
+
 ssize_t i_stream_read(struct istream *stream)
 {
 	struct istream_private *_stream = stream->real_stream;
@@ -213,12 +218,23 @@
 		ret = str_c_modifiable(stream->line_str);
 	}
 
-	i++;
+	if (i < stream->pos)
+		i++;
 	stream->istream.v_offset += i - stream->skip;
 	stream->skip = i;
 	return ret;
 }
 
+static char *i_stream_last_line(struct istream_private *_stream)
+{
+	if (_stream->istream.eof && _stream->skip != _stream->pos &&
+	    _stream->return_nolf_line) {
+		/* the last line is missing LF and we want to return it. */
+		return i_stream_next_line_finish(_stream, _stream->pos);
+	}
+	return NULL;
+}
+
 char *i_stream_next_line(struct istream *stream)
 {
 	struct istream_private *_stream = stream->real_stream;
@@ -244,7 +260,8 @@
                         break;
 		}
 	}
-
+	if (ret_buf == NULL)
+		return i_stream_last_line(_stream);
         return ret_buf;
 }
 
@@ -258,7 +275,7 @@
 			break;
 
 		if (i_stream_read(stream) <= 0)
-			return NULL;
+			return i_stream_last_line(stream->real_stream);
 	}
 	return line;
 }
diff -r 8f41c9f3f392 -r 1baa595093f5 src/lib/istream.h
--- a/src/lib/istream.h	Wed Nov 19 16:11:01 2008 +0200
+++ b/src/lib/istream.h	Wed Nov 19 16:28:22 2008 +0200
@@ -56,6 +56,9 @@
 /* Change the maximum size for stream's input buffer to grow. Useful only
    for buffered streams (currently only file). */
 void i_stream_set_max_buffer_size(struct istream *stream, size_t max_size);
+/* Enable/disable i_stream[_read]_next_line() returning the last line if it
+   doesn't end with LF. */
+void i_stream_set_return_partial_line(struct istream *stream, bool set);
 
 /* Returns number of bytes read if read was ok, -1 if EOF or error, -2 if the
    input buffer is full. */
@@ -83,8 +86,8 @@
 bool i_stream_have_bytes_left(const struct istream *stream) ATTR_PURE;
 
 /* Gets the next line from stream and returns it, or NULL if more data is
-   needed to make a full line. Note that if the stream ends with LF not being
-   the last character, this function doesn't return the last line. */
+   needed to make a full line. i_stream_set_return_partial_line() specifies
+   if the last line should be returned if it doesn't end with LF. */
 char *i_stream_next_line(struct istream *stream);
 /* Like i_stream_next_line(), but reads for more data if needed. Returns NULL
    if more data is needed or error occurred. */