ThreadSafeRefcounter.cpp

Go to the documentation of this file.

/* -*- C++ -*- */
#ifndef _MADARA_THREADSAFE_REFCOUNTER_CPP_
#define _MADARA_THREADSAFE_REFCOUNTER_CPP_

#include "madara/utility/ThreadSafeRefcounter.h"

template <typename T>
madara::utility::ThreadSafeRefcounter<T>::ThreadSafeRefcounter (void)
  : ptr_ (0)
{
}

template <typename T>
madara::utility::ThreadSafeRefcounter<T>::ThreadSafeRefcounter (T *ptr,
  bool increase_count, bool manage)
  : ptr_ (new Shim (ptr, manage))
{
  if (increase_count)
    increment ();
}

template <typename T>
madara::utility::ThreadSafeRefcounter<T>::ThreadSafeRefcounter (
  const ThreadSafeRefcounter &rhs)
  : ptr_ (rhs.ptr_)
{
  increment ();
}

template <typename T>
madara::utility::ThreadSafeRefcounter<T>::~ThreadSafeRefcounter (void)
{
  decrement ();
}

template <typename T>
void 
madara::utility::ThreadSafeRefcounter<T>::operator= (T *ptr)
{
  decrement ();
  ptr_ = new Shim (ptr);
}

template <typename T>
void
madara::utility::ThreadSafeRefcounter<T>::operator= (const ThreadSafeRefcounter& rhs)
{
  if (this != &rhs)
  {
    decrement ();
    ptr_ = rhs.ptr_;
    increment ();
  }
}

template <typename T>
T * 
madara::utility::ThreadSafeRefcounter<T>::get_ptr (void)
{
  T * result (0);
  
  if (ptr_)
  {
    result = ptr_->t_;
  }

  return result;
}

template <typename T>
const T *
madara::utility::ThreadSafeRefcounter<T>::get_ptr (void) const
{
  const T * result (0);

  if (ptr_)
  {
    result = ptr_->t_;
  }

  return result;
}

template <typename T>
bool
madara::utility::ThreadSafeRefcounter<T>::is_valid (void) const
{
  return ptr_ && ptr_->refcount_ > 0;
}

template <typename T>
T *
madara::utility::ThreadSafeRefcounter<T>::get (void)
{
  T * result (0);

  if (ptr_)
  {
    result = ptr_->t_;
  }

  return result;
}

template <typename T>
const T *
madara::utility::ThreadSafeRefcounter<T>::get (void) const
{
  const T * result (0);

  if (ptr_)
  {
    result = ptr_->t_;
  }

  return result;
}

template <typename T>
T & 
madara::utility::ThreadSafeRefcounter<T>::operator* (void)
{
  return *ptr_->t_;
}

template <typename T>
const 
T &
madara::utility::ThreadSafeRefcounter<T>::operator* (void) const
{
  return *ptr_->t_;
}

template <typename T>
T *
madara::utility::ThreadSafeRefcounter<T>::operator-> (void)
{
  T * result (0);

  if (ptr_)
  {
    result = ptr_->t_;
  }

  return result;
}

template <typename T>
const T *
madara::utility::ThreadSafeRefcounter<T>::operator-> (void) const
{
  const T * result (0);

  if (ptr_)
  {
    result = ptr_->t_;
  }

  return result;
}

template <typename T>
void 
madara::utility::ThreadSafeRefcounter<T>::increment (void)
{
  if (ptr_ && ptr_->manage_)
  {
    MADARA_GUARD_TYPE guard (ptr_->mutex_);
    ++ptr_->refcount_;
  }
}

template <typename T>
void 
madara::utility::ThreadSafeRefcounter<T>::decrement (void)
{
  if (ptr_&& ptr_->manage_)
  {
    MADARA_GUARD_TYPE guard (ptr_->mutex_);
    --ptr_->refcount_;
    if (ptr_->refcount_ <= 0)
    {
      delete ptr_;
      ptr_ = 0;
    }
  }
}

template <typename T>
madara::utility::ThreadSafeRefcounter<T>::Shim::Shim (T *t, bool manage)
  : t_ (t), refcount_ (1), manage_ (manage)
{
}

template <typename T>
madara::utility::ThreadSafeRefcounter<T>::Shim::~Shim (void) 
{
  if (manage_)
    delete t_; 
}

#endif /* _MADARA_THREADSAFE_REFCOUNTER_CPP_ */