CAFirstMix.hpp File Reference

Classes
class	tUINT32withLock
class	CAFirstMix
Defines
#define	TNC_SREQUEST   "TermsAndConditionsRequest"
#define	TNC_RESPONSE   "TermsAndConditionsResponse"
#define	TNC_SINTERRUPT   "TermsAndConditionsInterrupt"
#define	TNC_REQ_TRANSLATION   "Translation"
#define	TNC_RESOURCES   "Resources"
#define	TNC_RESOURCE_TEMPLATE   "Template"
#define	TNC_TEMPLATE_ROOT_ELEMENT   "TermsAndConditionsTemplate"
#define	TNC_RESOURCE_CUSTOMIZED_SECT   "CustomizedSections"
#define	TNC_RESPONSE_INVALID_REQUEST   "InvalidTermsAndConditionsRequest"
#define	TNC_CONFIRM_REQ   "TermsAndConditionsConfirm"
Functions
THREAD_RETURN	fm_loopSendToMix (void *)
	How to end this thread: 0.
THREAD_RETURN	fm_loopReadFromMix (void *)
THREAD_RETURN	fm_loopAcceptUsers (void *)
THREAD_RETURN	fm_loopReadFromUsers (void *)
THREAD_RETURN	fm_loopDoUserLogin (void *param)
THREAD_RETURN	fm_loopLog (void *)
THREAD_RETURN	iplist_loopDoLogCountries (void *param)

---

Define Documentation

#define TNC_CONFIRM_REQ   "TermsAndConditionsConfirm"

Referenced by CAFirstMix::CAFirstMix().

#define TNC_REQ_TRANSLATION   "Translation"

Referenced by CAFirstMix::handleTermsAndConditionsLogin().

#define TNC_RESOURCE_CUSTOMIZED_SECT   "CustomizedSections"

Referenced by CAFirstMix::handleTermsAndConditionsLogin().

#define TNC_RESOURCE_TEMPLATE   "Template"

Referenced by CAFirstMix::handleTermsAndConditionsLogin().

#define TNC_RESOURCES   "Resources"

Referenced by CAFirstMix::handleTermsAndConditionsLogin().

#define TNC_RESPONSE   "TermsAndConditionsResponse"

Referenced by CAFirstMix::handleTermsAndConditionsLogin().

#define TNC_RESPONSE_INVALID_REQUEST   "InvalidTermsAndConditionsRequest"

Referenced by CAFirstMix::handleTermsAndConditionsLogin().

#define TNC_SINTERRUPT   "TermsAndConditionsInterrupt"

Referenced by CAFirstMix::CAFirstMix().

#define TNC_SREQUEST   "TermsAndConditionsRequest"

Referenced by CAFirstMix::CAFirstMix().

#define TNC_TEMPLATE_ROOT_ELEMENT   "TermsAndConditionsTemplate"

Referenced by CAFirstMix::handleTermsAndConditionsExtension().

---

Function Documentation

THREAD_RETURN fm_loopAcceptUsers

(

void *

)

References CASocket::accept(), CASocketGroup::add(), CAThreadPool::addRequest(), BEGIN_STACK, CATempIPBlockList::checkIP(), CATempIPBlockList::count(), CASocket::countOpenSockets(), CAThreadPool::countRequests(), CAFirstMix::decNewConnections(), E_SOCKETCLOSED, E_SUCCESS, E_TIMEDOUT, E_UNKNOWN, FINISH_STACK, fm_loopDoUserLogin(), GET_NET_ERROR, CAMuxSocket::getCASocket(), CACmdLnOptions::getMaxNrOfUsers(), CAFirstMix::getNrOfUsers(), CALibProxytest::getOptions(), CASocket::getPeerIP(), CAFirstMix::incNewConnections(), INIT_STACK, CAIPList::insertIP(), CATempIPBlockList::insertIP(), isAllowedToPassRestrictions(), CASocketGroup::isSignaled(), CAFirstMix::m_arMixParameters, CAFirstMix::m_arrSocketsIn, CAFirstMix::m_bRestart, CAFirstMix::m_newConnections, CAFirstMix::m_nSocketsIn, CAFirstMix::m_pIPBlockList, CAFirstMix::m_pIPList, CAFirstMix::m_pthreadsLogin, t_mix_parameters::m_u32ReplayOffset, CAFirstMix::MAX_CONCURRENT_NEW_CONNECTIONS, msSleep(), T_UserLoginData::peerIP, T_UserLoginData::pMix, T_UserLoginData::pNewUser, CAMsg::printMsg(), CASocketGroup::remove(), CAIPList::removeIP(), CASocketGroup::select(), sSleep(), and THREAD_RETURN_SUCCESS.

THREAD_RETURN fm_loopDoUserLogin

(

void *

param

)

References BEGIN_STACK, CAFirstMix::decNewConnections(), CAFirstMix::doUserLogin(), FINISH_STACK, INIT_STACK, T_UserLoginData::peerIP, T_UserLoginData::pMix, T_UserLoginData::pNewUser, SAVE_STACK, and THREAD_RETURN_SUCCESS.

Referenced by fm_loopAcceptUsers().

THREAD_RETURN fm_loopLog

(

void *

)

References logMemoryUsage(), CAFirstMix::m_bRunLog, sSleep(), and THREAD_RETURN_SUCCESS.

THREAD_RETURN fm_loopReadFromMix

(

void *

)

References CASocketGroup::add(), CAQueue::add(), BEGIN_STACK, t_MixPacket::channel, CHANNEL_DUMMY, t_MixPacket::data, DATA_SIZE, diff64(), DUMMY_CHANNEL, E_TIMEDOUT, ev_net_nextConnectionClosed, FINISH_STACK, t_MixPacket::flags, getcurrentTimeMicros(), getcurrentTimeMillis(), getRandom(), CAQueue::getSize(), INIT_STACK, CAFirstMix::m_bRestart, CAFirstMix::m_pMuxOut, CAMix::m_pMuxOutControlChannelDispatcher, CAFirstMix::m_pQueueReadFromMix, CAMix::m_u32KeepAliveRecvInterval, MAX_READ_FROM_NEXT_MIX_QUEUE_SIZE, MIX_POOL_TIMEOUT, MIXPACKET_SIZE, MONITORING_FIRE_NET_EVENT, msSleep(), t_queue_entry::packet, CAPool::pool(), CAMsg::printMsg(), CAControlChannelDispatcher::proccessMixPacket(), CAMuxSocket::receive(), CASocketGroup::select(), setZero64(), and THREAD_RETURN_SUCCESS.

THREAD_RETURN fm_loopReadFromUsers

(

void *

)

THREAD_RETURN fm_loopSendToMix

(

void *

param

)

How to end this thread: 0.

set bRestart=true; 1. Close connection to next mix 2. put some bytes (len>MIX_PACKET_SIZE) in the Mix-Output-Queue

References BEGIN_STACK, t_MixPacket::channel, CHANNEL_DUMMY, CHANNEL_OPEN, t_MixPacket::data, DATA_SIZE, DUMMY_CHANNEL, E_SUCCESS, E_TIMEDOUT, FINISH_STACK, t_MixPacket::flags, getcurrentTimeMicros(), CAQueue::getOrWait(), getRandom(), INIT_STACK, isZero64(), len, CAFirstMix::m_bRestart, CAFirstMix::m_pMuxOut, CAMix::m_u32KeepAliveSendInterval, MIX_POOL_TIMEOUT, MIXPACKET_SIZE, t_queue_entry::packet, CAPool::pool(), CAMsg::printMsg(), CAMuxSocket::send(), setZero64(), and THREAD_RETURN_SUCCESS.

THREAD_RETURN iplist_loopDoLogCountries

(

void *

param

)

References tUINT32withLock::getAndzero(), CACmdLnOptions::getCascadeName(), CALibProxytest::getOptions(), CAMutex::lock(), LOG_COUNTRIES_INTERVALL, CAFirstMix::m_bRunLogCountries, CAFirstMix::m_CountryStats, CAFirstMix::m_mysqlCon, CAFirstMix::m_PacketsPerCountryIN, CAFirstMix::m_PacketsPerCountryOUT, CAFirstMix::m_pmutexUser, mysqlEscapeTableName(), NR_OF_COUNTRIES, CAMsg::printMsg(), sSleep(), THREAD_RETURN_SUCCESS, and CAMutex::unlock().