diff options
Diffstat (limited to 'vbench/src/vbench/core/simple_buffer.cpp')
-rw-r--r-- | vbench/src/vbench/core/simple_buffer.cpp | 78 |
1 files changed, 78 insertions, 0 deletions
diff --git a/vbench/src/vbench/core/simple_buffer.cpp b/vbench/src/vbench/core/simple_buffer.cpp new file mode 100644 index 00000000000..1e1d0a8e4ae --- /dev/null +++ b/vbench/src/vbench/core/simple_buffer.cpp @@ -0,0 +1,78 @@ +// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. + +#include <vespa/fastos/fastos.h> +#include "simple_buffer.h" + +namespace vbench { + +SimpleBuffer::SimpleBuffer() + : _data(), + _used(0) +{ +} + +Memory +SimpleBuffer::obtain(size_t bytes, size_t) +{ + return Memory(&_data[0], std::min(bytes, _used)); +} + +Input & +SimpleBuffer::evict(size_t bytes) +{ + assert(bytes <= _used); + _data.erase(_data.begin(), _data.begin() + bytes); + _used -= bytes; + return *this; +} + +WritableMemory +SimpleBuffer::reserve(size_t bytes) +{ + _data.resize(_used + bytes, char(0x55)); + return WritableMemory(&_data[_used], bytes); +} + +Output & +SimpleBuffer::commit(size_t bytes, size_t) +{ + assert(bytes <= (_data.size() - _used)); + _used += bytes; + return *this; +} + +bool +SimpleBuffer::operator==(const SimpleBuffer &rhs) const +{ + Memory a = get(); + Memory b = rhs.get(); + if (a.size != b.size) { + return false; + } + for (size_t i = 0; i < a.size; ++i) { + if (a.data[i] != b.data[i]) { + return false; + } + } + return true; +} + +std::ostream &operator<<(std::ostream &os, const SimpleBuffer &buf) { + Memory memory = buf.get(); + uint32_t written = 0; + uint32_t hexCount = 25; + os << "size: " << memory.size << "(bytes)" << std::endl; + for (size_t i = 0; i < memory.size; ++i, ++written) { + if (written > hexCount) { + os << std::endl; + written = 0; + } + os << strfmt("0x%02x ", memory.data[i] & 0xff); + } + if (written > 0) { + os << std::endl; + } + return os; +} + +} // namespace vbench |