|
Mixes for Privacy and Anonymity in the Internet
|
Public Member Functions | |
| CASocketList () | |
| CASocketList (bool bThreadSafe) | |
| ~CASocketList () | |
| SINT32 | add (CASocket *pSocket, CASymCipher *pCiphers) |
| Add a new channel to the channel-list. | |
| SINT32 | get (HCHANNEL in, CONNECTION *out) |
| Gets a copy of an entry form the channel-list. | |
| CASocket * | remove (HCHANNEL id) |
| SINT32 | clear () |
| CONNECTION * | getFirst () |
| Gets the first entry of the channel-list. | |
| CONNECTION * | getNext () |
| Gets the next entry of the channel-list. | |
| 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 |
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().
References clear().
| SINT32 CASocketList::add | ( | CASocket * | pSocket, |
| CASymCipher * | 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().
| SINT32 CASocketList::addSendMeCounter | ( | HCHANNEL | in, |
| SINT32 | value | ||
| ) |
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().
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().
Gets the first entry of the channel-list.
References m_AktEnumPos, and m_Connections.
Referenced by CALocalProxy::loop().
Gets the next entry of the channel-list.
References m_AktEnumPos, and connlist::next.
Referenced by CALocalProxy::loop().
References m_Size.
| SINT32 CASocketList::increasePool | ( | ) | [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().
| CASocket * CASocketList::remove | ( | HCHANNEL | id | ) |
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().
CAMutex CASocketList::cs [protected] |
Referenced by add(), addSendMeCounter(), get(), and remove().
CONNECTIONLIST* CASocketList::m_AktEnumPos [protected] |
Referenced by CASocketList(), clear(), getFirst(), getNext(), and remove().
bool CASocketList::m_bThreadSafe [protected] |
Referenced by add(), addSendMeCounter(), CASocketList(), get(), remove(), and setThreadSafe().
CONNECTIONLIST* CASocketList::m_Connections [protected] |
Referenced by add(), addSendMeCounter(), CASocketList(), clear(), get(), getFirst(), and remove().
t_MEMBLOCK* CASocketList::m_Memlist [protected] |
Referenced by CASocketList(), clear(), and increasePool().
CONNECTIONLIST* CASocketList::m_Pool [protected] |
Referenced by add(), CASocketList(), clear(), increasePool(), and remove().
UINT32 CASocketList::m_Size [protected] |
Referenced by add(), CASocketList(), getSize(), and remove().
1.7.6.1