universe@530: /* universe@530: * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. universe@530: * universe@530: * Copyright 2021 Mike Becker, Olaf Wintermann All rights reserved. universe@530: * universe@530: * Redistribution and use in source and binary forms, with or without universe@530: * modification, are permitted provided that the following conditions are met: universe@530: * universe@530: * 1. Redistributions of source code must retain the above copyright universe@530: * notice, this list of conditions and the following disclaimer. universe@530: * universe@530: * 2. Redistributions in binary form must reproduce the above copyright universe@530: * notice, this list of conditions and the following disclaimer in the universe@530: * documentation and/or other materials provided with the distribution. universe@530: * universe@530: * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" universe@530: * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE universe@530: * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE universe@530: * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE universe@530: * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR universe@530: * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF universe@530: * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS universe@530: * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN universe@530: * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) universe@530: * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE universe@530: * POSSIBILITY OF SUCH DAMAGE. universe@530: */ universe@530: universe@530: #include "cx/buffer.h" universe@530: universe@530: #include universe@530: #include "util_allocator.h" universe@530: universe@548: class BufferFixture : public ::testing::Test { universe@548: protected: universe@548: void SetUp() override { universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@548: buf.size = 6; universe@548: buf.pos = 3; universe@548: } universe@548: universe@548: void TearDown() override { universe@548: cxBufferDestroy(&buf); universe@548: } universe@548: universe@548: CxBuffer buf{}; universe@548: }; universe@548: universe@535: class BufferShiftFixture : public ::testing::Test { universe@535: protected: universe@535: void SetUp() override { universe@789: CX_TEST_ASSERT(cx_testing_allocator_verify(&talloc)); universe@789: cxBufferInit(&buf, NULL, 16, &alloc, CX_BUFFER_DEFAULT); universe@535: memcpy(buf.space, "test____________", 16); universe@535: buf.capacity = 8; // purposely pretend that the buffer has less capacity s.t. we can test beyond the range universe@535: buf.pos = 4; universe@535: buf.size = 4; universe@535: } universe@535: universe@535: void TearDown() override { universe@535: cxBufferDestroy(&buf); universe@789: CX_TEST_ASSERT(cx_testing_allocator_verify(&talloc)); universe@535: } universe@535: universe@535: CxTestingAllocator alloc; universe@535: CxBuffer buf{}; universe@535: }; universe@535: universe@535: class BufferShiftLeft : public BufferShiftFixture { universe@535: }; universe@535: universe@535: TEST_F(BufferShiftLeft, Zero) { universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@535: int ret = cxBufferShiftLeft(&buf, 0); universe@789: CX_TEST_ASSERT(ret == 0); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@789: CX_TEST_ASSERT(memcmp(buf.space, "test________", 8) == 0); universe@535: } universe@535: universe@547: TEST_F(BufferShiftLeft, ZeroOffsetInterface) { universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@547: int ret = cxBufferShift(&buf, -0); universe@789: CX_TEST_ASSERT(ret == 0); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@789: CX_TEST_ASSERT(memcmp(buf.space, "test________", 8) == 0); universe@547: } universe@547: universe@535: TEST_F(BufferShiftLeft, Standard) { universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@535: int ret = cxBufferShiftLeft(&buf, 2); universe@789: CX_TEST_ASSERT(ret == 0); universe@789: CX_TEST_ASSERT(buf.pos == 2); universe@789: CX_TEST_ASSERT(buf.size == 2); universe@789: CX_TEST_ASSERT(memcmp(buf.space, "stst________", 8) == 0); universe@535: } universe@535: universe@535: TEST_F(BufferShiftLeft, Overshift) { universe@535: ASSERT_LT(buf.pos, 6); universe@535: ASSERT_LT(buf.size, 6); universe@535: int ret = cxBufferShiftLeft(&buf, 6); universe@789: CX_TEST_ASSERT(ret == 0); universe@789: CX_TEST_ASSERT(buf.pos == 0); universe@789: CX_TEST_ASSERT(buf.size == 0); universe@789: CX_TEST_ASSERT(memcmp(buf.space, "test________", 8) == 0); universe@535: } universe@535: universe@535: TEST_F(BufferShiftLeft, OvershiftPosOnly) { universe@535: buf.pos = 2; universe@789: CX_TEST_ASSERT(buf.size == 4); universe@535: int ret = cxBufferShiftLeft(&buf, 3); universe@789: CX_TEST_ASSERT(ret == 0); universe@789: CX_TEST_ASSERT(buf.pos == 0); universe@789: CX_TEST_ASSERT(buf.size == 1); universe@789: CX_TEST_ASSERT(memcmp(buf.space, "test________", 8) == 0); universe@535: } universe@535: universe@535: TEST_F(BufferShiftLeft, OffsetInterface) { universe@535: buf.pos = 3; universe@789: CX_TEST_ASSERT(buf.size == 4); universe@535: int ret = cxBufferShift(&buf, -2); universe@789: CX_TEST_ASSERT(ret == 0); universe@789: CX_TEST_ASSERT(buf.pos == 1); universe@789: CX_TEST_ASSERT(buf.size == 2); universe@789: CX_TEST_ASSERT(memcmp(buf.space, "stst________", 8) == 0); universe@535: } universe@535: universe@535: TEST_F(BufferShiftRight, Zero) { universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@535: int ret = cxBufferShiftRight(&buf, 0); universe@789: CX_TEST_ASSERT(ret == 0); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@789: CX_TEST_ASSERT(memcmp(buf.space, "test________", 8) == 0); universe@535: } universe@535: universe@547: TEST_F(BufferShiftRight, ZeroOffsetInterface) { universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@547: int ret = cxBufferShift(&buf, +0); universe@789: CX_TEST_ASSERT(ret == 0); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@789: CX_TEST_ASSERT(memcmp(buf.space, "test________", 8) == 0); universe@547: } universe@547: universe@535: TEST_F(BufferShiftRight, Standard) { universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@535: int ret = cxBufferShiftRight(&buf, 3); universe@789: CX_TEST_ASSERT(ret == 0); universe@789: CX_TEST_ASSERT(buf.pos == 7); universe@789: CX_TEST_ASSERT(buf.size == 7); universe@789: CX_TEST_ASSERT(memcmp(buf.space, "testest_____", 8) == 0); universe@535: } universe@535: universe@535: TEST_F(BufferShiftRight, OvershiftDiscard) { universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@535: int ret = cxBufferShiftRight(&buf, 6); universe@789: CX_TEST_ASSERT(ret == 0); universe@789: CX_TEST_ASSERT(buf.pos == 8); universe@789: CX_TEST_ASSERT(buf.size == 8); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(memcmp(buf.space, "test__te____", 8) == 0); universe@535: } universe@535: universe@535: TEST_F(BufferShiftRight, OvershiftExtend) { universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@535: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@535: int ret = cxBufferShiftRight(&buf, 6); universe@789: CX_TEST_ASSERT(ret == 0); universe@789: CX_TEST_ASSERT(buf.pos == 10); universe@789: CX_TEST_ASSERT(buf.size == 10); universe@535: EXPECT_GE(buf.capacity, 10); universe@789: CX_TEST_ASSERT(memcmp(buf.space, "test__test__", 8) == 0); universe@535: } universe@535: universe@535: TEST_F(BufferShiftRight, OffsetInterface) { universe@535: buf.pos = 3; universe@789: CX_TEST_ASSERT(buf.size == 4); universe@535: int ret = cxBufferShift(&buf, 2); universe@789: CX_TEST_ASSERT(ret == 0); universe@789: CX_TEST_ASSERT(buf.pos == 5); universe@789: CX_TEST_ASSERT(buf.size == 6); universe@789: CX_TEST_ASSERT(memcmp(buf.space, "tetest______", 8) == 0); universe@761: } universe@761: universe@538: class BufferWrite : public ::testing::Test { universe@538: protected: universe@545: CxBuffer buf{}, target{}; universe@538: universe@538: void SetUp() override { universe@789: cxBufferInit(&target, NULL, 16, cxDefaultAllocator, CX_BUFFER_AUTO_EXTEND); universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@538: buf.capacity = 8; // artificially reduce capacity to check OOB writes universe@538: memset(buf.space, 0, 16); universe@538: memcpy(buf.space, "prep", 4); universe@538: buf.size = buf.pos = 4; universe@538: } universe@538: universe@538: void TearDown() override { universe@538: cxBufferDestroy(&buf); universe@545: cxBufferDestroy(&target); universe@545: } universe@545: universe@545: void enableFlushing() { universe@545: buf.flush_target = ⌖ universe@545: buf.flush_func = reinterpret_cast(cxBufferWrite); universe@545: buf.flush_blkmax = 1; universe@538: } universe@538: }; universe@538: universe@567: static size_t mock_write_limited_rate( universe@567: void const *ptr, universe@567: size_t size, universe@567: __attribute__((unused)) size_t nitems, universe@567: CxBuffer *buffer universe@567: ) { universe@567: // simulate limited target drain capacity universe@567: static bool full = false; universe@567: if (full) { universe@567: full = false; universe@567: return 0; universe@567: } else { universe@567: full = true; universe@567: return cxBufferWrite(ptr, size, nitems > 2 ? 2 : nitems, buffer); universe@567: } universe@567: } universe@567: universe@538: TEST_F(BufferWrite, SizeOneFit) { universe@538: const char *data = "test"; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@538: size_t written = cxBufferWrite(data, 1, 4, &buf); universe@789: CX_TEST_ASSERT(written == 4); universe@789: CX_TEST_ASSERT(buf.size == 8); universe@789: CX_TEST_ASSERT(buf.pos == 8); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@538: EXPECT_EQ(memcmp(buf.space, "preptest", 8), 0); universe@538: } universe@538: universe@538: TEST_F(BufferWrite, SizeOneDiscard) { universe@538: const char *data = "testing"; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@538: size_t written = cxBufferWrite(data, 1, 7, &buf); universe@789: CX_TEST_ASSERT(written == 4); universe@789: CX_TEST_ASSERT(buf.size == 8); universe@789: CX_TEST_ASSERT(buf.pos == 8); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@538: EXPECT_EQ(memcmp(buf.space, "preptest\0", 9), 0); universe@538: } universe@538: universe@538: TEST_F(BufferWrite, SizeOneExtend) { universe@538: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@538: const char *data = "testing"; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@538: size_t written = cxBufferWrite(data, 1, 7, &buf); universe@789: CX_TEST_ASSERT(written == 7); universe@789: CX_TEST_ASSERT(buf.size == 11); universe@789: CX_TEST_ASSERT(buf.pos == 11); universe@538: EXPECT_GE(buf.capacity, 11); universe@538: EXPECT_EQ(memcmp(buf.space, "preptesting", 11), 0); universe@538: } universe@538: universe@538: TEST_F(BufferWrite, MultibyteFit) { universe@541: const char *data = "test"; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@541: size_t written = cxBufferWrite(data, 2, 2, &buf); universe@789: CX_TEST_ASSERT(written == 2); universe@789: CX_TEST_ASSERT(buf.size == 8); universe@789: CX_TEST_ASSERT(buf.pos == 8); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@541: EXPECT_EQ(memcmp(buf.space, "preptest", 8), 0); universe@538: } universe@538: universe@538: TEST_F(BufferWrite, MultibyteDiscard) { universe@542: const char *data = "testing"; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@541: buf.pos = 3; universe@542: size_t written = cxBufferWrite(data, 2, 4, &buf); universe@538: // remember: whole elements are discarded if they do not fit universe@789: CX_TEST_ASSERT(written == 2); universe@789: CX_TEST_ASSERT(buf.size == 7); universe@789: CX_TEST_ASSERT(buf.pos == 7); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@541: EXPECT_EQ(memcmp(buf.space, "pretest\0", 8), 0); universe@538: } universe@538: universe@538: TEST_F(BufferWrite, MultibyteExtend) { universe@541: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@541: const char *data = "tester"; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@541: buf.pos = 3; universe@541: size_t written = cxBufferWrite(data, 2, 3, &buf); universe@541: // remember: whole elements are discarded if they do not fit universe@789: CX_TEST_ASSERT(written == 3); universe@789: CX_TEST_ASSERT(buf.size == 9); universe@789: CX_TEST_ASSERT(buf.pos == 9); universe@541: EXPECT_GE(buf.capacity, 9); universe@566: EXPECT_EQ(memcmp(buf.space, "pretester", 9), 0); universe@538: } universe@538: universe@538: TEST_F(BufferWrite, PutcWrapperFit) { universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@565: int c = cxBufferPut(&buf, 0x200 | 'a'); universe@789: CX_TEST_ASSERT(c == 'a'); universe@789: CX_TEST_ASSERT(buf.size == 5); universe@789: CX_TEST_ASSERT(buf.pos == 5); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@541: EXPECT_EQ(memcmp(buf.space, "prepa\0", 6), 0); universe@538: } universe@538: universe@538: TEST_F(BufferWrite, PutcWrapperDiscard) { universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@541: buf.pos = 8; universe@565: int c = cxBufferPut(&buf, 0x200 | 'a'); universe@789: CX_TEST_ASSERT(c == EOF); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@789: CX_TEST_ASSERT(buf.pos == 8); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@541: EXPECT_EQ(memcmp(buf.space, "prep\0\0\0\0\0", 9), 0); universe@538: } universe@538: universe@538: TEST_F(BufferWrite, PutcWrapperExtend) { universe@541: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@541: buf.pos = 8; universe@565: int c = cxBufferPut(&buf, 0x200 | 'a'); universe@789: CX_TEST_ASSERT(c == 'a'); universe@789: CX_TEST_ASSERT(buf.size == 9); universe@789: CX_TEST_ASSERT(buf.pos == 9); universe@541: EXPECT_GE(buf.capacity, 9); universe@566: EXPECT_EQ(memcmp(buf.space, "prep\0\0\0\0a", 9), 0); universe@538: } universe@538: universe@538: TEST_F(BufferWrite, PutStringWrapperFit) { universe@541: const char *data = "test"; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@541: size_t written = cxBufferPutString(&buf, data); universe@789: CX_TEST_ASSERT(written == 4); universe@789: CX_TEST_ASSERT(buf.size == 8); universe@789: CX_TEST_ASSERT(buf.pos == 8); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@541: EXPECT_EQ(memcmp(buf.space, "preptest", 8), 0); universe@538: } universe@538: universe@538: TEST_F(BufferWrite, PutStringWrapperDiscard) { universe@541: const char *data = "testing"; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@541: size_t written = cxBufferPutString(&buf, data); universe@789: CX_TEST_ASSERT(written == 4); universe@789: CX_TEST_ASSERT(buf.size == 8); universe@789: CX_TEST_ASSERT(buf.pos == 8); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@541: EXPECT_EQ(memcmp(buf.space, "preptest\0", 9), 0); universe@538: } universe@538: universe@538: TEST_F(BufferWrite, PutStringWrapperExtend) { universe@541: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@541: const char *data = "testing"; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@541: size_t written = cxBufferPutString(&buf, data); universe@789: CX_TEST_ASSERT(written == 7); universe@789: CX_TEST_ASSERT(buf.size == 11); universe@789: CX_TEST_ASSERT(buf.pos == 11); universe@541: EXPECT_GE(buf.capacity, 11); universe@541: EXPECT_EQ(memcmp(buf.space, "preptesting", 11), 0); universe@541: } universe@538: universe@541: TEST_F(BufferWrite, MultOverflow) { universe@541: const char *data = "testing"; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@541: size_t written = cxBufferWrite(data, 8, SIZE_MAX / 4, &buf); universe@789: CX_TEST_ASSERT(written == 0); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@541: EXPECT_EQ(memcmp(buf.space, "prep\0", 5), 0); universe@538: } universe@541: universe@541: TEST_F(BufferWrite, MaxCapaOverflow) { universe@541: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@541: const char *data = "testing"; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@541: size_t written = cxBufferWrite(data, 1, SIZE_MAX - 2, &buf); universe@789: CX_TEST_ASSERT(written == 0); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@789: CX_TEST_ASSERT(buf.size == 4); universe@541: EXPECT_EQ(memcmp(buf.space, "prep\0", 5), 0); universe@541: } universe@541: universe@541: TEST_F(BufferWrite, OnlyOverwrite) { universe@541: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@541: memcpy(buf.space, "preptest", 8); universe@541: buf.pos = 3; universe@541: buf.size = 8; universe@541: size_t written = cxBufferWrite("XXX", 2, 2, &buf); universe@789: CX_TEST_ASSERT(written == 2); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.size == 8); universe@789: CX_TEST_ASSERT(buf.pos == 7); universe@541: EXPECT_EQ(memcmp(buf.space, "preXXX\0t", 8), 0); universe@541: } universe@545: universe@545: TEST_F(BufferWrite, FlushAtCapacity) { universe@545: enableFlushing(); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@545: size_t written = cxBufferWrite("foo", 1, 3, &buf); universe@789: CX_TEST_ASSERT(written == 3); universe@789: CX_TEST_ASSERT(buf.pos == 7); universe@789: CX_TEST_ASSERT(buf.size == 7); universe@789: CX_TEST_ASSERT(target.pos == 0); universe@789: CX_TEST_ASSERT(target.size == 0); universe@545: written = cxBufferWrite("hello", 1, 5, &buf); universe@789: CX_TEST_ASSERT(written == 5); 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(target.pos == 12); universe@789: CX_TEST_ASSERT(target.size == 12); universe@545: EXPECT_EQ(memcmp(target.space, "prepfoohello", 12), 0); universe@545: } universe@546: universe@546: TEST_F(BufferWrite, FlushAtThreshold) { universe@546: enableFlushing(); universe@546: buf.flush_threshold = 12; universe@546: buf.flags |= CX_BUFFER_AUTO_EXTEND; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@546: size_t written = cxBufferWrite("foobar", 1, 6, &buf); universe@789: CX_TEST_ASSERT(written == 6); universe@789: CX_TEST_ASSERT(buf.pos == 10); universe@789: CX_TEST_ASSERT(buf.size == 10); universe@546: ASSERT_GE(buf.capacity, 10); universe@546: ASSERT_LE(buf.capacity, 12); universe@789: CX_TEST_ASSERT(target.pos == 0); universe@789: CX_TEST_ASSERT(target.size == 0); universe@546: written = cxBufferWrite("hello", 1, 5, &buf); universe@789: CX_TEST_ASSERT(written == 5); universe@789: CX_TEST_ASSERT(buf.pos == 0); universe@789: CX_TEST_ASSERT(buf.size == 0); universe@546: EXPECT_LE(buf.capacity, 12); universe@789: CX_TEST_ASSERT(target.pos == 15); universe@789: CX_TEST_ASSERT(target.size == 15); universe@546: EXPECT_EQ(memcmp(target.space, "prepfoobarhello", 15), 0); universe@546: } universe@547: universe@567: TEST_F(BufferWrite, FlushRateLimited) { universe@567: enableFlushing(); universe@567: // limit the rate of the flush function and the capacity of the target universe@567: target.capacity = 16; universe@567: target.flags &= ~CX_BUFFER_AUTO_EXTEND; universe@567: buf.flush_func = (cx_write_func) mock_write_limited_rate; universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@789: CX_TEST_ASSERT(buf.pos == 4); universe@567: size_t written = cxBufferWrite("foo", 1, 3, &buf); universe@789: CX_TEST_ASSERT(written == 3); universe@789: CX_TEST_ASSERT(buf.pos == 7); universe@789: CX_TEST_ASSERT(buf.size == 7); universe@789: CX_TEST_ASSERT(target.pos == 0); universe@789: CX_TEST_ASSERT(target.size == 0); universe@567: written = cxBufferWrite("hello, world!", 1, 13, &buf); universe@567: // " world!" fits into this buffer, the remaining stuff is flushed out universe@789: CX_TEST_ASSERT(written == 13); universe@789: CX_TEST_ASSERT(buf.pos == 7); universe@789: CX_TEST_ASSERT(buf.size == 7); universe@789: CX_TEST_ASSERT(buf.capacity == 8); universe@567: EXPECT_EQ(memcmp(buf.space, " world!", 7), 0); universe@789: CX_TEST_ASSERT(target.pos == 13); universe@789: CX_TEST_ASSERT(target.size == 13); universe@789: CX_TEST_ASSERT(target.capacity == 16); universe@567: EXPECT_EQ(memcmp(target.space, "prepfoohello,", 13), 0); universe@567: } universe@567: universe@548: universe@548: TEST_F(BufferEof, Reached) { universe@548: buf.pos = buf.size; universe@789: CX_TEST_ASSERT(cxBufferEof(&buf)); universe@548: buf.pos = buf.size - 1; universe@789: CX_TEST_ASSERT(!cxBufferEof(&buf)); universe@548: cxBufferPut(&buf, 'a'); universe@789: CX_TEST_ASSERT(cxBufferEof(&buf)); universe@548: } universe@548: universe@548: TEST_F(BufferEof, NotReached) { universe@548: buf.pos = buf.size - 1; universe@789: CX_TEST_ASSERT(!cxBufferEof(&buf)); universe@548: buf.pos = 0; universe@548: cxBufferWrite("test", 1, 5, &buf); universe@789: CX_TEST_ASSERT(!cxBufferEof(&buf)); universe@548: } universe@568: universe@568: class BufferRead : public ::testing::Test { universe@568: protected: universe@568: CxBuffer buf{}; universe@568: universe@568: void SetUp() override { universe@789: cxBufferInit(&buf, NULL, 16, cxDefaultAllocator, CX_BUFFER_DEFAULT); universe@568: buf.capacity = 8; // artificially reduce capacity to check OOB writes universe@568: memset(buf.space, 0, 16); universe@568: memcpy(buf.space, "some data", 9); universe@568: buf.size = 9; universe@568: } universe@568: universe@568: void TearDown() override { universe@568: cxBufferDestroy(&buf); universe@568: } universe@568: }; universe@568: universe@568: TEST_F(BufferRead, GetByte) { universe@568: buf.pos = 2; universe@568: EXPECT_EQ(cxBufferGet(&buf), 'm'); universe@568: EXPECT_EQ(cxBufferGet(&buf), 'e'); universe@568: EXPECT_EQ(cxBufferGet(&buf), ' '); universe@568: EXPECT_EQ(cxBufferGet(&buf), 'd'); universe@789: CX_TEST_ASSERT(buf.pos == 6); universe@568: } universe@568: universe@568: TEST_F(BufferRead, GetEof) { universe@568: buf.pos = buf.size; universe@568: EXPECT_EQ(cxBufferGet(&buf), EOF); universe@568: } universe@569: universe@569: TEST_F(BufferRead, ReadWithinBounds) { universe@569: buf.pos = 2; universe@569: char target[4]; universe@569: auto read = cxBufferRead(&target, 1, 4, &buf); universe@789: CX_TEST_ASSERT(read == 4); universe@569: EXPECT_EQ(memcmp(&target, "me d", 4), 0); universe@789: CX_TEST_ASSERT(buf.pos == 6); universe@569: } universe@569: universe@569: TEST_F(BufferRead, ReadOutOfBounds) { universe@569: buf.pos = 6; universe@569: char target[4]; universe@569: auto read = cxBufferRead(&target, 1, 4, &buf); universe@789: CX_TEST_ASSERT(read == 3); universe@569: EXPECT_EQ(memcmp(&target, "ata", 3), 0); universe@789: CX_TEST_ASSERT(buf.pos == 9); universe@569: } universe@569: universe@569: TEST_F(BufferRead, ReadOutOfBoundsMultibyte) { universe@569: buf.pos = 6; universe@569: char target[4]; universe@569: target[2] = '\0'; universe@569: auto read = cxBufferRead(&target, 2, 2, &buf); universe@789: CX_TEST_ASSERT(read == 1); universe@569: EXPECT_EQ(memcmp(&target, "at\0", 3), 0); universe@789: CX_TEST_ASSERT(buf.pos == 8); universe@569: } universe@569: universe@569: TEST_F(BufferRead, ReadEof) { universe@569: buf.pos = 9; universe@569: char target[4]; universe@569: auto read = cxBufferRead(&target, 1, 1, &buf); universe@789: CX_TEST_ASSERT(read == 0); universe@789: CX_TEST_ASSERT(buf.pos == 9); universe@569: }