CAFirstMix.cpp File Reference

Classes
struct	T_UserLoginData
Defines
#define	COUNTRY_STATS_DB   "CountryStats"
#define	NR_OF_COUNTRIES   254
Typedefs
typedef struct T_UserLoginData	t_UserLoginData
Functions
THREAD_RETURN	fm_loopSendToMix (void *param)
	How to end this thread: 0.
THREAD_RETURN	fm_loopReadFromMix (void *pParam)
SINT32	isAllowedToPassRestrictions (CASocket *pNewMuxSocket)
THREAD_RETURN	fm_loopAcceptUsers (void *param)
THREAD_RETURN	fm_loopLog (void *param)
THREAD_RETURN	fm_loopDoUserLogin (void *param)
void	mysqlEscapeTableName (UINT8 *str)
	Escape a string so tha it could be used as table anme.
THREAD_RETURN	iplist_loopDoLogCountries (void *param)

---

Define Documentation

#define COUNTRY_STATS_DB   "CountryStats"

Referenced by CAFirstMix::initCountryStats().

#define NR_OF_COUNTRIES   254

Referenced by CAFirstMix::initCountryStats(), iplist_loopDoLogCountries(), and CAFirstMix::updateCountryStats().

---

Typedef Documentation

typedef struct T_UserLoginData t_UserLoginData

---

Function Documentation

THREAD_RETURN fm_loopAcceptUsers

(

void *

param

)

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 *

param

)

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

THREAD_RETURN fm_loopReadFromMix

(

void *

pParam

)

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_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().

SINT32 isAllowedToPassRestrictions

(

CASocket *

pNewMuxSocket

)

References E_SUCCESS, E_UNKNOWN, CACmdLnOptions::getInfoServices(), CASocketAddrINet::getIP(), CALibProxytest::getOptions(), CASocket::getPeerIP(), HTTP_TCP, T_UserLoginData::peerIP, CAMsg::printMsg(), and RAW_TCP.

Referenced by fm_loopAcceptUsers().

void mysqlEscapeTableName

(

UINT8 *

str

)

Escape a string so tha it could be used as table anme.

This is: exchange the chars '.' ; '/' ; '\' ; ':' with '_'

Referenced by CAFirstMix::initCountryStats(), and iplist_loopDoLogCountries().