mosesdecoder/contrib/other-builds/moses2/MemPool.h

/*
 * MemPool.h
 *
 *  Created on: 28 Oct 2015
 *      Author: hieu
 */

#ifndef MEMPOOL_H_
#define MEMPOOL_H_

#include <algorithm>
#include <iostream>
#include <vector>
#include <stdint.h>
#include <stdlib.h>
#include <limits>
#include <iostream>

class MemPool {
	struct Page {
		uint8_t *mem;
		uint8_t *end;
		size_t size;

		Page(std::size_t size);
		~Page();
	};

  public:
	MemPool(std::size_t initSize = 10000);

    ~MemPool();

    void *Allocate(std::size_t size) {
      void *ret = current_;
      current_ += size;

      Page &page = m_pages[m_currPage];
      if (current_ < page.end) {
    	  // return what we got
      } else {
        ret = More(size);
      }
      return ret;

    }

    template<typename T>
    T *Allocate() {
    	void *ret = Allocate(sizeof(T));
    	return (T*) ret;
    }

    template<typename T>
    T *Allocate(size_t num) {
    	void *ret = Allocate(sizeof(T) * num);
    	return (T*) ret;
    }

    void Reset()
    {
    	m_currPage = 0;
    	current_ = m_pages[0].mem;
    }
  private:
    void *More(std::size_t size);

    std::vector<Page> m_pages;

    size_t m_currSize;
    size_t m_currPage;
    uint8_t *current_;

    // no copying
    MemPool(const MemPool &);
    MemPool &operator=(const MemPool &);
};

////////////////////////////////////////////////////////////////////////////////////////////////
template <typename T>
class MemPoolAllocator
{
public:
	typedef T value_type;
	typedef T* pointer;
	typedef const T* const_pointer;
	typedef T& reference;
    typedef const T& const_reference;
	typedef std::size_t size_type;
	typedef std::ptrdiff_t difference_type;

	template< class U >
	struct rebind { typedef MemPoolAllocator<U> other; };

	MemPoolAllocator() {}
	MemPoolAllocator(const MemPoolAllocator &other) {}

	template< class U >
	MemPoolAllocator( const MemPoolAllocator<U>& other ) {}

	size_type max_size() const
	{ return std::numeric_limits<size_type>::max(); }

	void deallocate( pointer p, size_type n )
	{
		//std::cerr << "deallocate " << p << " " << n << std::endl;
	}

	pointer allocate( size_type n, std::allocator<void>::const_pointer hint = 0 )
	{
		//std::cerr << "allocate " << n << " " << hint << std::endl;
		pointer ret = m_pool.Allocate<T>(n);
		return ret;
	}

	void construct( pointer p, const_reference val )
	{
		//std::cerr << "construct " << p << " " << n << std::endl;
		new((void *)p) T(val);
	}

	void destroy( pointer p )
	{
		//std::cerr << "destroy " << p << " " << n << std::endl;
	}

protected:
	MemPool m_pool;
};

////////////////////////////////////////////////////////////////////////////////////////////////
template <typename T>
class ObjectPoolContiguous {
  friend std::ostream& operator<<(std::ostream &, const ObjectPoolContiguous &);

  public:
	ObjectPoolContiguous(std::size_t initSize = 100000)
  	:m_size(0)
    ,m_actualSize(initSize)
  	{
		m_vec = (T*) malloc(sizeof(T) * initSize);
	}

    ~ObjectPoolContiguous()
    {
    	free (m_vec);
    }

    void Add(T &obj) {
    	if (m_size >= m_actualSize) {
	  //std::cerr << std::endl << "MORE " << m_size << std::endl;
	  m_actualSize *= 2;
 	  m_vec = (T*) realloc(m_vec, sizeof(T) * m_actualSize);
          
    	}
    	m_vec[m_size] = obj;
    	++m_size;
    }

    bool IsEmpty() const
    { return m_size == 0; }

    void Reset()
    {
    	m_size = 0;
    }

    // vector op
    size_t GetSize() const
    { return m_size; }


    const T& operator[](size_t ind) const {
    	return m_vec[ind];
    }

    // stack op
    const T &Get() const {
    	return m_vec[m_size - 1];
    }

    void Pop()
    {
    	--m_size;
    }

    T *GetData()
    {
    	return m_vec;
    }

    template<typename ORDERER>
    void Sort(const ORDERER &orderer)
    {
    	  std::sort(m_vec, m_vec + m_size, orderer);
    }

  private:
    T *m_vec;
    size_t m_size, m_actualSize;

    // no copying
    ObjectPoolContiguous(const ObjectPoolContiguous &);
    ObjectPoolContiguous &operator=(const ObjectPoolContiguous &);
};

template <typename T>
std::ostream& operator<<(std::ostream &out, const ObjectPoolContiguous<T> &obj)
{
	for (size_t i = 0; i < obj.size(); ++i) {
		T &ele = obj.get(i);
		out << ele;
	}
	return out;
}

#endif /* MEMPOOL_H_ */