CALastMixChannelList Class Reference

#include <CALastMixChannelList.hpp>

Collaboration diagram for CALastMixChannelList:

Public Member Functions
	CALastMixChannelList ()
	~CALastMixChannelList ()
SINT32	add (HCHANNEL id, CASocket *pSocket, CASymChannelCipher *pCipher, CAQueue *pQueue)
lmChannelListEntry *	get (HCHANNEL channelIn)
lmChannelListEntry *	getFirstSocket ()
lmChannelListEntry *	getNextSocket ()
SINT32	removeChannel (HCHANNEL channelIn)
UINT32	getSize ()

Static Public Member Functions
static SINT32	test ()

Private Attributes
UINT32	m_nChannels
LP_lmChannelListEntry *	m_HashTable
	The Hash-Table of all channels. More...
lmChannelList *	m_listSockets
	Pointer to the head of a list of all sockets. More...
lmChannelList *	m_listSocketsNext
	Next Element in the enumeration of all sockets. More...

Detailed Description

Definition at line 106 of file CALastMixChannelList.hpp.

Constructor & Destructor Documentation

CALastMixChannelList()

CALastMixChannelList::CALastMixChannelList

(

)

Definition at line 34 of file CALastMixChannelList.cpp.

  {
    m_HashTable=new LP_lmChannelListEntry[HASHTABLE_SIZE];
    memset(m_HashTable,0, HASHTABLE_SIZE*sizeof(LP_lmChannelListEntry));
    m_listSockets=NULL;
    m_listSocketsNext=NULL;
    m_nChannels=0;
#ifdef DELAY_CHANNELS
    m_u32DelayChannelUnlimitTraffic=DELAY_CHANNEL_TRAFFIC;
    m_u32DelayChannelBucketGrow=DELAY_BUCKET_GROW;
    m_u32DelayChannelBucketGrowIntervall=DELAY_BUCKET_GROW_INTERVALL;
    m_pDelayBuckets=new UINT32*[MAX_POLLFD];
    memset(m_pDelayBuckets,0,sizeof(UINT32*)*MAX_POLLFD);
    m_pMutexDelayChannel=new CAMutex();
    m_pThreadDelayBucketsLoop=new CAThread((UINT8*)"Delay Buckets Thread");
    m_bDelayBucketsLoopRun=true;
    m_pThreadDelayBucketsLoop->setMainLoop(lml_loopDelayBuckets);
    m_pThreadDelayBucketsLoop->start(this);
#endif
#ifdef DELAY_CHANNELS_LATENCY
    m_u32DelayChannelLatency=DELAY_CHANNEL_LATENCY;
#endif
#ifdef LOG_CRIME
    m_pMutex=new CAMutex();
#endif
}

References DELAY_CHANNEL_LATENCY, HASHTABLE_SIZE, m_HashTable, m_listSockets, m_listSocketsNext, m_nChannels, and MAX_POLLFD.

~CALastMixChannelList()

CALastMixChannelList::~CALastMixChannelList

(

)

Definition at line 61 of file CALastMixChannelList.cpp.

  {
#ifdef DELAY_CHANNELS
    m_bDelayBucketsLoopRun=false;
    m_pThreadDelayBucketsLoop->join();
    delete m_pThreadDelayBucketsLoop;
    m_pThreadDelayBucketsLoop = NULL;
    delete m_pMutexDelayChannel;
    m_pMutexDelayChannel = NULL;
    delete []m_pDelayBuckets;
    m_pDelayBuckets = NULL;
#endif
    for(UINT32 i=0;i < HASHTABLE_SIZE; i++)
      {
        lmChannelListEntry* akt=m_HashTable[i];
        lmChannelListEntry* tmp;
        while(akt!=NULL)
          {
            tmp=akt;
            akt=akt->list_Channels.next;
            delete tmp;
            tmp = NULL;
          }
      }
    delete[] m_HashTable;
    m_HashTable = NULL;
#ifdef LOG_CRIME
    delete m_pMutex;
#endif
 
  }

References HASHTABLE_SIZE, t_lastmixchannellist::list_Channels, m_HashTable, and t_lastmixchannellist::next.

Member Function Documentation

add()

SINT32 CALastMixChannelList::add	(	HCHANNEL	id,
		CASocket *	pSocket,
		CASymChannelCipher *	pCipher,
		CAQueue *	pQueue
	)

Definition at line 93 of file CALastMixChannelList.cpp.

  {
    UINT32 hash=id & HASH_MASK;
    lmChannelListEntry* pEntry=m_HashTable[hash];
    lmChannelListEntry* pNewEntry=new lmChannelListEntry;
    pNewEntry->channelIn=id;
    pNewEntry->pCipher=pCipher;
    pNewEntry->pSocket=pSocket;
    pNewEntry->pQueueSend=pQueue;
#if defined (LOG_CHANNEL)
    pNewEntry->timeCreated=timecreated;
#endif
#if defined (DELAY_CHANNELS_LATENCY)
    pNewEntry->timeLatency=delaytime+m_u32DelayChannelLatency;
#endif
#ifdef LOG_CHANNEL
    pNewEntry->trafficInFromUser=trafficInFromUser;
    pNewEntry->packetsDataInFromUser=1;
    pNewEntry->packetsDataOutToUser=0;
    pNewEntry->trafficOutToUser=0;
#endif
#ifdef LOG_CRIME
    pNewEntry->bIsCrime=bIsCrime;
    pNewEntry->bLogPayload=bLogPayload;
    pNewEntry->timeChannelOpened=timeChannelOpened;
#endif
#ifdef ANON_DEBUG_MODE
    pNewEntry->bDebug = bDebug;
#endif
    pNewEntry->sendmeCounterDownstream=0;
    pNewEntry->sendmeCounterUpstream=0;
#ifdef DELAY_CHANNELS
    pNewEntry->delayBucket=m_u32DelayChannelUnlimitTraffic; //can always send some first packets
    for(UINT32 i=0;i<MAX_POLLFD;i++)
      {
        if(m_pDelayBuckets[i]==NULL)
          {
            pNewEntry->delayBucketID=i;
            break;
          }
      }
    m_pDelayBuckets[pNewEntry->delayBucketID]=&pNewEntry->delayBucket;
#endif
    if(pEntry==NULL) //First Entry for Hash in HashTable
      {
        pNewEntry->list_Channels.next=NULL;
        pNewEntry->list_Channels.prev=NULL;
      }
    else //insert in Hashlist for Hashtableentry
      {
        pNewEntry->list_Channels.prev=NULL;
        pNewEntry->list_Channels.next=pEntry;
        pEntry->list_Channels.prev=pNewEntry;
      }
    //Insert in SocketList
#ifdef LOG_CRIME
    m_pMutex->lock();
#endif
    if(m_listSockets==NULL)
      {
        m_listSockets=pNewEntry;
        pNewEntry->list_Sockets.next=NULL;
        pNewEntry->list_Sockets.prev=NULL;
      }
    else
      {
        pNewEntry->list_Sockets.prev=NULL;
        pNewEntry->list_Sockets.next=m_listSockets;
        m_listSockets->list_Sockets.prev=pNewEntry;
        m_listSockets=pNewEntry;        
      }
#ifdef LOG_CRIME
    m_pMutex->unlock();
#endif
    m_HashTable[hash]=pNewEntry;
    //if(m_listSocketsNext==NULL)
    //  m_listSocketsNext=m_listSockets;
    m_nChannels++;
    return E_SUCCESS;
  }

References t_lastmixchannellist::channelIn, E_SUCCESS, HASH_MASK, t_lastmixchannellist::list_Channels, t_lastmixchannellist::list_Sockets, m_HashTable, m_listSockets, m_nChannels, MAX_POLLFD, t_lastmixchannellist::next, t_lastmixchannellist::pCipher, t_lastmixchannellist::pQueueSend, t_lastmixchannellist::prev, t_lastmixchannellist::pSocket, t_lastmixchannellist::sendmeCounterDownstream, and t_lastmixchannellist::sendmeCounterUpstream.

Referenced by CALastMixA::loop(), and test().

Here is the caller graph for this function:

get()

lmChannelListEntry* CALastMixChannelList::get ( HCHANNEL  channelIn )

inline

Definition at line 135 of file CALastMixChannelList.hpp.

        {
          lmChannelListEntry* akt=m_HashTable[channelIn & HASH_MASK];
          while(akt!=NULL)
            {
              if(akt->channelIn==channelIn)
                return akt;
              akt=akt->list_Channels.next;
            }
          return NULL;
        }

References t_lastmixchannellist::channelIn, HASH_MASK, t_lastmixchannellist::list_Channels, m_HashTable, and t_lastmixchannellist::next.

Referenced by CALastMixA::loop().

Here is the caller graph for this function:

getFirstSocket()

lmChannelListEntry* CALastMixChannelList::getFirstSocket ( )

inline

Definition at line 178 of file CALastMixChannelList.hpp.

        {
          if(m_listSockets!=NULL)
            m_listSocketsNext=m_listSockets->list_Sockets.next;
          else
            m_listSocketsNext=NULL;
          return m_listSockets;
        }

References t_lastmixchannellist::list_Sockets, m_listSockets, m_listSocketsNext, and t_lastmixchannellist::next.

Referenced by CALastMix::clean(), CALastMixA::loop(), and test().

Here is the caller graph for this function:

getNextSocket()

lmChannelListEntry* CALastMixChannelList::getNextSocket ( )

inline

Definition at line 187 of file CALastMixChannelList.hpp.

        {
          lmChannelListEntry* akt=m_listSocketsNext;
          if(m_listSocketsNext!=NULL)
            m_listSocketsNext=m_listSocketsNext->list_Sockets.next;
          return akt;
        }

References t_lastmixchannellist::list_Sockets, m_listSocketsNext, and t_lastmixchannellist::next.

Referenced by CALastMix::clean(), CALastMixA::loop(), and test().

Here is the caller graph for this function:

getSize()

UINT32 CALastMixChannelList::getSize ( )

inline

Definition at line 197 of file CALastMixChannelList.hpp.

{return m_nChannels;}   

References m_nChannels.

Referenced by CALastMixA::loop().

Here is the caller graph for this function:

removeChannel()

SINT32 CALastMixChannelList::removeChannel

(

HCHANNEL

channelIn

)

Definition at line 195 of file CALastMixChannelList.cpp.

  {
    UINT32 hash=channel & HASH_MASK;
    lmChannelListEntry* pEntry=m_HashTable[hash];
    while(pEntry!=NULL)
      {
        if(pEntry->channelIn==channel)
          {
            if(m_listSocketsNext==pEntry) //removing next enumeration Element...
              m_listSocketsNext=m_listSocketsNext->list_Sockets.next; //adjusting!
//remove from HashTable
            if(pEntry->list_Channels.prev==NULL)
              m_HashTable[hash]=pEntry->list_Channels.next;
            else
              {
                pEntry->list_Channels.prev->list_Channels.next=pEntry->list_Channels.next;
              }
            if(pEntry->list_Channels.next!=NULL)
              {
                pEntry->list_Channels.next->list_Channels.prev=pEntry->list_Channels.prev;
              }
            //remove from SocketList
#ifdef LOG_CRIME
            m_pMutex->lock();
#endif
            if(pEntry->list_Sockets.prev==NULL)
              m_listSockets=pEntry->list_Sockets.next;
            else
              pEntry->list_Sockets.prev->list_Sockets.next=pEntry->list_Sockets.next;
            if(pEntry->list_Sockets.next!=NULL)
              pEntry->list_Sockets.next->list_Sockets.prev=pEntry->list_Sockets.prev;
            #ifdef DELAY_CHANNELS
              m_pMutexDelayChannel->lock();
              m_pDelayBuckets[pEntry->delayBucketID]=NULL;
              m_pMutexDelayChannel->unlock();
            #endif
#ifdef LOG_CRIME
            if (pEntry->bIsCrime)
              {
                int log=LOG_ENCRYPTED;
                if(!CALibProxytest::getOptions()->isEncryptedLogEnabled())
                  log=LOG_CRIT;
                char buff[255];
                strftime(buff, 255, "%Y/%m/%d-%H:%M:%S", localtime(&pEntry->timeChannelOpened));
                CAMsg::printMsg(log, "Crime channel closed (opened at: %s [unix timestamp: %u]) -- previous mix channel: %u\n", buff,pEntry->timeChannelOpened,pEntry->channelIn);
              }
#endif
 
            delete pEntry;
            pEntry = NULL;
            m_nChannels--;          
#ifdef LOG_CRIME
            m_pMutex->unlock();
#endif
            return E_SUCCESS;
          }
        pEntry=pEntry->list_Channels.next;
      }
    return E_SUCCESS;
  }

References channel, t_lastmixchannellist::channelIn, E_SUCCESS, CALibProxytest::getOptions(), HASH_MASK, t_lastmixchannellist::list_Channels, t_lastmixchannellist::list_Sockets, LOG_ENCRYPTED, m_HashTable, m_listSockets, m_listSocketsNext, m_nChannels, t_lastmixchannellist::next, t_lastmixchannellist::prev, and CAMsg::printMsg().

Referenced by CALastMixA::loop(), and test().

Here is the call graph for this function:

Here is the caller graph for this function:

test()

SINT32 CALastMixChannelList::test ( )

static

Definition at line 256 of file CALastMixChannelList.cpp.

        {
#if !defined (LOG_CHANNEL)&&!defined(DELAY_CHANNELS_LATENCY)&&!defined(LOG_CRIME)&&!defined(ANON_DEBUG_MODE)
          CALastMixChannelList oList;
          UINT32 c;
          UINT32 rand;
          int i,j;
          for(i=0;i<100;i++)
            {
              getRandom(&c);
              oList.add(c,NULL,NULL,NULL);
 
          }
          for(i=0;i < 10000;i++)
            {
              lmChannelListEntry* akt=oList.getFirstSocket();
              while(akt!=NULL)
                {
                  getRandom(&rand);
                  if(rand<0x7FFFFFFF)
                    {
                      getRandom(&c);
                      oList.add(c,NULL,NULL,NULL);
                    }
                  getRandom(&rand);
                  if(rand<0x7FFFFFFF)
                    oList.removeChannel(akt->channelIn);
                  getRandom(&rand);
                  if(rand<0x0FFFFFFF)
                    for(j=0;j<5;j++)
                      {
                        getRandom(&c);
                        oList.add(c,NULL,NULL,NULL);
                      }
                  getRandom(&rand);
                  if(rand<0x7FFFFFFF)
                    for(j=0;j<10000;j++)
                      {
                        getRandom(&c);
                        oList.removeChannel(c);
                      }
                  akt=oList.getNextSocket();
                }
            }
#endif
          return 0;
        }

References add(), t_lastmixchannellist::channelIn, getFirstSocket(), getNextSocket(), getRandom(), and removeChannel().

Here is the call graph for this function:

Member Data Documentation

m_HashTable

LP_lmChannelListEntry* CALastMixChannelList::m_HashTable

private

The Hash-Table of all channels.

Definition at line 203 of file CALastMixChannelList.hpp.

Referenced by add(), CALastMixChannelList(), get(), removeChannel(), and ~CALastMixChannelList().

m_listSockets

lmChannelList* CALastMixChannelList::m_listSockets

private

Pointer to the head of a list of all sockets.

Definition at line 206 of file CALastMixChannelList.hpp.

Referenced by add(), CALastMixChannelList(), getFirstSocket(), and removeChannel().

m_listSocketsNext

lmChannelList* CALastMixChannelList::m_listSocketsNext

private

Next Element in the enumeration of all sockets.

Definition at line 208 of file CALastMixChannelList.hpp.

Referenced by CALastMixChannelList(), getFirstSocket(), getNextSocket(), and removeChannel().

m_nChannels

UINT32 CALastMixChannelList::m_nChannels

private

Definition at line 201 of file CALastMixChannelList.hpp.

Referenced by add(), CALastMixChannelList(), getSize(), and removeChannel().

---

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

• CALastMixChannelList.hpp
• CALastMixChannelList.cpp