CAThreadList Class Reference

#include <CAThreadList.hpp>

Collaboration diagram for CAThreadList:

Public Member Functions
	CAThreadList ()
	~CAThreadList ()
SINT32	put (const CAThread *const thread)
SINT32	remove (const CAThread *const thread)
SINT32	waitAndRemoveAll ()
	Waits for finishing of all threads in list and removes them. More...
void	showAll () const
UINT32	getSize () const

Private Member Functions
void	removeAll ()

Private Attributes
UINT32	m_Size
thread_list_entry_t *	m_pHead
CAMutex *	m_pListLock

Detailed Description

Definition at line 44 of file CAThreadList.hpp.

Constructor & Destructor Documentation

CAThreadList()

CAThreadList::CAThreadList

(

)

Author

Simon Pecher, JonDos GmbH

Definition at line 40 of file CAThreadList.cpp.

{
  m_pHead = NULL;
  m_Size=0;
  m_pListLock = new CAMutex();
}

References m_pHead, m_pListLock, and m_Size.

~CAThreadList()

CAThreadList::~CAThreadList

(

)

Definition at line 47 of file CAThreadList.cpp.

{
  m_pListLock->lock();
  removeAll();
  m_pListLock->unlock();
  
  delete m_pListLock;
  m_pListLock = NULL;
}

References CAMutex::lock(), m_pListLock, removeAll(), and CAMutex::unlock().

Here is the call graph for this function:

Member Function Documentation

getSize()

UINT32 CAThreadList::getSize ( ) const

inline

Definition at line 60 of file CAThreadList.hpp.

    {
      return m_Size;
    }

References m_Size.

put()

SINT32 CAThreadList::put

(

const CAThread *const

thread

)

Definition at line 59 of file CAThreadList.cpp.

{
  m_pListLock->lock();
  thread_list_entry_t *new_entry = new thread_list_entry_t;
  
  new_entry->tle_thread = (CAThread* const)thread;
  new_entry->tle_next = m_pHead;
  m_pHead = new_entry;  
  m_Size++;   
  m_pListLock->unlock();
  
  return E_SUCCESS;
}

References E_SUCCESS, CAMutex::lock(), m_pHead, m_pListLock, m_Size, thread_list_entry::tle_next, thread_list_entry::tle_thread, and CAMutex::unlock().

Referenced by CACryptoBenchmark::doBenchmark().

Here is the call graph for this function:

Here is the caller graph for this function:

remove()

SINT32 CAThreadList::remove

(

const CAThread *const

thread

)

Definition at line 73 of file CAThreadList.cpp.

{
  SINT32 ret=E_SUCCESS;
  
  m_pListLock->lock();
  thread_list_entry_t* iterator=m_pHead;
  thread_list_entry_t* prev=NULL;
    
  while (iterator!=NULL) 
  {
    if(iterator->tle_thread->getID() == thread->getID())
      {
        if(prev != NULL)
          {
            //unchain
            prev->tle_next = iterator->tle_next;
          }
        else
          {
            //Head holds the corresponding thread;
            m_pHead = iterator->tle_next;
          }
        //dispose the entry     
        delete iterator;
        iterator = NULL;
        m_Size--;
        break;
      }
    prev = iterator;
    iterator = iterator->tle_next;
  };
 
  m_pListLock->unlock();
  return ret;
}

References E_SUCCESS, CAThread::getID(), CAMutex::lock(), m_pHead, m_pListLock, m_Size, thread_list_entry::tle_next, thread_list_entry::tle_thread, and CAMutex::unlock().

Here is the call graph for this function:

removeAll()

void CAThreadList::removeAll ( )

private

Definition at line 152 of file CAThreadList.cpp.

{
  thread_list_entry_t* iterator=NULL;
  
  while(m_pHead != NULL)
    {
      iterator=m_pHead->tle_next;
 
      CAMsg::printMsg(LOG_INFO, "CAThreadList::removeAll: Thread %s, id %u\n", 
                      m_pHead->tle_thread->getName(),
                      m_pHead->tle_thread->getID());
      delete m_pHead;
      m_pHead=iterator;
    }
    
    m_pHead = NULL;
    m_Size=0;
  }

References CAThread::getID(), CAThread::getName(), m_pHead, m_Size, CAMsg::printMsg(), thread_list_entry::tle_next, and thread_list_entry::tle_thread.

Referenced by ~CAThreadList().

Here is the call graph for this function:

Here is the caller graph for this function:

showAll()

void CAThreadList::showAll

(

)

const

Definition at line 129 of file CAThreadList.cpp.

{
  m_pListLock->lock();
  
  if(m_pHead == NULL)
  {
    CAMsg::printMsg(LOG_INFO, "CAThreadList::showAll: list is empty, no threads found\n");
    m_pListLock->unlock();
    return;
  }
  
  thread_list_entry_t *iterator = m_pHead;
  do 
  {
    CAMsg::printMsg(LOG_INFO, "CAThreadList::showAll: Thread %s, id %u\n", 
                      iterator->tle_thread->getName(),
                      iterator->tle_thread->getID());
    iterator = iterator->tle_next;
  } while(iterator != NULL);
  m_pListLock->unlock();
}

References CAThread::getID(), CAThread::getName(), CAMutex::lock(), m_pHead, m_pListLock, CAMsg::printMsg(), thread_list_entry::tle_next, thread_list_entry::tle_thread, and CAMutex::unlock().

Here is the call graph for this function:

waitAndRemoveAll()

SINT32 CAThreadList::waitAndRemoveAll

(

)

Waits for finishing of all threads in list and removes them.

The memory of each CAThread object is freed.

Definition at line 172 of file CAThreadList.cpp.

{
  thread_list_entry_t* iterator = NULL;
 
  while (m_pHead != NULL)
  {
    iterator = m_pHead->tle_next;
#ifdef _DEBUG
    CAMsg::printMsg(LOG_INFO, "CAThreadList::waitAndRemoveAll: Thread %s, id %u\n",
      m_pHead->tle_thread->getName(),
      m_pHead->tle_thread->getID());
#endif
    m_pHead->tle_thread->join();
    delete m_pHead->tle_thread;
    delete m_pHead;
    m_pHead = iterator;
  }
 
  m_pHead = NULL;
  m_Size = 0;
  return E_SUCCESS;
}

References E_SUCCESS, CAThread::getID(), CAThread::getName(), CAThread::join(), m_pHead, m_Size, CAMsg::printMsg(), thread_list_entry::tle_next, and thread_list_entry::tle_thread.

Referenced by CACryptoBenchmark::doBenchmark().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

m_pHead

thread_list_entry_t* CAThreadList::m_pHead

private

Definition at line 70 of file CAThreadList.hpp.

Referenced by CAThreadList(), put(), remove(), removeAll(), showAll(), and waitAndRemoveAll().

m_pListLock

CAMutex* CAThreadList::m_pListLock

private

Definition at line 71 of file CAThreadList.hpp.

Referenced by CAThreadList(), put(), remove(), showAll(), and ~CAThreadList().

m_Size

UINT32 CAThreadList::m_Size

private

Definition at line 69 of file CAThreadList.hpp.

Referenced by CAThreadList(), getSize(), put(), remove(), removeAll(), and waitAndRemoveAll().

---

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

• CAThreadList.hpp
• CAThreadList.cpp