aboutsummaryrefslogtreecommitdiffstats
path: root/test/test_reader_writer.c
diff options
context:
space:
mode:
Diffstat (limited to 'test/test_reader_writer.c')
-rw-r--r--test/test_reader_writer.c320
1 files changed, 3 insertions, 317 deletions
diff --git a/test/test_reader_writer.c b/test/test_reader_writer.c
index 324135a4..fcd4a2b8 100644
--- a/test/test_reader_writer.c
+++ b/test/test_reader_writer.c
@@ -35,10 +35,7 @@ typedef struct {
} ErrorContext;
typedef struct {
- int n_base;
- int n_prefix;
int n_statement;
- int n_end;
} ReaderTest;
static const char* const doc_string =
@@ -69,280 +66,12 @@ test_sink(void* handle, const SerdEvent* event)
{
ReaderTest* rt = (ReaderTest*)handle;
- switch (event->type) {
- case SERD_BASE:
- ++rt->n_base;
- break;
- case SERD_PREFIX:
- ++rt->n_prefix;
- break;
- case SERD_STATEMENT:
- ++rt->n_statement;
- break;
- case SERD_END:
- ++rt->n_end;
- break;
- }
+ assert(event->type == SERD_STATEMENT);
+ ++rt->n_statement;
return SERD_SUCCESS;
}
-/// Reads a null byte after a statement, then succeeds again (like a socket)
-static size_t
-eof_test_read(void* buf, size_t size, size_t nmemb, void* stream)
-{
- assert(size == 1);
- assert(nmemb == 1);
- (void)size;
-
- static const char* const string = "_:s1 <http://example.org/p> _:o1 .\n"
- "_:s2 <http://example.org/p> _:o2 .\n";
-
- size_t* const count = (size_t*)stream;
-
- // Normal reading for the first statement
- if (*count < 35) {
- *(char*)buf = string[*count];
- ++*count;
- return nmemb;
- }
-
- // EOF for the first read at the start of the second statement
- if (*count == 35) {
- assert(string[*count] == '_');
- ++*count;
- return 0;
- }
-
- if (*count >= strlen(string)) {
- return 0;
- }
-
- // Normal reading after the EOF, adjusting for the skipped index 35
- *(char*)buf = string[*count - 1];
- ++*count;
- return nmemb;
-}
-
-static int
-eof_test_error(void* stream)
-{
- (void)stream;
- return 0;
-}
-
-static void
-test_read_nquads_chunks(const char* const path)
-{
- static const char null = 0;
-
- FILE* const f = fopen(path, "w+b");
- assert(f);
-
- // Write two statements, a null separator, then another statement
-
- fprintf(f,
- "<http://example.org/s> <http://example.org/p1> "
- "<http://example.org/o1> .\n");
-
- fprintf(f,
- "<http://example.org/s> <http://example.org/p2> "
- "<http://example.org/o2> .\n");
-
- fwrite(&null, sizeof(null), 1, f);
-
- fprintf(f,
- "<http://example.org/s> <http://example.org/p3> "
- "<http://example.org/o3> .\n");
-
- fseek(f, 0, SEEK_SET);
-
- SerdWorld* const world = serd_world_new();
- ReaderTest rt = {0, 0, 0, 0};
- SerdSink* const sink = serd_sink_new(&rt, test_sink, NULL);
- assert(sink);
-
- SerdReader* const reader = serd_reader_new(world, SERD_NQUADS, sink);
- assert(reader);
-
- SerdStatus st = serd_reader_start_stream(
- reader, (SerdReadFunc)fread, (SerdStreamErrorFunc)ferror, f, NULL, 1);
- assert(st == SERD_SUCCESS);
-
- // Read first statement
- st = serd_reader_read_chunk(reader);
- assert(st == SERD_SUCCESS);
- assert(rt.n_base == 0);
- assert(rt.n_prefix == 0);
- assert(rt.n_statement == 1);
- assert(rt.n_end == 0);
-
- // Read second statement
- st = serd_reader_read_chunk(reader);
- assert(st == SERD_SUCCESS);
- assert(rt.n_base == 0);
- assert(rt.n_prefix == 0);
- assert(rt.n_statement == 2);
- assert(rt.n_end == 0);
-
- // Read terminator
- st = serd_reader_read_chunk(reader);
- assert(st == SERD_FAILURE);
- assert(rt.n_base == 0);
- assert(rt.n_prefix == 0);
- assert(rt.n_statement == 2);
- assert(rt.n_end == 0);
-
- // Read last statement
- st = serd_reader_read_chunk(reader);
- assert(st == SERD_SUCCESS);
- assert(rt.n_base == 0);
- assert(rt.n_prefix == 0);
- assert(rt.n_statement == 3);
- assert(rt.n_end == 0);
-
- // EOF
- st = serd_reader_read_chunk(reader);
- assert(st == SERD_FAILURE);
- assert(rt.n_base == 0);
- assert(rt.n_prefix == 0);
- assert(rt.n_statement == 3);
- assert(rt.n_end == 0);
-
- assert(serd_reader_read_chunk(reader) == SERD_FAILURE);
-
- serd_reader_free(reader);
- serd_sink_free(sink);
- serd_world_free(world);
- fclose(f);
- remove(path);
-}
-
-static void
-test_read_turtle_chunks(const char* const path)
-{
- static const char null = 0;
-
- FILE* const f = fopen(path, "w+b");
- assert(f);
-
- // Write two statements separated by null characters
- fprintf(f, "@base <http://example.org/base/> .\n");
- fprintf(f, "@prefix eg: <http://example.org/> .\n");
- fprintf(f, "eg:s eg:p1 eg:o1 ;\n");
- fprintf(f, " eg:p2 eg:o2 .\n");
- fwrite(&null, sizeof(null), 1, f);
- fprintf(f, "eg:s eg:p [ eg:sp eg:so ] .\n");
- fwrite(&null, sizeof(null), 1, f);
- fseek(f, 0, SEEK_SET);
-
- SerdWorld* world = serd_world_new();
- ReaderTest rt = {0, 0, 0, 0};
- SerdSink* sink = serd_sink_new(&rt, test_sink, NULL);
- assert(sink);
-
- SerdReader* reader = serd_reader_new(world, SERD_TURTLE, sink);
- assert(reader);
-
- SerdStatus st = serd_reader_start_stream(
- reader, (SerdReadFunc)fread, (SerdStreamErrorFunc)ferror, f, NULL, 1);
- assert(st == SERD_SUCCESS);
-
- // Read base
- st = serd_reader_read_chunk(reader);
- assert(st == SERD_SUCCESS);
- assert(rt.n_base == 1);
- assert(rt.n_prefix == 0);
- assert(rt.n_statement == 0);
- assert(rt.n_end == 0);
-
- // Read prefix
- st = serd_reader_read_chunk(reader);
- assert(st == SERD_SUCCESS);
- assert(rt.n_base == 1);
- assert(rt.n_prefix == 1);
- assert(rt.n_statement == 0);
- assert(rt.n_end == 0);
-
- // Read first two statements
- st = serd_reader_read_chunk(reader);
- assert(st == SERD_SUCCESS);
- assert(rt.n_base == 1);
- assert(rt.n_prefix == 1);
- assert(rt.n_statement == 2);
- assert(rt.n_end == 0);
-
- // Read terminator
- st = serd_reader_read_chunk(reader);
- assert(st == SERD_FAILURE);
- assert(rt.n_base == 1);
- assert(rt.n_prefix == 1);
- assert(rt.n_statement == 2);
- assert(rt.n_end == 0);
-
- // Read statements after null terminator
- st = serd_reader_read_chunk(reader);
- assert(st == SERD_SUCCESS);
- assert(rt.n_base == 1);
- assert(rt.n_prefix == 1);
- assert(rt.n_statement == 4);
- assert(rt.n_end == 1);
-
- // Read terminator
- st = serd_reader_read_chunk(reader);
- assert(st == SERD_FAILURE);
- assert(rt.n_base == 1);
- assert(rt.n_prefix == 1);
- assert(rt.n_statement == 4);
- assert(rt.n_end == 1);
-
- // EOF
- st = serd_reader_read_chunk(reader);
- assert(st == SERD_FAILURE);
- assert(rt.n_base == 1);
- assert(rt.n_prefix == 1);
- assert(rt.n_statement == 4);
- assert(rt.n_end == 1);
-
- assert(serd_reader_read_chunk(reader) == SERD_FAILURE);
-
- serd_reader_free(reader);
- serd_sink_free(sink);
- serd_world_free(world);
- fclose(f);
- remove(path);
-}
-
-static void
-test_read_string(void)
-{
- SerdWorld* world = serd_world_new();
- ReaderTest rt = {0, 0, 0, 0};
- SerdSink* sink = serd_sink_new(&rt, test_sink, NULL);
- assert(sink);
-
- SerdReader* reader = serd_reader_new(world, SERD_TURTLE, sink);
- assert(reader);
-
- // Test reading a string that ends exactly at the end of input (no newline)
- assert(
- !serd_reader_start_string(reader,
- "<http://example.org/s> <http://example.org/p> "
- "<http://example.org/o> .",
- NULL));
-
- assert(!serd_reader_read_document(reader));
- assert(rt.n_base == 0);
- assert(rt.n_prefix == 0);
- assert(rt.n_statement == 1);
- assert(rt.n_end == 0);
- assert(!serd_reader_finish(reader));
-
- serd_reader_free(reader);
- serd_sink_free(sink);
- serd_world_free(world);
-}
-
static size_t
faulty_sink(const void* const buf,
const size_t size,
@@ -508,7 +237,7 @@ static void
test_reader(const char* path)
{
SerdWorld* world = serd_world_new();
- ReaderTest rt = {0, 0, 0, 0};
+ ReaderTest rt = {0};
SerdSink* const sink = serd_sink_new(&rt, test_sink, NULL);
assert(sink);
@@ -544,43 +273,9 @@ test_reader(const char* path)
assert(!serd_reader_start_file(reader, path, true));
assert(!serd_reader_read_document(reader));
- assert(rt.n_base == 0);
- assert(rt.n_prefix == 0);
assert(rt.n_statement == 6);
- assert(rt.n_end == 0);
assert(!serd_reader_finish(reader));
- // A read of a big page hits EOF then fails to read chunks immediately
- {
- FILE* const in = fopen(path, "rb");
-
- serd_reader_start_stream(
- reader, (SerdReadFunc)fread, (SerdStreamErrorFunc)ferror, in, NULL, 4096);
-
- assert(serd_reader_read_chunk(reader) == SERD_SUCCESS);
- assert(serd_reader_read_chunk(reader) == SERD_FAILURE);
- assert(serd_reader_read_chunk(reader) == SERD_FAILURE);
-
- serd_reader_finish(reader);
- fclose(in);
- }
-
- // A byte-wise reader that hits EOF once then continues (like a socket)
- {
- size_t n_reads = 0;
- serd_reader_start_stream(reader,
- (SerdReadFunc)eof_test_read,
- (SerdStreamErrorFunc)eof_test_error,
- &n_reads,
- NULL,
- 1);
-
- assert(serd_reader_read_chunk(reader) == SERD_SUCCESS);
- assert(serd_reader_read_chunk(reader) == SERD_FAILURE);
- assert(serd_reader_read_chunk(reader) == SERD_SUCCESS);
- assert(serd_reader_read_chunk(reader) == SERD_FAILURE);
- }
-
serd_reader_free(reader);
serd_sink_free(sink);
serd_world_free(world);
@@ -599,24 +294,15 @@ main(void)
#endif
const char* const ttl_name = "serd_test_reader_writer.ttl";
- const char* const nq_name = "serd_test_reader_writer.nq";
const size_t ttl_name_len = strlen(ttl_name);
- const size_t nq_name_len = strlen(nq_name);
const size_t path_len = tmp_len + 1 + ttl_name_len;
char* const path = (char*)calloc(path_len + 1, 1);
memcpy(path, tmp, tmp_len + 1);
path[tmp_len] = '/';
-
- memcpy(path + tmp_len + 1, nq_name, nq_name_len + 1);
- test_read_nquads_chunks(path);
-
memcpy(path + tmp_len + 1, ttl_name, ttl_name_len + 1);
- test_read_turtle_chunks(path);
- test_read_string();
test_write_errors();
-
test_writer(path);
test_reader(path);
generated by cgit v1.2.1 (git 2.18.0) at 2024-12-24 20:43:52 +0000