From 8577bb961b6819506619a0dff06f65796f56c86a Mon Sep 17 00:00:00 2001 From: David Robillard Date: Sun, 11 Jul 2021 11:14:28 -0400 Subject: Split out simple reader unit tests --- test/test_reader_writer.c | 320 +--------------------------------------------- 1 file changed, 3 insertions(+), 317 deletions(-) (limited to 'test/test_reader_writer.c') 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 _:o1 .\n" - "_:s2 _: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, - " " - " .\n"); - - fprintf(f, - " " - " .\n"); - - fwrite(&null, sizeof(null), 1, f); - - fprintf(f, - " " - " .\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 .\n"); - fprintf(f, "@prefix eg: .\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, - " " - " .", - 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); -- cgit v1.2.1