CASocketList Class Reference

#include <CASocketList.hpp>

Collaboration diagram for CASocketList:

Public Member Functions
	CASocketList ()
	CASocketList (bool bThreadSafe)
	~CASocketList ()
SINT32	add (CASocket *pSocket, CASymChannelCipher **pCiphers)
	Add a new channel to the channel-list. More...
SINT32	get (HCHANNEL in, CONNECTION *out)
	Gets a copy of an entry form the channel-list. More...
CASocket *	remove (HCHANNEL id)
SINT32	clear ()
CONNECTION *	getFirst ()
	Gets the first entry of the channel-list. More...
CONNECTION *	getNext ()
	Gets the next entry of the channel-list. More...
UINT32	getSize ()
SINT32	setThreadSafe (bool b)
SINT32	addSendMeCounter (HCHANNEL in, SINT32 value)

Protected Member Functions
SINT32	increasePool ()

Protected Attributes
CONNECTIONLIST *	m_Connections
CONNECTIONLIST *	m_Pool
CONNECTIONLIST *	m_AktEnumPos
t_MEMBLOCK *	m_Memlist
CAMutex	cs
bool	m_bThreadSafe
UINT32	m_Size

Detailed Description

Definition at line 47 of file CASocketList.hpp.

Constructor & Destructor Documentation

CASocketList() [1/2]

CASocketList::CASocketList

(

)

Definition at line 64 of file CASocketList.cpp.

  {
    m_Connections=NULL;
    m_Pool=NULL;
    m_Memlist=NULL;
    m_AktEnumPos=NULL;
    m_bThreadSafe=false;
    setThreadSafe(false);
    increasePool();
    m_Size=0;
  }

References increasePool(), m_AktEnumPos, m_bThreadSafe, m_Connections, m_Memlist, m_Pool, m_Size, and setThreadSafe().

Here is the call graph for this function:

CASocketList() [2/2]

CASocketList::CASocketList

(

bool

bThreadSafe

)

Definition at line 76 of file CASocketList.cpp.

  {
    m_Connections=NULL;
    m_Pool=NULL;
    m_Memlist=NULL;
    m_AktEnumPos=NULL;
    m_bThreadSafe=false;
    setThreadSafe(bThreadSafe);
    increasePool();
  }

References increasePool(), m_AktEnumPos, m_bThreadSafe, m_Connections, m_Memlist, m_Pool, and setThreadSafe().

Here is the call graph for this function:

~CASocketList()

CASocketList::~CASocketList

(

)

Definition at line 87 of file CASocketList.cpp.

  {
    clear();
  }

References clear().

Here is the call graph for this function:

Member Function Documentation

add()

SINT32 CASocketList::add	(	CASocket *	pSocket,
		CASymChannelCipher **	pCiphers
	)

Add a new channel to the channel-list.

The id for that channel is randomly choosen.

Parameters

pSocket	a CASocket assoziated with the channel
pCiphers	an array of CASymCipher assoziated with the channel

Returns

E_SUCCESS if no error occurs E_UNKNOWN otherwise

Definition at line 125 of file CASocketList.cpp.

  {
    if(m_bThreadSafe)
      cs.lock();
    CONNECTIONLIST* tmp;
    if(m_Pool==NULL)
      {
        if(increasePool()!=E_SUCCESS)
          {
            if(m_bThreadSafe)
              cs.unlock();
            return E_UNKNOWN;
          }
       }
    tmp=m_Pool;
    m_Pool=m_Pool->next;
    tmp->next=m_Connections;
    m_Connections=tmp;
    m_Connections->pSocket=pSocket;
    m_Connections->pCiphers=pCiphers;
    m_Connections->currentSendMeCounter=0;
    m_Connections->upstreamBytes=0;
    for(;;)
      {
SELECT_RANDOM_CHANNEL_ID:
        getRandom(&m_Connections->outChannel);        
        tmp=m_Connections->next;
        while(tmp!=NULL)
          {
            if(tmp->outChannel==m_Connections->outChannel)
              goto SELECT_RANDOM_CHANNEL_ID;
            tmp=tmp->next;
          }
        break;
      }
    m_Size++;
    if(m_bThreadSafe)
      cs.unlock();
    return E_SUCCESS;
  }

References cs, connlist::currentSendMeCounter, E_SUCCESS, E_UNKNOWN, getRandom(), increasePool(), CAMutex::lock(), m_bThreadSafe, m_Connections, m_Pool, m_Size, connlist::next, connlist::outChannel, connlist::pCiphers, connlist::pSocket, CAMutex::unlock(), and connlist::upstreamBytes.

Referenced by CALocalProxy::loop().

Here is the call graph for this function:

Here is the caller graph for this function:

addSendMeCounter()

SINT32 CASocketList::addSendMeCounter	(	HCHANNEL	in,
		SINT32	value
	)

Definition at line 195 of file CASocketList.cpp.

  {
    if(m_bThreadSafe)
      cs.lock();
    CONNECTIONLIST* tmp;
    tmp=m_Connections;
    while(tmp!=NULL)
      {
        if(tmp->outChannel==in)
          {
            tmp->currentSendMeCounter+=value;
            if(m_bThreadSafe)
              cs.unlock();
            return E_SUCCESS;
          }
        tmp=tmp->next;
      }
    if(m_bThreadSafe)
      cs.unlock();
    return E_UNKNOWN;
  }

References cs, connlist::currentSendMeCounter, E_SUCCESS, E_UNKNOWN, CAMutex::lock(), m_bThreadSafe, m_Connections, connlist::next, connlist::outChannel, and CAMutex::unlock().

Referenced by CALocalProxy::loop().

Here is the call graph for this function:

Here is the caller graph for this function:

clear()

SINT32 CASocketList::clear

(

)

Definition at line 92 of file CASocketList.cpp.

  {
    _MEMBLOCK* tmp;
    tmp=m_Memlist;
    while(tmp!=NULL)
      {
        delete []tmp->mem;
        tmp->mem = NULL;
        m_Memlist=tmp;
        tmp=tmp->next;
        delete m_Memlist;
        m_Memlist = NULL;
      }
    m_Connections=NULL;
    m_Pool=NULL;
    m_Memlist=NULL;
    m_AktEnumPos=NULL;
    return E_SUCCESS;
  }

References E_SUCCESS, m_AktEnumPos, m_Connections, m_Memlist, m_Pool, t_MEMBLOCK::mem, and t_MEMBLOCK::next.

Referenced by ~CASocketList().

Here is the caller graph for this function:

get()

SINT32 CASocketList::get	(	HCHANNEL	in,
		CONNECTION *	out
	)

Gets a copy of an entry form the channel-list.

Parameters

in	- the channel-id for wich the entry is requested
out	- the object, that will hold the copy

Returns

true - if the channel was found false - otherwise

Definition at line 173 of file CASocketList.cpp.

  {
    if(m_bThreadSafe)
      cs.lock();
    CONNECTIONLIST* tmp;
    tmp=m_Connections;
    while(tmp!=NULL)
      {
        if(tmp->outChannel==in)
          {
            memcpy(out,tmp,sizeof(CONNECTION));
            if(m_bThreadSafe)
              cs.unlock();
            return E_SUCCESS;
          }
        tmp=tmp->next;
      }
    if(m_bThreadSafe)
      cs.unlock();
    return E_UNKNOWN;
  }

References cs, E_SUCCESS, E_UNKNOWN, CAMutex::lock(), m_bThreadSafe, m_Connections, connlist::next, connlist::outChannel, and CAMutex::unlock().

Referenced by CALocalProxy::loop().

Here is the call graph for this function:

Here is the caller graph for this function:

getFirst()

CONNECTION* CASocketList::getFirst ( )

inline

Gets the first entry of the channel-list.

Returns

the first entry of the channel list (this is not a copy!!)

Definition at line 62 of file CASocketList.hpp.

        {
          m_AktEnumPos=m_Connections;
          return m_AktEnumPos;
        }

References m_AktEnumPos, and m_Connections.

Referenced by CALocalProxy::loop().

Here is the caller graph for this function:

getNext()

CONNECTION* CASocketList::getNext ( )

inline

Gets the next entry of the channel-list.

Returns

the next entry of the channel list (this is not a copy!!)

Definition at line 72 of file CASocketList.hpp.

        {
          if(m_AktEnumPos!=NULL)
            m_AktEnumPos=m_AktEnumPos->next;
          return m_AktEnumPos;
        }

References m_AktEnumPos, and connlist::next.

Referenced by CALocalProxy::loop().

Here is the caller graph for this function:

getSize()

UINT32 CASocketList::getSize ( )

inline

Definition at line 79 of file CASocketList.hpp.

{return m_Size;}

References m_Size.

increasePool()

SINT32 CASocketList::increasePool ( )

protected

Definition at line 39 of file CASocketList.cpp.

  {
    CONNECTIONLIST* tmp=new CONNECTIONLIST[POOL_SIZE];
    if(tmp==NULL)
      return E_UNKNOWN;
    _MEMBLOCK* tmpMem=new _MEMBLOCK;
    if(tmpMem==NULL)
      {
        delete[] tmp;
        tmp = NULL;
        return E_UNKNOWN;
      }
    memset(tmp,0,sizeof(CONNECTIONLIST)*POOL_SIZE);
    for(int i=1;i<POOL_SIZE;i++)
      {
        tmp[i-1].next=&tmp[i];
      }
    tmp[POOL_SIZE-1].next=m_Pool;
    m_Pool=tmp;
    tmpMem->next=m_Memlist;
    tmpMem->mem=tmp;
    m_Memlist=tmpMem;
    return E_SUCCESS;
  }

References E_SUCCESS, E_UNKNOWN, m_Memlist, m_Pool, t_MEMBLOCK::mem, t_MEMBLOCK::next, connlist::next, and POOL_SIZE.

Referenced by add(), and CASocketList().

Here is the caller graph for this function:

remove()

CASocket * CASocketList::remove

(

HCHANNEL

id

)

Definition at line 217 of file CASocketList.cpp.

  {
    if(m_bThreadSafe)
      cs.lock();
    CONNECTIONLIST* tmp,*before;
    CASocket* ret;
    tmp=m_Connections;
    before=NULL;
    while(tmp!=NULL)
      {
        if(tmp->outChannel==id)
          {
            if(m_AktEnumPos==tmp)
              m_AktEnumPos=tmp->next;
            if(before!=NULL)
              before->next=tmp->next;
            else
              m_Connections=tmp->next;
            tmp->next=m_Pool;
            m_Pool=tmp;
            ret=tmp->pSocket;
            m_Size--;
            if(m_bThreadSafe)
              cs.unlock();
            return ret;
          }
        before=tmp;
        tmp=tmp->next;
      }
    if(m_bThreadSafe)
      cs.unlock();
    return NULL;
  }

References cs, CAMutex::lock(), m_AktEnumPos, m_bThreadSafe, m_Connections, m_Pool, m_Size, connlist::next, connlist::outChannel, connlist::pSocket, and CAMutex::unlock().

Referenced by CALocalProxy::loop().

Here is the call graph for this function:

Here is the caller graph for this function:

setThreadSafe()

SINT32 CASocketList::setThreadSafe

(

bool

b

)

Definition at line 112 of file CASocketList.cpp.

  {
    m_bThreadSafe=b;
    return E_SUCCESS;
  }

References E_SUCCESS, and m_bThreadSafe.

Referenced by CASocketList().

Here is the caller graph for this function:

Member Data Documentation

cs

CAMutex CASocketList::cs

protected

Definition at line 88 of file CASocketList.hpp.

Referenced by add(), addSendMeCounter(), get(), and remove().

m_AktEnumPos

CONNECTIONLIST* CASocketList::m_AktEnumPos

protected

Definition at line 86 of file CASocketList.hpp.

Referenced by CASocketList(), clear(), getFirst(), getNext(), and remove().

m_bThreadSafe

bool CASocketList::m_bThreadSafe

protected

Definition at line 89 of file CASocketList.hpp.

Referenced by add(), addSendMeCounter(), CASocketList(), get(), remove(), and setThreadSafe().

m_Connections

CONNECTIONLIST* CASocketList::m_Connections

protected

Definition at line 84 of file CASocketList.hpp.

Referenced by add(), addSendMeCounter(), CASocketList(), clear(), get(), getFirst(), and remove().

m_Memlist

t_MEMBLOCK* CASocketList::m_Memlist

protected

Definition at line 87 of file CASocketList.hpp.

Referenced by CASocketList(), clear(), and increasePool().

m_Pool

CONNECTIONLIST* CASocketList::m_Pool

protected

Definition at line 85 of file CASocketList.hpp.

Referenced by add(), CASocketList(), clear(), increasePool(), and remove().

m_Size

UINT32 CASocketList::m_Size

protected

Definition at line 90 of file CASocketList.hpp.

Referenced by add(), CASocketList(), getSize(), and remove().

---

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

• CASocketList.hpp
• CASocketList.cpp