aboutsummaryrefslogtreecommitdiffstats
path: root/src/byte_source.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/byte_source.c')
-rw-r--r--src/byte_source.c107
1 files changed, 54 insertions, 53 deletions
diff --git a/src/byte_source.c b/src/byte_source.c
index a62f7a47..1b461fd0 100644
--- a/src/byte_source.c
+++ b/src/byte_source.c
@@ -27,23 +27,23 @@
SerdStatus
serd_byte_source_page(SerdByteSource* source)
{
- source->read_head = 0;
- const size_t n_read = source->read_func(
- 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);
- }
-
- if (n_read < source->page_size) {
- source->file_buf[n_read] = '\0';
- source->buf_size = n_read;
- }
-
- return SERD_SUCCESS;
+ source->read_head = 0;
+ const size_t n_read =
+ source->read_func(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);
+ }
+
+ if (n_read < source->page_size) {
+ source->file_buf[n_read] = '\0';
+ source->buf_size = n_read;
+ }
+
+ return SERD_SUCCESS;
}
SerdStatus
@@ -54,58 +54,59 @@ serd_byte_source_open_source(SerdByteSource* source,
const uint8_t* name,
size_t page_size)
{
- const Cursor cur = { name, 1, 1 };
-
- memset(source, '\0', sizeof(*source));
- source->stream = stream;
- source->from_stream = true;
- source->page_size = page_size;
- source->buf_size = page_size;
- source->cur = cur;
- source->error_func = error_func;
- source->read_func = read_func;
-
- if (page_size > 1) {
- source->file_buf = (uint8_t*)serd_allocate_buffer(page_size);
- source->read_buf = source->file_buf;
- memset(source->file_buf, '\0', page_size);
- } else {
- source->read_buf = &source->read_byte;
- }
-
- return SERD_SUCCESS;
+ const Cursor cur = {name, 1, 1};
+
+ memset(source, '\0', sizeof(*source));
+ source->stream = stream;
+ source->from_stream = true;
+ source->page_size = page_size;
+ source->buf_size = page_size;
+ source->cur = cur;
+ source->error_func = error_func;
+ source->read_func = read_func;
+
+ if (page_size > 1) {
+ source->file_buf = (uint8_t*)serd_allocate_buffer(page_size);
+ source->read_buf = source->file_buf;
+ memset(source->file_buf, '\0', page_size);
+ } else {
+ source->read_buf = &source->read_byte;
+ }
+
+ return SERD_SUCCESS;
}
SerdStatus
serd_byte_source_prepare(SerdByteSource* source)
{
- source->prepared = true;
+ source->prepared = true;
- if (source->from_stream) {
- return (source->page_size > 1 ? serd_byte_source_page(source)
- : serd_byte_source_advance(source));
- }
+ if (source->from_stream) {
+ return (source->page_size > 1 ? serd_byte_source_page(source)
+ : serd_byte_source_advance(source));
+ }
- return SERD_SUCCESS;
+ return SERD_SUCCESS;
}
SerdStatus
serd_byte_source_open_string(SerdByteSource* source, const uint8_t* utf8)
{
- const Cursor cur = { (const uint8_t*)"(string)", 1, 1 };
+ const Cursor cur = {(const uint8_t*)"(string)", 1, 1};
- memset(source, '\0', sizeof(*source));
- source->cur = cur;
- source->read_buf = utf8;
- return SERD_SUCCESS;
+ memset(source, '\0', sizeof(*source));
+ source->cur = cur;
+ source->read_buf = utf8;
+ return SERD_SUCCESS;
}
SerdStatus
serd_byte_source_close(SerdByteSource* source)
{
- if (source->page_size > 1) {
- serd_free_aligned(source->file_buf);
- }
- memset(source, '\0', sizeof(*source));
- return SERD_SUCCESS;
+ if (source->page_size > 1) {
+ serd_free_aligned(source->file_buf);
+ }
+
+ memset(source, '\0', sizeof(*source));
+ return SERD_SUCCESS;
}