universe@789: /* universe@789: * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. universe@789: * universe@789: * Copyright 2023 Mike Becker, Olaf Wintermann All rights reserved. universe@789: * universe@789: * Redistribution and use in source and binary forms, with or without universe@789: * modification, are permitted provided that the following conditions are met: universe@789: * universe@789: * 1. Redistributions of source code must retain the above copyright universe@789: * notice, this list of conditions and the following disclaimer. universe@789: * universe@789: * 2. Redistributions in binary form must reproduce the above copyright universe@789: * notice, this list of conditions and the following disclaimer in the universe@789: * documentation and/or other materials provided with the distribution. universe@789: * universe@789: * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" universe@789: * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE universe@789: * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE universe@789: * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE universe@789: * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR universe@789: * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF universe@789: * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS universe@789: * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN universe@789: * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) universe@789: * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE universe@789: * POSSIBILITY OF SUCH DAMAGE. universe@789: */ universe@789: universe@789: #include "cx/test.h" universe@789: #include "util_allocator.h" universe@789: universe@789: #include "cx/buffer.h" universe@789: universe@789: static CX_TEST_SUBROUTINE(expect_default_flush_config, CxBuffer *buf) { universe@789: CX_TEST_ASSERT(buf->flush_blkmax == 0); universe@789: CX_TEST_ASSERT(buf->flush_blksize == 4096); universe@789: CX_TEST_ASSERT(buf->flush_threshold == SIZE_MAX); universe@789: CX_TEST_ASSERT(buf->flush_func == NULL); universe@789: CX_TEST_ASSERT(buf->flush_target == NULL); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_init_wrap_space) { universe@789: CxTestingAllocator talloc; universe@789: cx_testing_allocator_init(&talloc); universe@789: CxAllocator *alloc = &talloc.base; universe@789: CX_TEST_DO { universe@789: CxBuffer buf; universe@789: void *space = cxMalloc(alloc, 16); universe@789: cxBufferInit(&buf, space, 16, alloc, CX_BUFFER_DEFAULT); universe@789: CX_TEST_CALL_SUBROUTINE(expect_default_flush_config, &buf); universe@789: CX_TEST_ASSERT(buf.space == space); universe@789: CX_TEST_ASSERT((buf.flags & CX_BUFFER_AUTO_EXTEND) == 0); universe@789: CX_TEST_ASSERT((buf.flags & CX_BUFFER_FREE_CONTENTS) == 0); universe@789: CX_TEST_ASSERT(buf.pos == 0); universe@789: CX_TEST_ASSERT(buf.size == 0); universe@789: CX_TEST_ASSERT(buf.capacity == 16); universe@789: CX_TEST_ASSERT(buf.allocator == alloc); universe@789: cxBufferDestroy(&buf); universe@789: CX_TEST_ASSERT(!cx_testing_allocator_verify(&talloc)); universe@789: cxFree(alloc, space); universe@789: CX_TEST_ASSERT(cx_testing_allocator_verify(&talloc)); universe@789: } universe@789: cx_testing_allocator_destroy(&talloc); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_init_wrap_space_auto_extend) { universe@789: CxTestingAllocator talloc; universe@789: cx_testing_allocator_init(&talloc); universe@789: CxAllocator *alloc = &talloc.base; universe@789: CX_TEST_DO { universe@789: CxBuffer buf; universe@789: void *space = cxMalloc(alloc, 16); universe@789: cxBufferInit(&buf, space, 16, alloc, CX_BUFFER_AUTO_EXTEND); universe@789: CX_TEST_CALL_SUBROUTINE(expect_default_flush_config, &buf); universe@789: CX_TEST_ASSERT(buf.space == space); universe@789: CX_TEST_ASSERT((buf.flags & CX_BUFFER_AUTO_EXTEND) == CX_BUFFER_AUTO_EXTEND); universe@789: CX_TEST_ASSERT((buf.flags & CX_BUFFER_FREE_CONTENTS) == 0); universe@789: CX_TEST_ASSERT(buf.pos == 0); universe@789: CX_TEST_ASSERT(buf.size == 0); universe@789: CX_TEST_ASSERT(buf.capacity == 16); universe@789: CX_TEST_ASSERT(buf.allocator == alloc); universe@789: cxBufferDestroy(&buf); universe@789: CX_TEST_ASSERT(!cx_testing_allocator_verify(&talloc)); universe@789: cxFree(alloc, space); universe@789: CX_TEST_ASSERT(cx_testing_allocator_verify(&talloc)); universe@789: } universe@789: cx_testing_allocator_destroy(&talloc); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_init_wrap_space_auto_free) { universe@789: CxTestingAllocator talloc; universe@789: cx_testing_allocator_init(&talloc); universe@789: CxAllocator *alloc = &talloc.base; universe@789: CX_TEST_DO { universe@789: CxBuffer buf; universe@789: void *space = cxMalloc(alloc, 16); universe@789: cxBufferInit(&buf, space, 16, alloc, CX_BUFFER_FREE_CONTENTS); universe@789: CX_TEST_CALL_SUBROUTINE(expect_default_flush_config, &buf); universe@789: CX_TEST_ASSERT(buf.space == space); universe@789: CX_TEST_ASSERT((buf.flags & CX_BUFFER_AUTO_EXTEND) == 0); universe@789: CX_TEST_ASSERT((buf.flags & CX_BUFFER_FREE_CONTENTS) == CX_BUFFER_FREE_CONTENTS); universe@789: CX_TEST_ASSERT(buf.pos == 0); universe@789: CX_TEST_ASSERT(buf.size == 0); universe@789: CX_TEST_ASSERT(buf.capacity == 16); universe@789: CX_TEST_ASSERT(buf.allocator == alloc); universe@789: CX_TEST_ASSERT(!cx_testing_allocator_verify(&talloc)); universe@789: cxBufferDestroy(&buf); universe@789: CX_TEST_ASSERT(cx_testing_allocator_verify(&talloc)); universe@789: } universe@789: cx_testing_allocator_destroy(&talloc); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_init_fresh_space) { universe@789: CxTestingAllocator talloc; universe@789: cx_testing_allocator_init(&talloc); universe@789: CxAllocator *alloc = &talloc.base; universe@789: CX_TEST_DO { universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, NULL, 8, alloc, CX_BUFFER_DEFAULT); universe@789: CX_TEST_CALL_SUBROUTINE(expect_default_flush_config, &buf); universe@789: CX_TEST_ASSERT(buf.space != NULL); universe@789: CX_TEST_ASSERT((buf.flags & CX_BUFFER_AUTO_EXTEND) == 0); universe@789: CX_TEST_ASSERT((buf.flags & CX_BUFFER_FREE_CONTENTS) == CX_BUFFER_FREE_CONTENTS); universe@789: CX_TEST_ASSERT(buf.pos == 0); universe@789: CX_TEST_ASSERT(buf.size == 0); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.allocator == alloc); universe@789: CX_TEST_ASSERT(!cx_testing_allocator_verify(&talloc)); // space is still allocated universe@789: cxBufferDestroy(&buf); universe@789: CX_TEST_ASSERT(cx_testing_allocator_verify(&talloc)); universe@789: } universe@789: cx_testing_allocator_destroy(&talloc); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_init_on_heap) { universe@789: CxTestingAllocator talloc; universe@789: cx_testing_allocator_init(&talloc); universe@789: CxAllocator *alloc = &talloc.base; universe@789: CX_TEST_DO { universe@789: CxBuffer *buf; universe@789: void *space = cxMalloc(alloc, 16); universe@789: buf = cxBufferCreate(space, 16, alloc, CX_BUFFER_FREE_CONTENTS); universe@789: CX_TEST_ASSERT(buf != NULL); universe@789: CX_TEST_CALL_SUBROUTINE(expect_default_flush_config, buf); universe@789: CX_TEST_ASSERT(buf->space == space); universe@789: CX_TEST_ASSERT((buf->flags & CX_BUFFER_AUTO_EXTEND) == 0); universe@789: CX_TEST_ASSERT((buf->flags & CX_BUFFER_FREE_CONTENTS) == CX_BUFFER_FREE_CONTENTS); universe@789: CX_TEST_ASSERT(buf->pos == 0); universe@789: CX_TEST_ASSERT(buf->size == 0); universe@789: CX_TEST_ASSERT(buf->capacity == 16); universe@789: CX_TEST_ASSERT(buf->allocator == alloc); universe@789: cxBufferFree(buf); universe@789: CX_TEST_ASSERT(cx_testing_allocator_verify(&talloc)); universe@789: } universe@789: cx_testing_allocator_destroy(&talloc); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_minimum_capacity_sufficient) { universe@789: CxTestingAllocator talloc; universe@789: cx_testing_allocator_init(&talloc); universe@789: CxAllocator *alloc = &talloc.base; universe@789: CX_TEST_DO { universe@789: void *space = cxMalloc(alloc, 8); universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, space, 8, alloc, CX_BUFFER_FREE_CONTENTS); universe@789: memcpy(space, "Testing", 8); universe@789: buf.size = 8; universe@789: cxBufferMinimumCapacity(&buf, 6); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.size == 8); universe@789: CX_TEST_ASSERT(memcmp(buf.space, "Testing", 8) == 0); universe@789: cxBufferDestroy(&buf); universe@789: CX_TEST_ASSERT(cx_testing_allocator_verify(&talloc)); universe@789: } universe@789: cx_testing_allocator_destroy(&talloc); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_minimum_capacity_extend) { universe@789: CxTestingAllocator talloc; universe@789: cx_testing_allocator_init(&talloc); universe@789: CxAllocator *alloc = &talloc.base; universe@789: CX_TEST_DO { universe@789: void *space = cxMalloc(alloc, 8); universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, space, 8, alloc, CX_BUFFER_FREE_CONTENTS); // NO auto extend! universe@789: memcpy(space, "Testing", 8); universe@789: buf.size = 8; universe@789: cxBufferMinimumCapacity(&buf, 16); universe@789: CX_TEST_ASSERT(buf.capacity == 16); universe@789: CX_TEST_ASSERT(buf.size == 8); universe@789: CX_TEST_ASSERT(memcmp(buf.space, "Testing", 8) == 0); universe@789: cxBufferDestroy(&buf); universe@789: CX_TEST_ASSERT(cx_testing_allocator_verify(&talloc)); universe@789: } universe@789: cx_testing_allocator_destroy(&talloc); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_clear) { universe@789: char space[16]; universe@789: strcpy(space, "clear test"); universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, space, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@789: CX_TEST_DO { universe@789: CX_TEST_ASSERT(buf.size == 0); universe@789: // only clear the used part of the buffer universe@789: cxBufferClear(&buf); universe@789: CX_TEST_ASSERT(0 == memcmp(space, "clear test", 10)); universe@789: buf.size = 5; universe@789: buf.pos = 3; universe@789: cxBufferClear(&buf); universe@789: CX_TEST_ASSERT(0 == memcmp(space, "\0\0\0\0\0 test", 10)); universe@789: CX_TEST_ASSERT(buf.size == 0); universe@789: CX_TEST_ASSERT(buf.pos == 0); universe@789: } universe@789: cxBufferDestroy(&buf); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_reset) { universe@789: char space[16]; universe@789: strcpy(space, "reset test"); universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, space, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@789: CX_TEST_DO { universe@789: buf.size = 5; universe@789: buf.pos = 3; universe@789: cxBufferReset(&buf); universe@789: CX_TEST_ASSERT(0 == memcmp(space, "reset test", 10)); universe@789: CX_TEST_ASSERT(buf.size == 0); universe@789: CX_TEST_ASSERT(buf.pos == 0); universe@789: } universe@789: cxBufferDestroy(&buf); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_seek_set_zero) { universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@789: buf.size = 6; universe@789: buf.pos = 3; universe@789: CX_TEST_DO { universe@789: int result = cxBufferSeek(&buf, 0, SEEK_SET); universe@789: CX_TEST_ASSERT(result == 0); universe@789: CX_TEST_ASSERT(buf.pos == 0); universe@789: } universe@789: cxBufferDestroy(&buf); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_seek_set_valid) { universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@789: buf.size = 6; universe@789: buf.pos = 3; universe@789: CX_TEST_DO { universe@789: int result = cxBufferSeek(&buf, 5, SEEK_SET); universe@789: CX_TEST_ASSERT(result == 0); universe@789: CX_TEST_ASSERT(buf.pos == 5); universe@789: } universe@789: cxBufferDestroy(&buf); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_seek_set_invalid) { universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@789: buf.size = 6; universe@789: buf.pos = 3; universe@789: CX_TEST_DO { universe@789: int result = cxBufferSeek(&buf, 6, SEEK_SET); universe@789: CX_TEST_ASSERT(result != 0); universe@789: CX_TEST_ASSERT(buf.pos == 3); universe@789: } universe@789: cxBufferDestroy(&buf); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_seek_cur_zero) { universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@789: buf.size = 6; universe@789: buf.pos = 3; universe@789: CX_TEST_DO { universe@789: int result = cxBufferSeek(&buf, 0, SEEK_CUR); universe@789: CX_TEST_ASSERT(result == 0); universe@789: CX_TEST_ASSERT(buf.pos == 3); universe@789: } universe@789: cxBufferDestroy(&buf); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_seek_cur_valid_positive) { universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@789: buf.size = 6; universe@789: buf.pos = 3; universe@789: CX_TEST_DO { universe@789: int result = cxBufferSeek(&buf, 2, SEEK_CUR); universe@789: CX_TEST_ASSERT(result == 0); universe@789: CX_TEST_ASSERT(buf.pos == 5); universe@789: } universe@789: cxBufferDestroy(&buf); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_seek_cur_valid_negative) { universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@789: buf.size = 6; universe@789: buf.pos = 3; universe@789: CX_TEST_DO { universe@789: int result = cxBufferSeek(&buf, -3, SEEK_CUR); universe@789: CX_TEST_ASSERT(result == 0); universe@789: CX_TEST_ASSERT(buf.pos == 0); universe@789: } universe@789: cxBufferDestroy(&buf); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_seek_cur_invalid_positive) { universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@789: buf.size = 6; universe@789: buf.pos = 3; universe@789: CX_TEST_DO { universe@789: int result = cxBufferSeek(&buf, 3, SEEK_CUR); universe@789: CX_TEST_ASSERT(result != 0); universe@789: CX_TEST_ASSERT(buf.pos == 3); universe@789: } universe@789: cxBufferDestroy(&buf); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_seek_cur_invalid_negative) { universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@789: buf.size = 6; universe@789: buf.pos = 3; universe@789: CX_TEST_DO { universe@789: int result = cxBufferSeek(&buf, -4, SEEK_CUR); universe@789: CX_TEST_ASSERT(result != 0); universe@789: CX_TEST_ASSERT(buf.pos == 3); universe@789: } universe@789: cxBufferDestroy(&buf); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_seek_end_zero) { universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@789: buf.size = 6; universe@789: buf.pos = 3; universe@789: CX_TEST_DO { universe@789: int result = cxBufferSeek(&buf, 0, SEEK_END); universe@789: // the (past-the-)end position is always invalid universe@789: CX_TEST_ASSERT(result != 0); universe@789: CX_TEST_ASSERT(buf.pos == 3); universe@789: } universe@789: cxBufferDestroy(&buf); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_seek_end_valid) { universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@789: buf.size = 6; universe@789: buf.pos = 3; universe@789: CX_TEST_DO { universe@789: int result = cxBufferSeek(&buf, -6, SEEK_END); universe@789: CX_TEST_ASSERT(result == 0); universe@789: CX_TEST_ASSERT(buf.pos == 0); universe@789: } universe@789: cxBufferDestroy(&buf); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_seek_end_invalid) { universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@789: buf.size = 6; universe@789: buf.pos = 3; universe@789: CX_TEST_DO { universe@789: int result = cxBufferSeek(&buf, 1, SEEK_END); universe@789: CX_TEST_ASSERT(result != 0); universe@789: CX_TEST_ASSERT(buf.pos == 3); universe@789: } universe@789: cxBufferDestroy(&buf); universe@789: } universe@789: universe@789: CX_TEST(test_buffer_seek_whence_invalid) { universe@789: CxBuffer buf; universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@789: buf.size = 6; universe@789: buf.pos = 3; universe@789: CX_TEST_DO { universe@789: int result = cxBufferSeek(&buf, 2, 9000); universe@789: CX_TEST_ASSERT(result != 0); universe@789: CX_TEST_ASSERT(buf.size == 6); universe@789: CX_TEST_ASSERT(buf.pos == 3); universe@789: } universe@789: cxBufferDestroy(&buf); universe@789: } universe@789: universe@792: CX_TEST(test_buffer_eof_reached) { universe@792: CxBuffer buf; universe@792: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@792: buf.size = buf.pos = 3; universe@792: CX_TEST_DO { universe@792: CX_TEST_ASSERT(cxBufferEof(&buf)); universe@792: buf.pos = buf.size - 1; universe@792: CX_TEST_ASSERT(!cxBufferEof(&buf)); universe@792: cxBufferPut(&buf, 'a'); universe@792: CX_TEST_ASSERT(cxBufferEof(&buf)); universe@792: } universe@792: cxBufferDestroy(&buf); universe@792: } universe@792: universe@792: CX_TEST(test_buffer_eof_not_reached) { universe@792: CxBuffer buf; universe@792: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@792: buf.size = 6; universe@792: CX_TEST_DO { universe@792: buf.pos = buf.size - 1; universe@792: CX_TEST_ASSERT(!cxBufferEof(&buf)); universe@792: buf.pos = 0; universe@792: cxBufferWrite("test", 1, 5, &buf); universe@792: CX_TEST_ASSERT(!cxBufferEof(&buf)); universe@792: } universe@792: cxBufferDestroy(&buf); universe@792: } universe@792: universe@792: #define TEST_BUFFER_SHIFT_SETUP(buf) \ universe@792: CxTestingAllocator talloc; \ universe@792: cx_testing_allocator_init(&talloc); \ universe@792: CxAllocator *alloc = &talloc.base; \ universe@792: CxBuffer buf; \ universe@792: cxBufferInit(&buf, NULL, 16, alloc, CX_BUFFER_DEFAULT); \ universe@792: memcpy(buf.space, "test____XXXXXXXX", 16); \ universe@792: buf.capacity = 8; \ universe@792: buf.pos = 4; \ universe@792: buf.size = 4 universe@792: #define TEST_BUFFER_SHIFT_TEARDOWN(buf) \ universe@792: cxBufferDestroy(&buf); \ universe@792: CX_TEST_ASSERT(cx_testing_allocator_verify(&talloc)); \ universe@793: cx_testing_allocator_destroy(&talloc) universe@792: universe@792: universe@792: CX_TEST(test_buffer_shift_left_zero) { universe@792: TEST_BUFFER_SHIFT_SETUP(buf); universe@792: CX_TEST_DO { universe@792: int ret = cxBufferShiftLeft(&buf, 0); universe@792: CX_TEST_ASSERT(ret == 0); universe@792: CX_TEST_ASSERT(buf.pos == 4); universe@792: CX_TEST_ASSERT(buf.size == 4); universe@792: CX_TEST_ASSERT(memcmp(buf.space, "test____XXXXXXXX", 16) == 0); universe@792: TEST_BUFFER_SHIFT_TEARDOWN(buf); universe@792: } universe@792: } universe@792: universe@792: CX_TEST(test_buffer_shift_left_zero_offset_interface) { universe@792: TEST_BUFFER_SHIFT_SETUP(buf); universe@792: CX_TEST_DO { universe@792: int ret = cxBufferShift(&buf, -0); universe@792: CX_TEST_ASSERT(ret == 0); universe@792: CX_TEST_ASSERT(buf.pos == 4); universe@792: CX_TEST_ASSERT(buf.size == 4); universe@792: CX_TEST_ASSERT(memcmp(buf.space, "test____XXXXXXXX", 16) == 0); universe@792: TEST_BUFFER_SHIFT_TEARDOWN(buf); universe@792: } universe@792: } universe@792: universe@792: CX_TEST(test_buffer_shift_left_standard) { universe@792: TEST_BUFFER_SHIFT_SETUP(buf); universe@792: CX_TEST_DO { universe@792: int ret = cxBufferShiftLeft(&buf, 2); universe@792: CX_TEST_ASSERT(ret == 0); universe@792: CX_TEST_ASSERT(buf.pos == 2); universe@792: CX_TEST_ASSERT(buf.size == 2); universe@792: CX_TEST_ASSERT(memcmp(buf.space, "stst____XXXXXXXX", 16) == 0); universe@792: TEST_BUFFER_SHIFT_TEARDOWN(buf); universe@792: } universe@792: } universe@792: universe@792: CX_TEST(test_buffer_shift_left_overshift) { universe@792: TEST_BUFFER_SHIFT_SETUP(buf); universe@792: CX_TEST_DO { universe@792: int ret = cxBufferShiftLeft(&buf, 6); universe@792: CX_TEST_ASSERT(ret == 0); universe@792: CX_TEST_ASSERT(buf.pos == 0); universe@792: CX_TEST_ASSERT(buf.size == 0); universe@792: CX_TEST_ASSERT(memcmp(buf.space, "test____XXXXXXXX", 16) == 0); universe@792: TEST_BUFFER_SHIFT_TEARDOWN(buf); universe@792: } universe@792: } universe@792: universe@792: CX_TEST(test_buffer_shift_left_overshift_pos_only) { universe@792: TEST_BUFFER_SHIFT_SETUP(buf); universe@792: buf.pos = 2; universe@792: CX_TEST_DO { universe@792: int ret = cxBufferShiftLeft(&buf, 3); universe@792: CX_TEST_ASSERT(ret == 0); universe@792: CX_TEST_ASSERT(buf.pos == 0); universe@792: CX_TEST_ASSERT(buf.size == 1); universe@792: CX_TEST_ASSERT(memcmp(buf.space, "test____XXXXXXXX", 16) == 0); universe@792: TEST_BUFFER_SHIFT_TEARDOWN(buf); universe@792: } universe@792: } universe@792: universe@792: CX_TEST(test_buffer_shift_left_offset_interface) { universe@792: TEST_BUFFER_SHIFT_SETUP(buf); universe@792: buf.pos = 3; universe@792: CX_TEST_DO { universe@792: int ret = cxBufferShift(&buf, -2); universe@792: CX_TEST_ASSERT(ret == 0); universe@792: CX_TEST_ASSERT(buf.pos == 1); universe@792: CX_TEST_ASSERT(buf.size == 2); universe@792: CX_TEST_ASSERT(memcmp(buf.space, "stst____XXXXXXXX", 16) == 0); universe@792: TEST_BUFFER_SHIFT_TEARDOWN(buf); universe@792: } universe@792: } universe@792: universe@792: CX_TEST(test_buffer_shift_right_zero) { universe@792: TEST_BUFFER_SHIFT_SETUP(buf); universe@792: CX_TEST_DO { universe@792: int ret = cxBufferShiftRight(&buf, 0); universe@792: CX_TEST_ASSERT(ret == 0); universe@792: CX_TEST_ASSERT(buf.pos == 4); universe@792: CX_TEST_ASSERT(buf.size == 4); universe@792: CX_TEST_ASSERT(memcmp(buf.space, "test____XXXXXXXX", 16) == 0); universe@792: TEST_BUFFER_SHIFT_TEARDOWN(buf); universe@792: } universe@792: } universe@792: universe@792: CX_TEST(test_buffer_shift_right_zero_offset_interface) { universe@792: TEST_BUFFER_SHIFT_SETUP(buf); universe@792: CX_TEST_DO { universe@792: int ret = cxBufferShift(&buf, +0); universe@792: CX_TEST_ASSERT(ret == 0); universe@792: CX_TEST_ASSERT(buf.pos == 4); universe@792: CX_TEST_ASSERT(buf.size == 4); universe@792: CX_TEST_ASSERT(memcmp(buf.space, "test____XXXXXXXX", 16) == 0); universe@792: TEST_BUFFER_SHIFT_TEARDOWN(buf); universe@792: } universe@792: } universe@792: universe@792: CX_TEST(test_buffer_shift_right_standard) { universe@792: TEST_BUFFER_SHIFT_SETUP(buf); universe@792: CX_TEST_DO { universe@792: int ret = cxBufferShiftRight(&buf, 3); universe@792: CX_TEST_ASSERT(ret == 0); universe@792: CX_TEST_ASSERT(buf.pos == 7); universe@792: CX_TEST_ASSERT(buf.size == 7); universe@792: CX_TEST_ASSERT(memcmp(buf.space, "testest_XXXXXXXX", 16) == 0); universe@792: TEST_BUFFER_SHIFT_TEARDOWN(buf); universe@792: } universe@792: } universe@792: universe@792: CX_TEST(test_buffer_shift_right_overshift_discard) { universe@792: TEST_BUFFER_SHIFT_SETUP(buf); universe@792: CX_TEST_DO { universe@792: int ret = cxBufferShiftRight(&buf, 6); universe@792: CX_TEST_ASSERT(ret == 0); universe@792: CX_TEST_ASSERT(buf.pos == 8); universe@792: CX_TEST_ASSERT(buf.size == 8); universe@792: CX_TEST_ASSERT(buf.capacity == 8); universe@792: CX_TEST_ASSERT(memcmp(buf.space, "test__teXXXXXXXX", 16) == 0); universe@792: TEST_BUFFER_SHIFT_TEARDOWN(buf); universe@792: } universe@792: } universe@792: universe@792: CX_TEST(test_buffer_shift_right_overshift_extend) { universe@792: TEST_BUFFER_SHIFT_SETUP(buf); universe@792: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@792: CX_TEST_DO { universe@792: int ret = cxBufferShiftRight(&buf, 6); universe@792: CX_TEST_ASSERT(ret == 0); universe@792: CX_TEST_ASSERT(buf.pos == 10); universe@792: CX_TEST_ASSERT(buf.size == 10); universe@792: CX_TEST_ASSERT(buf.capacity >= 10); universe@792: // cannot assert more than 10 bytes because universe@792: // the buffer was required to reallocate the space universe@792: CX_TEST_ASSERT(memcmp(buf.space, "test__test", 10) == 0); universe@792: TEST_BUFFER_SHIFT_TEARDOWN(buf); universe@792: } universe@792: } universe@792: universe@792: CX_TEST(test_buffer_shift_right_offset_interface) { universe@792: TEST_BUFFER_SHIFT_SETUP(buf); universe@792: buf.pos = 3; universe@792: CX_TEST_DO { universe@792: int ret = cxBufferShift(&buf, 2); universe@792: CX_TEST_ASSERT(ret == 0); universe@792: CX_TEST_ASSERT(buf.pos == 5); universe@792: CX_TEST_ASSERT(buf.size == 6); universe@792: CX_TEST_ASSERT(memcmp(buf.space, "tetest__XXXXXXXX", 16) == 0); universe@792: TEST_BUFFER_SHIFT_TEARDOWN(buf); universe@792: } universe@792: } universe@792: universe@793: static size_t mock_write_limited_rate( universe@793: void const *ptr, universe@793: size_t size, universe@793: __attribute__((unused)) size_t nitems, universe@793: CxBuffer *buffer universe@793: ) { universe@793: // simulate limited target drain capacity universe@793: static bool full = false; universe@793: if (full) { universe@793: full = false; universe@793: return 0; universe@793: } else { universe@793: full = true; universe@793: return cxBufferWrite(ptr, size, nitems > 2 ? 2 : nitems, buffer); universe@793: } universe@793: } universe@793: universe@793: CX_TEST(test_buffer_write_size_one_fit) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = buf.pos = 4; universe@793: const char *data = "test"; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferWrite(data, 1, 4, &buf); universe@793: CX_TEST_ASSERT(written == 4); universe@793: CX_TEST_ASSERT(buf.size == 8); universe@793: CX_TEST_ASSERT(buf.pos == 8); universe@793: CX_TEST_ASSERT(buf.capacity == 8); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "preptest", 8)); universe@793: } universe@793: universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_write_size_one_discard) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = buf.pos = 4; universe@793: const char *data = "testing"; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferWrite(data, 1, 7, &buf); universe@793: CX_TEST_ASSERT(written == 4); universe@793: CX_TEST_ASSERT(buf.size == 8); universe@793: CX_TEST_ASSERT(buf.pos == 8); universe@793: CX_TEST_ASSERT(buf.capacity == 8); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "preptest\0", 9)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_write_size_one_extend) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = buf.pos = 4; universe@793: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@793: const char *data = "testing"; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferWrite(data, 1, 7, &buf); universe@793: CX_TEST_ASSERT(written == 7); universe@793: CX_TEST_ASSERT(buf.size == 11); universe@793: CX_TEST_ASSERT(buf.pos == 11); universe@793: CX_TEST_ASSERT(buf.capacity >= 11); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "preptesting", 11)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_write_multibyte_fit) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = buf.pos = 4; universe@793: const char *data = "test"; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferWrite(data, 2, 2, &buf); universe@793: CX_TEST_ASSERT(written == 2); universe@793: CX_TEST_ASSERT(buf.size == 8); universe@793: CX_TEST_ASSERT(buf.pos == 8); universe@793: CX_TEST_ASSERT(buf.capacity == 8); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "preptest", 8)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_write_multibyte_discard) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = 4; universe@793: buf.pos = 3; universe@793: const char *data = "testing"; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferWrite(data, 2, 4, &buf); universe@793: // remember: whole elements are discarded if they do not fit universe@793: CX_TEST_ASSERT(written == 2); universe@793: CX_TEST_ASSERT(buf.size == 7); universe@793: CX_TEST_ASSERT(buf.pos == 7); universe@793: CX_TEST_ASSERT(buf.capacity == 8); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "pretest\0", 8)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_write_multibyte_extend) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = 4; universe@793: buf.pos = 3; universe@793: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@793: const char *data = "tester"; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferWrite(data, 2, 3, &buf); universe@793: // remember: whole elements are discarded if they do not fit universe@793: CX_TEST_ASSERT(written == 3); universe@793: CX_TEST_ASSERT(buf.size == 9); universe@793: CX_TEST_ASSERT(buf.pos == 9); universe@793: CX_TEST_ASSERT(buf.capacity >= 9); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "pretester", 9)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_put_fit) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = buf.pos = 4; universe@793: CX_TEST_DO { universe@793: int c = cxBufferPut(&buf, 0x200 | 'a'); universe@793: CX_TEST_ASSERT(c == 'a'); universe@793: CX_TEST_ASSERT(buf.size == 5); universe@793: CX_TEST_ASSERT(buf.pos == 5); universe@793: CX_TEST_ASSERT(buf.capacity == 8); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "prepa\0", 6)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_put_discard) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = 4; universe@793: buf.pos = 8; universe@793: CX_TEST_DO { universe@793: int c = cxBufferPut(&buf, 0x200 | 'a'); universe@793: CX_TEST_ASSERT(c == EOF); universe@793: CX_TEST_ASSERT(buf.size == 4); universe@793: CX_TEST_ASSERT(buf.pos == 8); universe@793: CX_TEST_ASSERT(buf.capacity == 8); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "prep\0\0\0\0\0", 9)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_put_extend) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = 4; universe@793: buf.pos = 8; universe@793: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@793: CX_TEST_DO { universe@793: int c = cxBufferPut(&buf, 0x200 | 'a'); universe@793: CX_TEST_ASSERT(c == 'a'); universe@793: CX_TEST_ASSERT(buf.size == 9); universe@793: CX_TEST_ASSERT(buf.pos == 9); universe@793: CX_TEST_ASSERT(buf.capacity >= 9); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "prep\0\0\0\0a", 9)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_put_string_fit) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = buf.pos = 4; universe@793: const char *data = "test"; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferPutString(&buf, data); universe@793: CX_TEST_ASSERT(written == 4); universe@793: CX_TEST_ASSERT(buf.size == 8); universe@793: CX_TEST_ASSERT(buf.pos == 8); universe@793: CX_TEST_ASSERT(buf.capacity == 8); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "preptest", 8)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_put_string_discard) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = buf.pos = 4; universe@793: const char *data = "testing"; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferPutString(&buf, data); universe@793: CX_TEST_ASSERT(written == 4); universe@793: CX_TEST_ASSERT(buf.size == 8); universe@793: CX_TEST_ASSERT(buf.pos == 8); universe@793: CX_TEST_ASSERT(buf.capacity == 8); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "preptest\0", 9)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_put_string_extend) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = buf.pos = 4; universe@793: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@793: const char *data = "testing"; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferPutString(&buf, data); universe@793: CX_TEST_ASSERT(written == 7); universe@793: CX_TEST_ASSERT(buf.size == 11); universe@793: CX_TEST_ASSERT(buf.pos == 11); universe@793: CX_TEST_ASSERT(buf.capacity >= 11); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "preptesting", 11)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_write_size_overflow) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = buf.pos = 4; universe@793: const char *data = "testing"; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferWrite(data, 8, SIZE_MAX / 4, &buf); universe@793: CX_TEST_ASSERT(written == 0); universe@793: CX_TEST_ASSERT(buf.capacity == 8); universe@793: CX_TEST_ASSERT(buf.pos == 4); universe@793: CX_TEST_ASSERT(buf.size == 4); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "prep\0", 5)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_write_capacity_overflow) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = buf.pos = 4; universe@793: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@793: const char *data = "testing"; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferWrite(data, 1, SIZE_MAX - 2, &buf); universe@793: CX_TEST_ASSERT(written == 0); universe@793: CX_TEST_ASSERT(buf.capacity == 8); universe@793: CX_TEST_ASSERT(buf.pos == 4); universe@793: CX_TEST_ASSERT(buf.size == 4); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "prep\0", 5)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_write_only_overwrite) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "preptest\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.pos = 3; universe@793: buf.size = 8; universe@793: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferWrite("XXX", 2, 2, &buf); universe@793: CX_TEST_ASSERT(written == 2); universe@793: CX_TEST_ASSERT(buf.capacity == 8); universe@793: CX_TEST_ASSERT(buf.size == 8); universe@793: CX_TEST_ASSERT(buf.pos == 7); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, "preXXX\0t", 8)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_write_flush_at_capacity) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = buf.pos = 4; universe@793: buf.flush_target = ⌖ universe@793: buf.flush_func = (cx_write_func)cxBufferWrite; universe@793: buf.flush_blkmax = 1; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferWrite("foo", 1, 3, &buf); universe@793: CX_TEST_ASSERT(written == 3); universe@793: CX_TEST_ASSERT(buf.pos == 7); universe@793: CX_TEST_ASSERT(buf.size == 7); universe@793: CX_TEST_ASSERT(target.pos == 0); universe@793: CX_TEST_ASSERT(target.size == 0); universe@793: written = cxBufferWrite("hello", 1, 5, &buf); universe@793: CX_TEST_ASSERT(written == 5); universe@793: CX_TEST_ASSERT(buf.pos == 0); universe@793: CX_TEST_ASSERT(buf.size == 0); universe@793: CX_TEST_ASSERT(buf.capacity == 8); universe@793: CX_TEST_ASSERT(target.pos == 12); universe@793: CX_TEST_ASSERT(target.size == 12); universe@793: CX_TEST_ASSERT(0 == memcmp(target.space, "prepfoohello", 12)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_write_flush_at_threshold) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = buf.pos = 4; universe@793: buf.flush_target = ⌖ universe@793: buf.flush_func = (cx_write_func)cxBufferWrite; universe@793: buf.flush_blkmax = 1; universe@793: buf.flush_threshold = 12; universe@793: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferWrite("foobar", 1, 6, &buf); universe@793: CX_TEST_ASSERT(written == 6); universe@793: CX_TEST_ASSERT(buf.pos == 10); universe@793: CX_TEST_ASSERT(buf.size == 10); universe@793: CX_TEST_ASSERT(buf.capacity >= 10); universe@793: CX_TEST_ASSERT(buf.capacity <= 12); universe@793: CX_TEST_ASSERT(target.pos == 0); universe@793: CX_TEST_ASSERT(target.size == 0); universe@793: written = cxBufferWrite("hello", 1, 5, &buf); universe@793: CX_TEST_ASSERT(written == 5); universe@793: CX_TEST_ASSERT(buf.pos == 0); universe@793: CX_TEST_ASSERT(buf.size == 0); universe@793: CX_TEST_ASSERT(buf.capacity <= 12); universe@793: CX_TEST_ASSERT(target.pos == 15); universe@793: CX_TEST_ASSERT(target.size == 15); universe@793: CX_TEST_ASSERT(0 == memcmp(target.space, "prepfoobarhello", 15)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_write_flush_rate_limited) { universe@793: CxBuffer buf, target; universe@793: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "prep\0\0\0\0\0\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 8; universe@793: buf.size = buf.pos = 4; universe@793: buf.flush_target = ⌖ universe@793: buf.flush_blkmax = 1; universe@793: // limit the rate of the flush function and the capacity of the target universe@793: buf.flush_func = (cx_write_func) mock_write_limited_rate; universe@793: target.capacity = 16; universe@793: target.flags &= ~CX_BUFFER_AUTO_EXTEND; universe@793: CX_TEST_DO { universe@793: size_t written = cxBufferWrite("foo", 1, 3, &buf); universe@793: CX_TEST_ASSERT(written == 3); universe@793: CX_TEST_ASSERT(buf.pos == 7); universe@793: CX_TEST_ASSERT(buf.size == 7); universe@793: CX_TEST_ASSERT(target.pos == 0); universe@793: CX_TEST_ASSERT(target.size == 0); universe@793: written = cxBufferWrite("hello, world!", 1, 13, &buf); universe@793: // " world!" fits into this buffer, the remaining stuff is flushed out universe@793: CX_TEST_ASSERT(written == 13); universe@793: CX_TEST_ASSERT(buf.pos == 7); universe@793: CX_TEST_ASSERT(buf.size == 7); universe@793: CX_TEST_ASSERT(buf.capacity == 8); universe@793: CX_TEST_ASSERT(0 == memcmp(buf.space, " world!", 7)); universe@793: CX_TEST_ASSERT(target.pos == 13); universe@793: CX_TEST_ASSERT(target.size == 13); universe@793: CX_TEST_ASSERT(target.capacity == 16); universe@793: CX_TEST_ASSERT(0 == memcmp(target.space, "prepfoohello,", 13)); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: cxBufferDestroy(&target); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_get) { universe@793: CxBuffer buf; universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "some data\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 12; universe@793: buf.size = 9; universe@793: buf.pos = 2; universe@793: CX_TEST_DO { universe@793: CX_TEST_ASSERT(cxBufferGet(&buf) == 'm'); universe@793: CX_TEST_ASSERT(cxBufferGet(&buf) == 'e'); universe@793: CX_TEST_ASSERT(cxBufferGet(&buf) == ' '); universe@793: CX_TEST_ASSERT(cxBufferGet(&buf) == 'd'); universe@793: CX_TEST_ASSERT(buf.pos == 6); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_get_eof) { universe@793: CxBuffer buf; universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "some data\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 12; universe@793: buf.pos = buf.size = 9; universe@793: CX_TEST_DO { universe@793: CX_TEST_ASSERT(cxBufferGet(&buf) == EOF); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_read) { universe@793: CxBuffer buf; universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "some data\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 12; universe@793: buf.size = 9; universe@793: buf.pos = 2; universe@793: CX_TEST_DO { universe@793: char target[4]; universe@793: size_t read = cxBufferRead(&target, 1, 4, &buf); universe@793: CX_TEST_ASSERT(read == 4); universe@793: CX_TEST_ASSERT(0 == memcmp(&target, "me d", 4)); universe@793: CX_TEST_ASSERT(buf.pos == 6); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_read_oob) { universe@793: CxBuffer buf; universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "some data\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 12; universe@793: buf.size = 9; universe@793: buf.pos = 6; universe@793: CX_TEST_DO { universe@793: char target[4]; universe@793: size_t read = cxBufferRead(&target, 1, 4, &buf); universe@793: CX_TEST_ASSERT(read == 3); universe@793: CX_TEST_ASSERT(0 == memcmp(&target, "ata", 3)); universe@793: CX_TEST_ASSERT(buf.pos == 9); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_read_oob_multibyte) { universe@793: CxBuffer buf; universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "some data\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 12; universe@793: buf.size = 9; universe@793: buf.pos = 6; universe@793: CX_TEST_DO { universe@793: char target[4]; universe@793: target[2] = '\0'; universe@793: size_t read = cxBufferRead(&target, 2, 2, &buf); universe@793: CX_TEST_ASSERT(read == 1); universe@793: CX_TEST_ASSERT(0 == memcmp(&target, "at\0", 3)); universe@793: CX_TEST_ASSERT(buf.pos == 8); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: } universe@793: universe@793: CX_TEST(test_buffer_read_eof) { universe@793: CxBuffer buf; universe@793: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@793: memcpy(buf.space, "some data\0\0\0\0\0\0\0", 16); universe@793: buf.capacity = 12; universe@793: buf.size = buf.pos = 9; universe@793: CX_TEST_DO { universe@793: char target[4]; universe@793: size_t read = cxBufferRead(&target, 1, 1, &buf); universe@793: CX_TEST_ASSERT(read == 0); universe@793: CX_TEST_ASSERT(buf.pos == 9); universe@793: } universe@793: cxBufferDestroy(&buf); universe@793: } universe@793: universe@789: CxTestSuite *cx_test_suite_buffer(void) { universe@789: CxTestSuite *suite = cx_test_suite_new("buffer"); universe@789: universe@789: cx_test_register(suite, test_buffer_init_wrap_space); universe@789: cx_test_register(suite, test_buffer_init_wrap_space_auto_extend); universe@789: cx_test_register(suite, test_buffer_init_wrap_space_auto_free); universe@789: cx_test_register(suite, test_buffer_init_fresh_space); universe@789: cx_test_register(suite, test_buffer_init_on_heap); universe@789: cx_test_register(suite, test_buffer_minimum_capacity_sufficient); universe@789: cx_test_register(suite, test_buffer_minimum_capacity_extend); universe@789: cx_test_register(suite, test_buffer_clear); universe@789: cx_test_register(suite, test_buffer_reset); universe@789: cx_test_register(suite, test_buffer_seek_set_zero); universe@789: cx_test_register(suite, test_buffer_seek_set_valid); universe@789: cx_test_register(suite, test_buffer_seek_set_invalid); universe@789: cx_test_register(suite, test_buffer_seek_cur_zero); universe@789: cx_test_register(suite, test_buffer_seek_cur_valid_positive); universe@789: cx_test_register(suite, test_buffer_seek_cur_valid_negative); universe@789: cx_test_register(suite, test_buffer_seek_cur_invalid_positive); universe@789: cx_test_register(suite, test_buffer_seek_cur_invalid_negative); universe@789: cx_test_register(suite, test_buffer_seek_end_zero); universe@789: cx_test_register(suite, test_buffer_seek_end_valid); universe@789: cx_test_register(suite, test_buffer_seek_end_invalid); universe@789: cx_test_register(suite, test_buffer_seek_whence_invalid); universe@792: cx_test_register(suite, test_buffer_eof_reached); universe@792: cx_test_register(suite, test_buffer_eof_not_reached); universe@792: cx_test_register(suite, test_buffer_shift_left_zero); universe@792: cx_test_register(suite, test_buffer_shift_left_zero_offset_interface); universe@792: cx_test_register(suite, test_buffer_shift_left_standard); universe@792: cx_test_register(suite, test_buffer_shift_left_overshift); universe@792: cx_test_register(suite, test_buffer_shift_left_overshift_pos_only); universe@792: cx_test_register(suite, test_buffer_shift_left_offset_interface); universe@792: cx_test_register(suite, test_buffer_shift_right_zero); universe@792: cx_test_register(suite, test_buffer_shift_right_zero_offset_interface); universe@792: cx_test_register(suite, test_buffer_shift_right_standard); universe@792: cx_test_register(suite, test_buffer_shift_right_overshift_discard); universe@792: cx_test_register(suite, test_buffer_shift_right_overshift_extend); universe@792: cx_test_register(suite, test_buffer_shift_right_offset_interface); universe@793: cx_test_register(suite, test_buffer_write_size_one_fit); universe@793: cx_test_register(suite, test_buffer_write_size_one_discard); universe@793: cx_test_register(suite, test_buffer_write_size_one_extend); universe@793: cx_test_register(suite, test_buffer_write_multibyte_fit); universe@793: cx_test_register(suite, test_buffer_write_multibyte_discard); universe@793: cx_test_register(suite, test_buffer_write_multibyte_extend); universe@793: cx_test_register(suite, test_buffer_put_fit); universe@793: cx_test_register(suite, test_buffer_put_discard); universe@793: cx_test_register(suite, test_buffer_put_extend); universe@793: cx_test_register(suite, test_buffer_put_string_fit); universe@793: cx_test_register(suite, test_buffer_put_string_discard); universe@793: cx_test_register(suite, test_buffer_put_string_extend); universe@793: cx_test_register(suite, test_buffer_write_size_overflow); universe@793: cx_test_register(suite, test_buffer_write_capacity_overflow); universe@793: cx_test_register(suite, test_buffer_write_only_overwrite); universe@793: cx_test_register(suite, test_buffer_write_flush_at_capacity); universe@793: cx_test_register(suite, test_buffer_write_flush_at_threshold); universe@793: cx_test_register(suite, test_buffer_write_flush_rate_limited); universe@793: cx_test_register(suite, test_buffer_get); universe@793: cx_test_register(suite, test_buffer_get_eof); universe@793: cx_test_register(suite, test_buffer_read); universe@793: cx_test_register(suite, test_buffer_read_oob); universe@793: cx_test_register(suite, test_buffer_read_oob_multibyte); universe@793: cx_test_register(suite, test_buffer_read_eof); universe@793: universe@789: return suite; universe@789: }