/** * @file preallocated_buffer.h * * @section LICENSE * * The MIT License * * @copyright Copyright (c) 2017-2020 TileDB, Inc. * * Permission is hereby granted, free of charge, to any person obtaining a copy * of this software and associated documentation files (the "Software"), to deal * in the Software without restriction, including without limitation the rights * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell * copies of the Software, and to permit persons to whom the Software is * furnished to do so, subject to the following conditions: * * The above copyright notice and this permission notice shall be included in * all copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN * THE SOFTWARE. * * @section DESCRIPTION * * This file defines class PreallocatedBuffer. */ #ifndef TILEDB_PREALLOCATED_BUFFER_H #define TILEDB_PREALLOCATED_BUFFER_H #include #include "tiledb/common/status.h" using namespace tiledb::common; namespace tiledb { namespace sm { /** * Convenience class wrapping a pre-allocated memory region in a class that * tracks an offset when reading and writing to the region. */ class PreallocatedBuffer { public: /* ********************************* */ /* CONSTRUCTORS & DESTRUCTORS */ /* ********************************* */ /** * Constructor. * * @param data The data of the buffer. * @param size The size of the buffer. */ PreallocatedBuffer(const void* data, const uint64_t size); /* ********************************* */ /* API */ /* ********************************* */ /** Advances the offset by *nbytes*. */ void advance_offset(const uint64_t nbytes); /** Returns the buffer data pointer at the current offset. */ void* cur_data() const; /** Returns the buffer data. */ const void* data() const; /** Returns the "free space" in the buffer, which is the size minus the * current offset. */ uint64_t free_space() const; /** Returns the buffer offset. */ uint64_t offset() const; /** * Reads from the internal buffer into the input buffer. * * @param buffer The buffer to write to when reading from the local buffer. * @param nbytes The number of bytes to read. * @return Status. */ Status read(void* buffer, const uint64_t nbytes); /** Returns the size of the buffer. */ uint64_t size() const; /** * Returns a value from the buffer of type T. * * @tparam T The type of the value to be read. * @param offset The offset in the local buffer to read from. * @return The desired value of type T. */ template inline T value(const uint64_t offset) const { return ((const T*)(((const char*)data_) + offset))[0]; } /** * Returns the value at the current offset of the buffer of type T. * * @tparam T The type of the value to be returned. * @return The value to be returned of type T. */ template inline T value() const { return ((const T*)(((const char*)data_) + offset_))[0]; } /** * Writes exactly *nbytes* into the local buffer by reading from the * input buffer *buf*. * * @param buffer The buffer to read from. * @param nbytes Number of bytes to write. * @return Status. */ Status write(const void* buffer, const uint64_t nbytes); private: /* ********************************* */ /* PRIVATE ATTRIBUTES */ /* ********************************* */ /** The (read-only) buffer data. */ const void* data_; /** The current offset in the buffer to read from. */ uint64_t offset_; /** The size of the buffer. */ uint64_t size_; }; } // namespace sm } // namespace tiledb #endif // TILEDB_PREALLOCATED_BUFFER_H