Refactor ShMemIterator, resolves #3458

This commit is contained in:
Michael Krasnyk 2017-01-18 20:40:38 +01:00 committed by Daniel J. H
parent 6b06c5bd32
commit c03b230e84

View File

@ -1,10 +1,13 @@
#ifndef SHARED_MEMORY_VECTOR_WRAPPER_HPP #ifndef SHARED_MEMORY_VECTOR_WRAPPER_HPP
#define SHARED_MEMORY_VECTOR_WRAPPER_HPP #define SHARED_MEMORY_VECTOR_WRAPPER_HPP
#include <boost/assert.hpp>
#include "util/log.hpp" #include "util/log.hpp"
#include <boost/assert.hpp>
#include <boost/iterator/iterator_facade.hpp>
#include <boost/iterator/reverse_iterator.hpp>
#include <climits>
#include <cstddef> #include <cstddef>
#include <algorithm> #include <algorithm>
@ -18,61 +21,34 @@ namespace osrm
namespace util namespace util
{ {
template <typename DataT> class ShMemIterator : public std::iterator<std::input_iterator_tag, DataT>
{
DataT *p;
public:
explicit ShMemIterator(DataT *x) : p(x) {}
ShMemIterator(const ShMemIterator &mit) : p(mit.p) {}
ShMemIterator &operator++()
{
++p;
return *this;
}
ShMemIterator operator++(int)
{
ShMemIterator tmp(*this);
operator++();
return tmp;
}
ShMemIterator operator+(std::ptrdiff_t diff)
{
ShMemIterator tmp(p + diff);
return tmp;
}
bool operator==(const ShMemIterator &rhs) { return p == rhs.p; }
bool operator!=(const ShMemIterator &rhs) { return p != rhs.p; }
DataT &operator*() { return *p; }
};
template <typename DataT> template <typename DataT>
class ShMemReverseIterator : public std::iterator<std::input_iterator_tag, DataT> class ShMemIterator
: public boost::iterator_facade<ShMemIterator<DataT>, DataT, boost::random_access_traversal_tag>
{ {
DataT *p; typedef boost::iterator_facade<ShMemIterator<DataT>, DataT, boost::random_access_traversal_tag>
base_t;
public: public:
explicit ShMemReverseIterator(DataT *x) : p(x) {} typedef typename base_t::value_type value_type;
ShMemReverseIterator(const ShMemReverseIterator &mit) : p(mit.p) {} typedef typename base_t::difference_type difference_type;
ShMemReverseIterator &operator++() typedef typename base_t::reference reference;
typedef std::random_access_iterator_tag iterator_category;
explicit ShMemIterator(DataT *x) : m_value(x) {}
private:
void increment() { ++m_value; }
void decrement() { --m_value; }
void advance(difference_type offset) { m_value += offset; }
bool equal(const ShMemIterator &other) const { return m_value == other.m_value; }
reference dereference() const { return *m_value; }
difference_type distance_to(const ShMemIterator &other) const
{ {
--p; return other.m_value - m_value;
return *this;
} }
ShMemReverseIterator operator++(int)
{ friend class ::boost::iterator_core_access;
ShMemReverseIterator tmp(*this); DataT *m_value;
operator++();
return tmp;
}
ShMemReverseIterator operator+(std::ptrdiff_t diff)
{
ShMemReverseIterator tmp(p - diff);
return tmp;
}
bool operator==(const ShMemReverseIterator &rhs) { return p == rhs.p; }
bool operator!=(const ShMemReverseIterator &rhs) { return p != rhs.p; }
DataT &operator*() { return *p; }
}; };
template <typename DataT> class SharedMemoryWrapper template <typename DataT> class SharedMemoryWrapper
@ -82,6 +58,9 @@ template <typename DataT> class SharedMemoryWrapper
std::size_t m_size; std::size_t m_size;
public: public:
using iterator = ShMemIterator<DataT>;
using reverse_iterator = boost::reverse_iterator<iterator>;
SharedMemoryWrapper() : m_ptr(nullptr), m_size(0) {} SharedMemoryWrapper() : m_ptr(nullptr), m_size(0) {}
SharedMemoryWrapper(DataT *ptr, std::size_t size) : m_ptr(ptr), m_size(size) {} SharedMemoryWrapper(DataT *ptr, std::size_t size) : m_ptr(ptr), m_size(size) {}
@ -96,16 +75,13 @@ template <typename DataT> class SharedMemoryWrapper
const DataT &at(const std::size_t index) const { return m_ptr[index]; } const DataT &at(const std::size_t index) const { return m_ptr[index]; }
ShMemIterator<DataT> begin() const { return ShMemIterator<DataT>(m_ptr); } auto begin() const { return iterator(m_ptr); }
ShMemIterator<DataT> end() const { return ShMemIterator<DataT>(m_ptr + m_size); } auto end() const { return iterator(m_ptr + m_size); }
ShMemReverseIterator<DataT> rbegin() const auto rbegin() const { return reverse_iterator(iterator(m_ptr + m_size)); }
{
return ShMemReverseIterator<DataT>(m_ptr + m_size - 1);
}
ShMemReverseIterator<DataT> rend() const { return ShMemReverseIterator<DataT>(m_ptr - 1); } auto rend() const { return reverse_iterator(iterator(m_ptr)); }
std::size_t size() const { return m_size; } std::size_t size() const { return m_size; }
@ -140,8 +116,9 @@ template <> class SharedMemoryWrapper<bool>
bool at(const std::size_t index) const bool at(const std::size_t index) const
{ {
const std::size_t bucket = index / 32; BOOST_ASSERT_MSG(index < m_size, "invalid size");
const unsigned offset = static_cast<unsigned>(index % 32); const std::size_t bucket = index / (CHAR_BIT * sizeof(unsigned));
const unsigned offset = index % (CHAR_BIT * sizeof(unsigned));
return m_ptr[bucket] & (1u << offset); return m_ptr[bucket] & (1u << offset);
} }
@ -155,13 +132,7 @@ template <> class SharedMemoryWrapper<bool>
bool empty() const { return 0 == size(); } bool empty() const { return 0 == size(); }
bool operator[](const unsigned index) bool operator[](const unsigned index) const { return at(index); }
{
BOOST_ASSERT_MSG(index < m_size, "invalid size");
const unsigned bucket = index / 32;
const unsigned offset = index % 32;
return m_ptr[bucket] & (1u << offset);
}
template <typename T> template <typename T>
friend void swap(SharedMemoryWrapper<T> &, SharedMemoryWrapper<T> &) noexcept; friend void swap(SharedMemoryWrapper<T> &, SharedMemoryWrapper<T> &) noexcept;