ptrDispatcher Class Reference

#include <ptr_dispatcher.hh>

Public Member Functions
	ptrDispatcher ()
	~ptrDispatcher ()
void	close ()
void	signal ()
void	lock ()
void	unlock ()
void *	get_nolock ()
void *	get ()
void	put_nolock (void *pointer)
void	put (void *pointer)

Private Member Functions
void	wait ()

Private Attributes
std::deque< void * >	m_queue
pthread_mutex_t	m_mutex
pthread_cond_t	m_cond
boost::atomic< bool >	m_status

Detailed Description

Author

cpellegrino

Definition at line 12 of file ptr_dispatcher.hh.

Constructor & Destructor Documentation

ptrDispatcher::ptrDispatcher ( )

inline

Definition at line 24 of file ptr_dispatcher.hh.

    :
    m_status(true)
  {
    pthread_mutex_init(&m_mutex, 0);
    pthread_cond_init (&m_cond,  0);
  }

ptrDispatcher::~ptrDispatcher ( )

inline

Definition at line 32 of file ptr_dispatcher.hh.

  {
    close();
    pthread_mutex_destroy(&m_mutex);
    pthread_cond_destroy(&m_cond);
  }

Member Function Documentation

void ptrDispatcher::close ( )

inline

Definition at line 39 of file ptr_dispatcher.hh.

  {
    m_status = false;
    lock();
    signal();
    unlock();
  }

void ptrDispatcher::signal ( )

inline

Definition at line 47 of file ptr_dispatcher.hh.

  {
    pthread_cond_signal(&m_cond);
  }

void ptrDispatcher::lock ( )

inline

Definition at line 52 of file ptr_dispatcher.hh.

  {
    pthread_mutex_lock(&m_mutex);
  }

void ptrDispatcher::unlock ( )

inline

Definition at line 57 of file ptr_dispatcher.hh.

  {
    pthread_mutex_unlock(&m_mutex);
  }

void* ptrDispatcher::get_nolock ( )

inline

Definition at line 62 of file ptr_dispatcher.hh.

  {
    if (m_queue.empty() || !m_status)
    {
      return 0;
    }

    void* pointer = m_queue.front();
    m_queue.pop_front();
    return pointer;
  }

void* ptrDispatcher::get ( )

inline

Definition at line 74 of file ptr_dispatcher.hh.

  {
    if (!m_status)
    {
      return 0;
    }

    lock();
    wait();

    void* pointer = 0;

    if (m_queue.size())
    {
      pointer = m_queue.front();
      m_queue.pop_front();
    }

    unlock();
    return pointer;
  }

void ptrDispatcher::put_nolock ( void *  pointer )

inline

Definition at line 96 of file ptr_dispatcher.hh.

  {
    if (m_status)
    {
      m_queue.push_back(pointer);
    }
  }

void ptrDispatcher::put ( void *  pointer )

inline

Definition at line 104 of file ptr_dispatcher.hh.

  {
    if (m_status)
    {
      lock();
      m_queue.push_back(pointer);
      signal();
      unlock();
    }
  }

void ptrDispatcher::wait ( )

inlineprivate

Definition at line 117 of file ptr_dispatcher.hh.

  {
    while (m_queue.empty() && m_status)
    {
      if (pthread_cond_wait(&m_cond, &m_mutex) == EINVAL)
      {
        break;
      }
    }
  }

Member Data Documentation

std::deque<void*> ptrDispatcher::m_queue

private

Definition at line 14 of file ptr_dispatcher.hh.

pthread_mutex_t ptrDispatcher::m_mutex

private

Definition at line 16 of file ptr_dispatcher.hh.

pthread_cond_t ptrDispatcher::m_cond

private

Definition at line 18 of file ptr_dispatcher.hh.

boost::atomic<bool> ptrDispatcher::m_status

private

Definition at line 20 of file ptr_dispatcher.hh.

---

The documentation for this class was generated from the following file:

• ptr_dispatcher.hh