CAFirstMixChannelList.cpp File Reference

#include "StdAfx.h"
#include "CAFirstMixChannelList.hpp"
#include "CAUtil.hpp"
#include "CAMsg.hpp"
#include "CAThread.hpp"
#include "CAAccountingInstance.hpp"

Include dependency graph for CAFirstMixChannelList.cpp:

Go to the source code of this file.

Macros
#define	MAX_HASH_KEY   8200
#define	MAX_NUMBER_OF_CHANNELS   CHANNELS_PER_CLIENT
	The maximum number of channels allowed per connection. More...
#define	ERR_MSG_TO_MANY_CHANNELS   "More than " STR(MAX_NUMBER_OF_CHANNELS) " channels!\n"

Functions
THREAD_RETURN	fml_loopDelayBuckets (void *param)

Macro Definition Documentation

ERR_MSG_TO_MANY_CHANNELS

#define ERR_MSG_TO_MANY_CHANNELS   "More than " STR(MAX_NUMBER_OF_CHANNELS) " channels!\n"

MAX_HASH_KEY

#define MAX_HASH_KEY   8200

Definition at line 34 of file CAFirstMixChannelList.cpp.

MAX_NUMBER_OF_CHANNELS

#define MAX_NUMBER_OF_CHANNELS   CHANNELS_PER_CLIENT

The maximum number of channels allowed per connection.

Definition at line 223 of file CAFirstMixChannelList.cpp.

Function Documentation

fml_loopDelayBuckets()

THREAD_RETURN fml_loopDelayBuckets

(

void *

param

)

Definition at line 1175 of file CAFirstMixChannelList.cpp.

    {
      INIT_STACK;
      BEGIN_STACK("CAFirstMixChannelList::fml_loopDelayBuckets");
 
      CAFirstMixChannelList* pChannelList=(CAFirstMixChannelList*)param;
      volatile UINT32** pDelayBuckets=pChannelList->m_pDelayBuckets;
      while(pChannelList->m_bDelayBucketsLoopRun)
        {
          pChannelList->m_pMutexDelayChannel->lock();
          UINT32 u32BucketGrow=pChannelList->m_u32DelayChannelBucketGrow;
          UINT32 u32MaxBucket=u32BucketGrow*10;
          for(UINT32 i=0;i<MAX_POLLFD;i++)
            {
              if(pDelayBuckets[i]!=NULL&&*(pDelayBuckets[i])<u32MaxBucket)
              {
                *(pDelayBuckets[i])+=u32BucketGrow;
              }
            }
          pChannelList->m_pMutexDelayChannel->unlock();
          msSleep(pChannelList->m_u32DelayChannelBucketGrowIntervall);
        }
 
      FINISH_STACK("CAFirstMixChannelList::fml_loopDelayBuckets");
 
      THREAD_RETURN_SUCCESS;
    }