CAFirstMixChannelToQueueList Class Reference

#include <CAFirstMix.hpp>

Collaboration diagram for CAFirstMixChannelToQueueList:

Public Member Functions
	CAFirstMixChannelToQueueList ()
SINT32	add (HCHANNEL channel, CAQueue *pQueue)
CAQueue *	get (HCHANNEL channel)
SINT32	removeChannel (HCHANNEL channel)
void	performanceTest ()

Private Attributes
CAMutex *	m_pMutex
tFirstMixChannelToQueueListEntry **	m_pHeads

Detailed Description

Definition at line 123 of file CAFirstMix.hpp.

Constructor & Destructor Documentation

CAFirstMixChannelToQueueList()

CAFirstMixChannelToQueueList::CAFirstMixChannelToQueueList ( )

inline

Definition at line 126 of file CAFirstMix.hpp.

        {
          m_pMutex = new CAMutex();
          m_pHeads = new t_FirstMixChannelToQueueList_entry*[0x10000];
          memset(m_pHeads, 0, sizeof(t_FirstMixChannelToQueueList_entry*) * 0x10000);
        }

References m_pHeads, and m_pMutex.

Member Function Documentation

add()

SINT32 CAFirstMixChannelToQueueList::add ( HCHANNEL  channel, CAQueue *  pQueue  )

inline

Definition at line 133 of file CAFirstMix.hpp.

        {
          m_pMutex->lock();
          tFirstMixChannelToQueueListEntry* pNewEntry = new tFirstMixChannelToQueueListEntry;
          pNewEntry->channel = channel;
          pNewEntry->pQueue = pQueue;
          UINT32 hashkey = channel & 0x0FFFF;
          pNewEntry->next = m_pHeads[hashkey];
          m_pHeads[hashkey] = pNewEntry;
          m_pMutex->unlock();
          return E_SUCCESS;
        }

References t_FirstMixChannelToQueueList_entry::channel, channel, E_SUCCESS, CAMutex::lock(), m_pHeads, m_pMutex, t_FirstMixChannelToQueueList_entry::next, t_FirstMixChannelToQueueList_entry::pQueue, and CAMutex::unlock().

Referenced by performanceTest().

Here is the call graph for this function:

Here is the caller graph for this function:

get()

CAQueue* CAFirstMixChannelToQueueList::get ( HCHANNEL  channel )

inline

Definition at line 146 of file CAFirstMix.hpp.

        {
#ifndef LOCK_FREE_LIST
          m_pMutex->lock();
#endif
          tFirstMixChannelToQueueListEntry* pEntry = m_pHeads[channel & 0x0FFFF ];
          while (pEntry != NULL)
            {
              if (pEntry->channel == channel)
                {
                  CAQueue* pQueue = pEntry->pQueue;
#ifndef LOCK_FREE_LIST
                  m_pMutex->unlock();
#endif
                  return pQueue;
                }
              pEntry=pEntry->next;
            }
#ifndef LOCK_FREE_LIST
          m_pMutex->unlock();
#endif
          return NULL;
        }

References t_FirstMixChannelToQueueList_entry::channel, channel, CAMutex::lock(), m_pHeads, m_pMutex, t_FirstMixChannelToQueueList_entry::next, t_FirstMixChannelToQueueList_entry::pQueue, and CAMutex::unlock().

Referenced by performanceTest().

Here is the call graph for this function:

Here is the caller graph for this function:

performanceTest()

void CAFirstMixChannelToQueueList::performanceTest ( )

inline

Definition at line 197 of file CAFirstMix.hpp.

        {
          UINT32 nrChannels = 10000;
          UINT32 nrAccess = 10000000;
          HCHANNEL* pChannels = new HCHANNEL[nrChannels];
          printf("%u Channel test - %u accesses\n",nrChannels,nrAccess);
          for (UINT32 i = 0; i < nrChannels; i++)
            {
              getRandom(&pChannels[i]);
              add(pChannels[i], NULL);
            }
 
          UINT64 startTime;
          getcurrentTimeMillis(startTime);
          for (UINT32 i = 0; i < nrAccess; i++)
            {
              UINT32 r;
              getRandom(&r);
              r %= 10000;
              get(pChannels[r]);
            }
          UINT64 endTime;
          getcurrentTimeMillis(endTime);
          
          printf("Duration: %u ms\n", diff64(endTime, startTime));
        }

References add(), diff64(), get(), getcurrentTimeMillis(), and getRandom().

Here is the call graph for this function:

removeChannel()

SINT32 CAFirstMixChannelToQueueList::removeChannel ( HCHANNEL  channel )

inline

Definition at line 170 of file CAFirstMix.hpp.

        {
          m_pMutex->lock();
          tFirstMixChannelToQueueListEntry* pEntry = m_pHeads[channel & 0x0FFFF];
          tFirstMixChannelToQueueListEntry* pLastEntry = NULL;
          while (pEntry != NULL)
            {
              if (pEntry->channel == channel)
                {
                  if (pLastEntry != NULL)
                    {
                      pLastEntry->next = pEntry->next;
                    }
                  else
                    {
                      m_pHeads[channel & 0x0FFFF] = pEntry->next;
                    }
                  delete pEntry;
                  m_pMutex->unlock();
                  return E_SUCCESS;
                }
            pEntry=pEntry->next;
        }
          m_pMutex->unlock();
          return E_UNKNOWN;
        }

References t_FirstMixChannelToQueueList_entry::channel, channel, E_SUCCESS, E_UNKNOWN, CAMutex::lock(), m_pHeads, m_pMutex, t_FirstMixChannelToQueueList_entry::next, and CAMutex::unlock().

Here is the call graph for this function:

Member Data Documentation

m_pHeads

tFirstMixChannelToQueueListEntry** CAFirstMixChannelToQueueList::m_pHeads

private

Definition at line 225 of file CAFirstMix.hpp.

Referenced by add(), CAFirstMixChannelToQueueList(), get(), and removeChannel().

m_pMutex

CAMutex* CAFirstMixChannelToQueueList::m_pMutex

private

Definition at line 224 of file CAFirstMix.hpp.

Referenced by add(), CAFirstMixChannelToQueueList(), get(), and removeChannel().

---

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

• CAFirstMix.hpp