Move EOF flag from reader to byte source

3 files changed, 11 insertions, 11 deletions

diff --git a/src/byte_source.c b/src/byte_source.c
index 588d258e..8346785f 100644
--- a/src/byte_source.c
+++ b/src/byte_source.c
@@ -24,6 +24,7 @@ serd_byte_source_page(SerdByteSource* source)
 		source->file_buf, 1, source->page_size, source->stream);
 	if (n_read == 0) {
 		source->file_buf[0] = '\0';
+		source->eof         = true;
 		return (source->error_func(source->stream)
 		        ? SERD_ERR_UNKNOWN : SERD_FAILURE);
 	} else if (n_read < source->page_size) {
@@ -61,6 +62,7 @@ SerdStatus
 serd_byte_source_prepare(SerdByteSource* source)
 {
 	if (!source->prepared) {
+		source->eof      = false;
 		source->prepared = true;
 		if (source->page_size > 1) {
 			return serd_byte_source_page(source);
diff --git a/src/reader.c b/src/reader.c
index 5d996e34..5fab0b3c 100644
--- a/src/reader.c
+++ b/src/reader.c
@@ -79,7 +79,6 @@ struct SerdReaderImpl {
 	uint8_t*          bprefix;
 	size_t            bprefix_len;
 	bool              strict;     ///< True iff strict parsing
-	bool              eof;
 	bool              seen_genid;
 #ifdef SERD_STACK_CHECK
 	Ref*              allocs;     ///< Stack of push offsets
@@ -130,7 +129,7 @@ eat_byte_safe(SerdReader* reader, const uint8_t byte)
 {
 	assert(peek_byte(reader) == byte);
 	switch (byte) {
-	case '\0': reader->eof = (byte != '\0'); break;
+	case '\0': break;
 	case '\n': ++reader->cur.line; reader->cur.col = 0; break;
 	default:   ++reader->cur.col;
 	}
@@ -1604,7 +1603,7 @@ read_statement(SerdReader* reader)
 	read_ws_star(reader);
 	switch (peek_byte(reader)) {
 	case '\0':
-		reader->eof = true;
+		reader->source.eof = true;
 		return reader->status <= SERD_FAILURE;
 	case '@':
 		if (!fancy_syntax(reader)) {
@@ -1669,7 +1668,7 @@ skip_until(SerdReader* reader, uint8_t byte)
 static bool
 read_turtleTrigDoc(SerdReader* reader)
 {
-	while (!reader->eof) {
+	while (!reader->source.eof) {
 		if (!read_statement(reader)) {
 			if (reader->strict) {
 				return 0;
@@ -1684,14 +1683,14 @@ read_turtleTrigDoc(SerdReader* reader)
 static bool
 read_nquadsDoc(SerdReader* reader)
 {
-	while (!reader->eof) {
+	while (!reader->source.eof) {
 		SerdStatementFlags flags   = 0;
 		ReadContext        ctx     = { 0, 0, 0, 0, 0, 0, &flags };
 		bool               ate_dot = false;
 		char               s_type  = false;
 		read_ws_star(reader);
 		if (peek_byte(reader) == '\0') {
-			reader->eof = true;
+			reader->source.eof = true;
 			break;
 		} else if (peek_byte(reader) == '@') {
 			return r_err(reader, SERD_ERR_BAD_SYNTAX,
@@ -1916,12 +1915,11 @@ serd_reader_start_source_stream(SerdReader*         reader,
 static SerdStatus
 serd_reader_prepare(SerdReader* reader)
 {
-	reader->eof    = false;
 	reader->status = serd_byte_source_prepare(&reader->source);
 	if (reader->status == SERD_SUCCESS) {
 		reader->status = skip_bom(reader);
 	} else if (reader->status == SERD_FAILURE) {
-		reader->eof = true;
+		reader->source.eof = true;
 	} else {
 		r_err(reader, reader->status, "read error: %s\n", strerror(errno));
 	}
@@ -1937,8 +1935,8 @@ serd_reader_read_chunk(SerdReader* reader)
 		if ((st = serd_reader_prepare(reader))) {
 			return st;
 		}
-	} else if (reader->eof) {
-		reader->eof = false;
+	} else if (reader->source.eof) {
+		reader->source.eof = false;
 		if ((st = serd_byte_source_advance(&reader->source))) {
 			return st;
 		}
@@ -1995,7 +1993,6 @@ serd_reader_read_string(SerdReader* reader, const uint8_t* utf8)
 
 	serd_byte_source_open_string(&reader->source, utf8);
 	reader->cur = cur;
-	reader->eof = false;
 
 	SerdStatus st = serd_reader_prepare(reader);
 	if (!st) {
diff --git a/src/serd_internal.h b/src/serd_internal.h
index 5cda4d16..7c758cb8 100644
--- a/src/serd_internal.h
+++ b/src/serd_internal.h
@@ -85,6 +85,7 @@ typedef struct {
 	uint8_t             read_byte;    ///< 1-byte 'buffer' used when not paging
 	bool                from_stream;  ///< True iff reading from `stream`
 	bool                prepared;     ///< True iff prepared for reading
+	bool                eof;          ///< True iff end of file reached
 } SerdByteSource;
 
 SerdStatus