Mixes for Privacy and Anonymity in the Internet
|
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 |
CASocketList::CASocketList | ( | ) |
References increasePool(), m_AktEnumPos, m_bThreadSafe, m_Connections, m_Memlist, m_Pool, m_Size, and setThreadSafe().
CASocketList::CASocketList | ( | bool | bThreadSafe | ) |
References increasePool(), m_AktEnumPos, m_bThreadSafe, m_Connections, m_Memlist, m_Pool, and setThreadSafe().
CASocketList::~CASocketList | ( | ) |
References clear().
SINT32 CASocketList::add | ( | CASocket * | pSocket, |
CASymChannelCipher ** | pCiphers | ||
) |
Add a new channel to the channel-list.
The id for that channel is randomly choosen.
pSocket | a CASocket assoziated with the channel |
pCiphers | an array of CASymCipher assoziated with the channel |
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().
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().
SINT32 CASocketList::clear | ( | ) |
References E_SUCCESS, m_AktEnumPos, m_Connections, m_Memlist, m_Pool, t_MEMBLOCK::mem, and t_MEMBLOCK::next.
Referenced by ~CASocketList().
SINT32 CASocketList::get | ( | HCHANNEL | in, |
CONNECTION * | out | ||
) |
Gets a copy of an entry form the channel-list.
in | - the channel-id for wich the entry is requested |
out | - the object, that will hold the copy |
References cs, E_SUCCESS, E_UNKNOWN, CAMutex::lock(), m_bThreadSafe, m_Connections, connlist::next, connlist::outChannel, and CAMutex::unlock().
Referenced by CALocalProxy::loop().
CONNECTION* CASocketList::getFirst | ( | ) |
Gets the first entry of the channel-list.
References m_AktEnumPos, and m_Connections.
Referenced by CALocalProxy::loop().
CONNECTION* CASocketList::getNext | ( | ) |
Gets the next entry of the channel-list.
References m_AktEnumPos, and connlist::next.
Referenced by CALocalProxy::loop().
|
protected |
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().
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().
SINT32 CASocketList::setThreadSafe | ( | bool | b | ) |
References E_SUCCESS, and m_bThreadSafe.
Referenced by CASocketList().
|
protected |
Referenced by add(), addSendMeCounter(), get(), and remove().
|
protected |
Referenced by CASocketList(), clear(), getFirst(), getNext(), and remove().
|
protected |
Referenced by add(), addSendMeCounter(), CASocketList(), get(), remove(), and setThreadSafe().
|
protected |
Referenced by add(), addSendMeCounter(), CASocketList(), clear(), get(), getFirst(), and remove().
|
protected |
Referenced by CASocketList(), clear(), and increasePool().
|
protected |
Referenced by add(), CASocketList(), clear(), increasePool(), and remove().
|
protected |
Referenced by add(), CASocketList(), getSize(), and remove().