1 #ifndef OSMIUM_MEMORY_BUFFER_HPP
2 #define OSMIUM_MEMORY_BUFFER_HPP
60 std::runtime_error(
"Osmium buffer is full") {
145 throw std::invalid_argument(
"buffer size needs to be multiple of alignment");
161 m_capacity(capacity),
162 m_written(committed),
163 m_committed(committed) {
165 throw std::invalid_argument(
"buffer capacity needs to be multiple of alignment");
168 throw std::invalid_argument(
"buffer parameter 'committed' needs to be multiple of alignment");
180 m_data(m_memory.
data()),
181 m_capacity(capacity),
186 throw std::invalid_argument(
"buffer capacity needs to be multiple of alignment");
203 unsigned char*
data() const noexcept {
254 if (m_memory.empty()) {
255 throw std::logic_error(
"Can't grow Buffer if it doesn't use internal memory management.");
257 if (m_capacity < size) {
259 throw std::invalid_argument(
"buffer capacity needs to be multiple of alignment");
261 m_memory.resize(size);
262 m_data = m_memory.data();
306 T&
get(
const size_t offset)
const {
307 return *
reinterpret_cast<T*
>(&m_data[offset]);
336 if (m_written + size > m_capacity) {
341 size_t new_capacity = m_capacity * 2;
342 while (m_written + size > new_capacity) {
369 std::copy_n(reinterpret_cast<const unsigned char*>(&item), item.padded_size(), target);
370 return *
reinterpret_cast<T*
>(target);
381 std::copy_n(reinterpret_cast<const unsigned char*>(buffer.
data()), buffer.
committed(), target);
412 return iterator(m_data, m_data + m_committed);
421 return iterator(m_data + offset, m_data + m_committed);
430 return iterator(m_data + m_committed, m_data + m_committed);
457 return const_iterator(m_data + m_committed, m_data + m_committed);
474 const_iterator
end()
const {
481 explicit operator bool()
const {
482 return m_data !=
nullptr;
509 template <
class TCallbackClass>
515 iterator it_write =
begin();
518 for (iterator it_read =
begin(); it_read !=
end(); it_read = next) {
519 next = std::next(it_read);
520 if (!it_read->removed()) {
521 if (it_read != it_write) {
522 assert(it_read.data() >=
data());
524 size_t old_offset =
static_cast<size_t>(it_read.data() -
data());
525 size_t new_offset =
static_cast<size_t>(it_write.
data() -
data());
526 callback->moving_in_buffer(old_offset, new_offset);
527 std::memmove(it_write.
data(), it_read.data(), it_read->padded_size());
534 m_written =
static_cast<size_t>(it_write.
data() -
data());
541 return lhs.data() == rhs.data() && lhs.capacity() == rhs.capacity() && lhs.committed() == rhs.committed();
545 return ! (lhs == rhs);
552 #endif // OSMIUM_MEMORY_BUFFER_HPP
size_t m_written
Definition: buffer.hpp:108
Item value_type
Definition: buffer.hpp:115
t_const_iterator< T > cend() const
Definition: buffer.hpp:452
const_iterator begin() const
Definition: buffer.hpp:465
size_t clear()
Definition: buffer.hpp:292
bool is_aligned() const noexcept
Definition: buffer.hpp:233
size_t written() const noexcept
Definition: buffer.hpp:225
iterator get_iterator(size_t offset)
Definition: buffer.hpp:420
bool operator!=(const Buffer &lhs, const Buffer &rhs) noexcept
Definition: buffer.hpp:544
void grow(size_t size)
Definition: buffer.hpp:253
const_iterator end() const
Definition: buffer.hpp:474
Definition: item_iterator.hpp:131
unsigned char * m_data
Definition: buffer.hpp:106
t_const_iterator< osmium::OSMEntity > const_iterator
Definition: buffer.hpp:404
constexpr item_size_type align_bytes
Definition: item.hpp:53
Buffer(unsigned char *data, size_t capacity, size_t committed)
Definition: buffer.hpp:158
Definition: reader_iterator.hpp:39
ItemIterator< TMember > & advance_once()
Definition: item_iterator.hpp:180
Buffer(size_t capacity, auto_grow auto_grow=auto_grow::yes)
Definition: buffer.hpp:178
unsigned char * data() const
Definition: item_iterator.hpp:201
bool operator==(const Buffer &lhs, const Buffer &rhs) noexcept
Definition: buffer.hpp:540
t_iterator< T > end()
Definition: buffer.hpp:425
Namespace for everything in the Osmium library.
Definition: assembler.hpp:55
T & add_item(const T &item)
Definition: buffer.hpp:367
void purge_removed(TCallbackClass *callback)
Definition: buffer.hpp:510
t_iterator< T > begin()
Definition: buffer.hpp:407
void add_buffer(const Buffer &buffer)
Definition: buffer.hpp:379
friend void swap(Buffer &lhs, Buffer &rhs)
Definition: buffer.hpp:485
const_iterator cbegin() const
Definition: buffer.hpp:438
size_t m_committed
Definition: buffer.hpp:109
unsigned char * data() const noexcept
Definition: buffer.hpp:203
Buffer() noexcept
Definition: buffer.hpp:122
size_t capacity() const noexcept
Definition: buffer.hpp:210
unsigned char * reserve_space(const size_t size)
Definition: buffer.hpp:335
auto_grow m_auto_grow
Definition: buffer.hpp:110
void push_back(const osmium::memory::Item &item)
Definition: buffer.hpp:388
iterator end()
Definition: buffer.hpp:429
iterator begin()
Definition: buffer.hpp:411
const_iterator cend() const
Definition: buffer.hpp:456
size_t m_capacity
Definition: buffer.hpp:107
t_const_iterator< T > get_iterator(size_t offset) const
Definition: buffer.hpp:443
size_t committed() const noexcept
Definition: buffer.hpp:217
Buffer(unsigned char *data, size_t size)
Definition: buffer.hpp:138
t_iterator< osmium::OSMEntity > iterator
Definition: buffer.hpp:403
t_const_iterator< T > end() const
Definition: buffer.hpp:470
Definition: buffer.hpp:94
Definition: buffer.hpp:57
const_iterator get_iterator(size_t offset) const
Definition: buffer.hpp:447
t_const_iterator< T > cbegin() const
Definition: buffer.hpp:434
t_const_iterator< T > begin() const
Definition: buffer.hpp:461
auto_grow
Definition: buffer.hpp:98
std::vector< unsigned char > m_memory
Definition: buffer.hpp:105
buffer_is_full()
Definition: buffer.hpp:59
void rollback()
Definition: buffer.hpp:283
t_iterator< T > get_iterator(size_t offset)
Definition: buffer.hpp:416
void set_full_callback(std::function< void(Buffer &)> full)
Definition: buffer.hpp:241
std::function< void(Buffer &)> m_full
Definition: buffer.hpp:111
Buffer & operator=(const Buffer &)=delete
size_t commit()
Definition: buffer.hpp:272