diff options
author | David Robillard <d@drobilla.net> | 2018-02-10 13:32:06 +0100 |
---|---|---|
committer | David Robillard <d@drobilla.net> | 2018-12-30 17:56:22 -0500 |
commit | 0e24282852a889894dfc3e3afa61766a4b8f4ddb (patch) | |
tree | 7b2eac33b38ef20758a3998c25274b81dcb213d7 /src/serdi.c | |
parent | 9f7d2de1ee0443c1d82a854ac459fc7dbe79749d (diff) | |
download | serd-0e24282852a889894dfc3e3afa61766a4b8f4ddb.tar.gz serd-0e24282852a889894dfc3e3afa61766a4b8f4ddb.tar.bz2 serd-0e24282852a889894dfc3e3afa61766a4b8f4ddb.zip |
Simplify reader interface
Diffstat (limited to 'src/serdi.c')
-rw-r--r-- | src/serdi.c | 36 |
1 files changed, 28 insertions, 8 deletions
diff --git a/src/serdi.c b/src/serdi.c index 5cea387e..2819788d 100644 --- a/src/serdi.c +++ b/src/serdi.c @@ -115,6 +115,22 @@ quiet_error_sink(void* handle, const SerdError* e) return SERD_SUCCESS; } +/** fread-like wrapper for getc (which is faster). */ +static size_t +serd_file_read_byte(void* buf, size_t size, size_t nmemb, void* stream) +{ + (void)size; + (void)nmemb; + + const int c = getc((FILE*)stream); + if (c == EOF) { + *((uint8_t*)buf) = 0; + return 0; + } + *((uint8_t*)buf) = (uint8_t)c; + return 1; +} + int main(int argc, char** argv) { @@ -284,17 +300,21 @@ main(int argc, char** argv) SerdStatus status = SERD_SUCCESS; if (!from_file) { - status = serd_reader_read_string(reader, input); - } else if (bulk_read) { - status = serd_reader_read_file_handle(reader, in_fd, in_name); + status = serd_reader_start_string(reader, input); } else { - status = serd_reader_start_stream(reader, in_fd, in_name, false); - while (!status) { - status = serd_reader_read_chunk(reader); - } - serd_reader_end_stream(reader); + status = serd_reader_start_stream( + reader, + bulk_read ? (SerdSource)fread : serd_file_read_byte, + (SerdStreamErrorFunc)ferror, + in_fd, + in_name, + bulk_read ? SERD_PAGE_SIZE : 1); } + status = serd_reader_read_document(reader); + + serd_reader_end_stream(reader); + serd_reader_free(reader); serd_writer_finish(writer); serd_writer_free(writer); |