Inheritance diagram for CAFirstMix:

Public Member Functions
	CAFirstMix ()

virtual	~CAFirstMix ()

tMixType	getType () const

bool	forceKickout (fmHashTableEntry pHashTableEntry, const XERCES_CPP_NAMESPACE::DOMDocument pErrDoc=NULL)

CAMutex *	getLoginMutex ()

SINT32	connectToNextMix (CASocketAddr *a_pAddrNext)

SINT32	getMixedPackets (UINT64 &ppackets)

UINT32	getNrOfUsers ()

SINT32	getLevel (SINT32 puser, SINT32 prisk, SINT32 *ptraffic)

TermsAndConditions *	getTermsAndConditions (const UINT8 *opSki)

DOMNode *	getTermsAndConditionsTemplate (UINT8 *templateRefID)

SINT32	getMixCount ()

tMixParameters *	getMixParameters ()
	Returns the ordered list of the mix parameters from the first mix to the last mix. More...

SINT32	setMixParameters (const tMixParameters &params)
	Sets the parameters for the mix specified in the params.m_strMixID field. More...

SINT32	handleKeyInfoExtensions (DOMElement *root)

SINT32	handleTermsAndConditionsExtension (DOMElement *extensionRoot)

Public Member Functions inherited from CAMixWithReplayDB
	CAMixWithReplayDB ()

CADatabase *	getReplayDB () const

Public Member Functions inherited from CAMix
	CAMix ()

virtual	~CAMix ()

SINT32	start ()

virtual void	shutDown ()

virtual bool	isShutDown ()

SINT32	getMixCascadeInfo (XERCES_CPP_NAMESPACE::DOMDocument *&docMixCascadeInfo)
	Returns the Mix-Cascade info which should be send to the InfoService. More...

bool	acceptsReconfiguration ()

CAControlChannelDispatcher *	getDownstreamControlChannelDispatcher () const

CAControlChannelDispatcher *	getUpstreamControlChannelDispatcher () const

UINT32	getLastConnectionTime ()

bool	isConnected ()

Public Attributes
UINT64	m_u64LastTimestampReceived

Public Attributes inherited from CAMixWithReplayDB
UINT64	m_u64ReferenceTime

Protected Member Functions
virtual SINT32	loop ()=0

bool	isShuttingDown ()

SINT32	init ()

SINT32	clean ()

virtual SINT32	initOnce ()

virtual SINT32	processKeyExchange ()

SINT32	initMixParameters (DOMElement *elemMixes)
	Initialises the MixParameters info for each mix form the <Mixes> element received from the second mix. More...

SINT32	incUsers (LP_fmHashTableEntry pHashEntry)

SINT32	decUsers (LP_fmHashTableEntry pHashEntry)

SINT32	incMixedPackets ()

SINT32	doUserLogin (CAMuxSocket *pNewUSer, UINT8 perrIP[4])

SINT32	reconfigure ()

SINT32	deleteCountryStats ()

Protected Member Functions inherited from CAMix
SINT32	checkCompatibility (DOMNode a_parent, const char a_mixPosition)

SINT32	appendCompatibilityInfo (DOMNode *a_parent)

SINT32	addMixInfo (DOMNode *a_element, bool a_bForceFirstNode)

virtual SINT32	initMixCascadeInfo (DOMElement *elemMixes)
	This will initialize the XML Cascade Info struct XMLFirstMixToInfoService that is sent to the InfoService in `CAInfoService::sendCascadeHelo()` More...

SINT32	signXML (DOMNode *a_element)

Protected Attributes
CAIPList *	m_pIPList

CATempIPBlockList *	m_pIPBlockList

CAQueue *	m_pQueueSendToMix

CAQueue *	m_pQueueReadFromMix

volatile UINT32	m_nUser

UINT32	m_nSocketsIn

volatile bool	m_bRestart

CASocket **	m_arrSocketsIn

UINT32	m_u32MixCount

tMixParameters *	m_arMixParameters

CAFirstMixChannelList *	m_pChannelList

CASocketGroupEpoll *	m_psocketgroupUsersRead

CASocketGroupEpoll *	m_psocketgroupUsersWrite

CAMuxSocket *	m_pMuxOut

UINT8 *	m_xmlKeyInfoBuff

UINT16	m_xmlKeyInfoSize

XERCES_CPP_NAMESPACE::DOMDocument *	m_docMixCascadeInfo

UINT64	m_nMixedPackets

CAASymCipher *	m_pRSA

CAMutex *	m_pmutexUser

CAMutex *	m_pmutexMixedPackets

CAMutex *	m_pmutexLoginThreads

CAThread *	m_pthreadAcceptUsers

CAThreadPool *	m_pthreadsLogin

CAThread *	m_pthreadSendToMix

CAThread *	m_pthreadReadFromMix

UINT32	m_nrOfTermsAndConditionsDefs

TermsAndConditions **	m_tnCDefs

UINT32	m_nrOfTermsAndConditionsTemplates

DOMNode **	m_tcTemplates

XERCES_CPP_NAMESPACE::DOMDocument *	m_templatesOwner

const XMLCh *	TNC_REQUEST

const XMLCh *	TNC_CONFIRM

const XMLCh *	TNC_INTERRUPT

tUINT32withLock *	m_PacketsPerCountryIN

tUINT32withLock *	m_PacketsPerCountryOUT

bool	m_bIsShuttingDown

volatile bool	m_bRunLog

CAMutex *	m_pmutexLogin

Protected Attributes inherited from CAMixWithReplayDB
CADatabase *	m_pReplayDB

CAReplayCtrlChannelMsgProc *	m_pReplayMsgProc

Protected Attributes inherited from CAMix
volatile bool	m_bLoop

bool	m_bReconfiguring

volatile bool	m_bShutDown

CAMultiSignature *	m_pMultiSignature

CAInfoService *	m_pInfoService

UINT32	m_u32KeepAliveRecvInterval

UINT32	m_u32KeepAliveSendInterval

bool	m_acceptReconfiguration

volatile bool	m_bConnected

volatile UINT32	m_lLastConnectionTime

XERCES_CPP_NAMESPACE::DOMDocument *	m_docMixCascadeInfo

CAControlChannelDispatcher *	m_pMuxOutControlChannelDispatcher

CAControlChannelDispatcher *	m_pMuxInControlChannelDispatcher

Private Member Functions
SINT32	initCountryStats (char db_host, char db_user, char *db_passwd)

SINT32	updateCountryStats (const UINT8 ip[4], UINT32 a_countryID, bool bRemove)
	Update the statisitics of the countries users come from. More...

SINT32	sendReplayTimestampRequestsToAllMixes ()

SINT32	doUserLogin_internal (CAMuxSocket *pNewUSer, UINT8 perrIP[4])
	Sends and receives all data neccessary for a User to "login". More...

SINT32	isAllowedToPassRestrictions (CASocket *pNewMuxSocket)

termsAndConditionMixAnswer_t *	handleTermsAndConditionsLogin (XERCES_CPP_NAMESPACE::DOMDocument *request)

void	incNewConnections ()

void	decNewConnections ()

Private Attributes
volatile bool	m_bRunLogCountries

volatile UINT32 *	m_CountryStats

CAThread *	m_threadLogLoop

MYSQL *	m_mysqlCon

volatile UINT32	m_newConnections

CAMutex *	m_pmutexNewConnections

Static Private Attributes
static const UINT32	MAX_CONCURRENT_NEW_CONNECTIONS = NUM_LOGIN_WORKER_TRHEADS * 2

Friends
THREAD_RETURN	fm_loopSendToMix (void *)
	How to end this thread: 0. More...

THREAD_RETURN	fm_loopReadFromMix (void *)

THREAD_RETURN	fm_loopAcceptUsers (void *)

THREAD_RETURN	fm_loopDoUserLogin (void *param)

THREAD_RETURN	iplist_loopDoLogCountries (void *param)

THREAD_RETURN	fm_loopLog (void *)

Additional Inherited Members
Public Types inherited from CAMix
enum	tMixType { FIRST_MIX , MIDDLE_MIX , LAST_MIX , JAP }

Static Public Attributes inherited from CAMix
static const UINT32	TIMEOUT_MIX_CONNECTION_ESTABLISHEMENT = 60000

Constructor & Destructor Documentation

◆ CAFirstMix()

CAFirstMix::CAFirstMix ( )

◆ ~CAFirstMix()

virtual CAFirstMix::~CAFirstMix ( )

virtual

References clean(), m_pmutexLogin, m_pmutexLoginThreads, m_pmutexMixedPackets, m_pmutexNewConnections, and m_pmutexUser.

Member Function Documentation

◆ clean()

SINT32 CAFirstMix::clean ( )

protectedvirtual

Implements CAMix.

References CAQueue::add(), CAAccountingInstance::clean(), CAAccountingDBInterface::cleanup(), CAMuxSocket::close(), CASocket::close(), deleteCountryStats(), E_SUCCESS, CAFirstMixChannelList::getFirst(), CAFirstMixChannelList::getFirstChannelForSocket(), getMemoryUsage(), CAFirstMixChannelList::getNext(), CAFirstMixChannelList::getNextChannel(), CAThread::join(), m_arMixParameters, m_arrSocketsIn, m_bRestart, m_bRunLog, m_docMixCascadeInfo, m_nMixedPackets, m_nrOfTermsAndConditionsDefs, m_nrOfTermsAndConditionsTemplates, m_nSocketsIn, m_nUser, m_pChannelList, CAMix::m_pInfoService, m_pIPBlockList, m_pIPList, m_pMuxOut, CAMix::m_pMuxOutControlChannelDispatcher, m_pQueueReadFromMix, m_pQueueSendToMix, CAMixWithReplayDB::m_pReplayMsgProc, m_pRSA, m_psocketgroupUsersRead, m_psocketgroupUsersWrite, m_pthreadAcceptUsers, m_pthreadReadFromMix, m_pthreadSendToMix, m_pthreadsLogin, t_mix_parameters::m_strMixID, m_tcTemplates, m_templatesOwner, m_tnCDefs, m_u32MixCount, m_xmlKeyInfoBuff, t_firstmixchannellist::pCipher, t_fmhashtableentry::pMuxSocket, t_fmhashtableentry::pQueueSend, CAMsg::printMsg(), t_fmhashtableentry::pSymCipher, CAFirstMixChannelList::remove(), and CAInfoService::stop().

Referenced by CAFirstMixA::loop(), and ~CAFirstMix().

◆ connectToNextMix()

SINT32 CAFirstMix::connectToNextMix ( CASocketAddr * a_pAddrNext )

References CAMuxSocket::connect(), E_SUCCESS, E_UNKNOWN, ERR_INTERN_CONNREFUSED, ERR_INTERN_TIMEDOUT, GET_NET_ERROR, GET_NET_ERROR_STR, m_pMuxOut, CAMsg::printMsg(), sSleep(), and CASocketAddr::toString().

Referenced by init().

◆ decNewConnections()

void CAFirstMix::decNewConnections ( )

private

References CAMutex::lock(), m_newConnections, m_pmutexNewConnections, and CAMutex::unlock().

◆ decUsers()

SINT32 CAFirstMix::decUsers ( LP_fmHashTableEntry pHashEntry )

protected

References t_fmhashtableentry::countryID, E_SUCCESS, CAMutex::lock(), m_nUser, m_pmutexUser, CAMutex::unlock(), and updateCountryStats().

Referenced by CAFirstMixA::closeConnection(), and CAFirstMixB::loop().

◆ deleteCountryStats()

SINT32 CAFirstMix::deleteCountryStats ( )

protected

References E_SUCCESS, CAThread::join(), m_bRunLogCountries, m_CountryStats, m_mysqlCon, m_PacketsPerCountryIN, m_PacketsPerCountryOUT, and m_threadLogLoop.

Referenced by clean().

◆ doUserLogin()

SINT32 CAFirstMix::doUserLogin	(	CAMuxSocket *	pNewUSer,
		UINT8	perrIP[4]
	)

protected

References doUserLogin_internal(), FINISH_STACK, INIT_STACK, T_UserLoginData::peerIP, and T_UserLoginData::pNewUser.

◆ doUserLogin_internal()

SINT32 CAFirstMix::doUserLogin_internal	(	CAMuxSocket *	pNewUser,
		UINT8	peerIP[4]
	)

private

Sends and receives all data neccessary for a User to "login".

This means sending the public key of the Mixes and receiving the sym keys of JAP. This is done in a thread on a per user basis

Todo:: Cleanup of runing thread if mix restarts...

TODO: move to the if-statement above

References CAFirstMixChannelList::add(), CASocketGroupEpoll::add(), AI_LOGIN_SO_TIMEOUT, AUTH_LOGIN_FAILED, AUTH_LOGIN_NOT_FINISHED, AUTH_LOGIN_SKIP_SETTLEMENT, AUTH_WAITING_FOR_FIRST_SETTLED_CC, BEGIN_STACK, t_MixPacket::channel, cleanupTnCMixAnswer(), t_fmhashtableentry::countryID, CASymChannelCipherFactory::createCipher(), createDOMDocument(), createDOMElement(), CABase64::decode(), decryptXMLElement(), DOM_Output::dumpToMem(), E_SOCKETCLOSED, E_SUCCESS, E_TIMEDOUT, E_UNKNOWN, CABase64::encode(), equals(), CAAccountingInstance::finishLoginProcess(), FIRST_MIX_RECEIVE_SYM_KEY_FROM_JAP_TIME_OUT, CAFirstMixChannelList::get(), CAQueue::get(), GET_NET_ERROR, GET_NET_ERROR_STR, CAMuxSocket::getCASocket(), getDOMChildByName(), getDOMElementValue(), CAMuxSocket::getHashKey(), getMixCount(), CACmdLnOptions::getMixId(), CALibProxytest::getOptions(), CAQueue::getSize(), handleTermsAndConditionsLogin(), t_fmhashtableentry::id, incUsers(), INIT_STACK, CATempIPBlockList::insertIP(), CASocket::isClosed(), CAAccountingInstance::loginProcessStatus(), m_arMixParameters, m_pChannelList, m_pIPBlockList, m_pIPList, CAMix::m_pMultiSignature, CAMixWithReplayDB::m_pReplayMsgProc, m_pRSA, m_psocketgroupUsersRead, m_psocketgroupUsersWrite, m_u64LastTimestampReceived, CAMixWithReplayDB::m_u64ReferenceTime, m_xmlKeyInfoBuff, m_xmlKeyInfoSize, MIXPACKET_SIZE, CAAccountingInstance::newSettlementTransaction(), parseDOMDocument(), t_fmhashtableentry::pControlChannelDispatcher, t_fmhashtableentry::pControlMessageQueue, T_UserLoginData::peerIP, T_UserLoginData::pNewUser, CAMuxSocket::prepareForSend(), CAMsg::printMsg(), CAControlChannelDispatcher::proccessMixPacket(), t_fmhashtableentry::pSymCipher, CAFirstMixChannelList::pushTimeoutEntry(), CAMuxSocket::receive(), CASocket::receiveFullyT(), CAControlChannelDispatcher::registerControlChannel(), CAFirstMixChannelList::remove(), CAIPList::removeIP(), REPLAY_BASE, termsAndConditionMixAnswer_t::result, SAVE_STACK, CASocket::sendFullyTimeOut(), SET_NET_ERROR, CAMuxSocket::setCrypt(), setDOMElementAttribute(), setDOMElementValue(), CASymChannelCipher::setIVs(), CASocket::setKeepAlive(), CASymChannelCipher::setKey(), CASocket::setNonBlocking(), CAMuxSocket::setReceiveKey(), CAMuxSocket::setSendKey(), CAMultiSignature::sign(), strerror(), TC_FAILED, TC_UNFINISHED, CAAccountingInstance::unlockLogin(), and termsAndConditionMixAnswer_t::xmlAnswer.

Referenced by doUserLogin().

◆ forceKickout()

bool CAFirstMix::forceKickout	(	fmHashTableEntry *	pHashTableEntry,
		const XERCES_CPP_NAMESPACE::DOMDocument *	pErrDoc = `NULL`
	)

References CAFirstMixChannelList::forceKickout(), and m_pChannelList.

Referenced by CAAccountingInstance::handleChallengeResponse_internal().

◆ getLevel()

SINT32 CAFirstMix::getLevel	(	SINT32 *	puser,
		SINT32 *	prisk,
		SINT32 *	ptraffic
	)

References E_SUCCESS, and getNrOfUsers().

◆ getLoginMutex()

CAMutex* CAFirstMix::getLoginMutex ( )

References m_pmutexLogin.

Referenced by CAAccountingInstance::handleChallengeResponse_internal().

◆ getMixCount()

SINT32 CAFirstMix::getMixCount ( )

References m_u32MixCount.

Referenced by doUserLogin_internal().

◆ getMixedPackets()

SINT32 CAFirstMix::getMixedPackets ( UINT64 & ppackets )

References E_SUCCESS, m_nMixedPackets, and set64().

◆ getMixParameters()

tMixParameters* CAFirstMix::getMixParameters ( )

Returns the ordered list of the mix parameters from the first mix to the last mix.

References m_arMixParameters.

◆ getNrOfUsers()

UINT32 CAFirstMix::getNrOfUsers ( )

References CAAccountingInstance::getNrOfUsers(), and m_nUser.

Referenced by getLevel().

◆ getTermsAndConditions()

TermsAndConditions * CAFirstMix::getTermsAndConditions ( const UINT8 * opSki )

References m_nrOfTermsAndConditionsDefs, and m_tnCDefs.

Referenced by handleTermsAndConditionsLogin().

◆ getTermsAndConditionsTemplate()

DOMNode * CAFirstMix::getTermsAndConditionsTemplate ( UINT8 * templateRefID )

References getTermsAndConditionsTemplateRefId(), m_nrOfTermsAndConditionsTemplates, m_tcTemplates, and TEMPLATE_REFID_MAXLEN.

Referenced by handleTermsAndConditionsExtension().

◆ getType()

tMixType CAFirstMix::getType ( ) const

virtual

Implements CAMix.

References CAMix::FIRST_MIX.

◆ handleKeyInfoExtensions()

SINT32 CAFirstMix::handleKeyInfoExtensions ( DOMElement * root )

References E_SUCCESS, E_UNKNOWN, getDOMChildByName(), handleTermsAndConditionsExtension(), and KEYINFO_NODE_EXTENSIONS.

◆ handleTermsAndConditionsExtension()

SINT32 CAFirstMix::handleTermsAndConditionsExtension ( DOMElement * extensionRoot )

◆ handleTermsAndConditionsLogin()

termsAndConditionMixAnswer_t * CAFirstMix::handleTermsAndConditionsLogin ( XERCES_CPP_NAMESPACE::DOMDocument * request )

private

◆ incMixedPackets()

SINT32 CAFirstMix::incMixedPackets ( )

protected

References E_SUCCESS, inc64(), CAMutex::lock(), m_nMixedPackets, m_pmutexMixedPackets, and CAMutex::unlock().

Referenced by CAFirstMixA::loop(), and CAFirstMixB::loop().

◆ incNewConnections()

void CAFirstMix::incNewConnections ( )

private

References CAMutex::lock(), m_newConnections, m_pmutexNewConnections, and CAMutex::unlock().

◆ incUsers()

SINT32 CAFirstMix::incUsers ( LP_fmHashTableEntry pHashEntry )

protected

References t_fmhashtableentry::countryID, E_SUCCESS, CAMutex::lock(), m_nUser, m_pmutexUser, t_fmhashtableentry::peerIP, CAMutex::unlock(), and updateCountryStats().

Referenced by doUserLogin_internal().

◆ init()

SINT32 CAFirstMix::init ( )

protectedvirtual

Connect to the next mix

Implements CAMix.

References CATargetInterface::cleanAddr(), connectToNextMix(), CASocket::create(), createDOMDocument(), CACmdLnOptions::createSockets(), E_SHUTDOWN, E_SUCCESS, E_UNKNOWN, ev_net_keyExchangeNextSuccessful, ev_net_nextConnected, ev_net_nextConnectionClosed, fm_loopAcceptUsers, fm_loopReadFromMix, fm_loopSendToMix, FM_PACKET_STATS_LOG_INTERVALL, GET_NET_ERROR_STR, CATargetInterface::getAddr(), CAMuxSocket::getCASocket(), CACmdLnOptions::getCountryStatsDBConnectionLoginData(), CALibProxytest::getOptions(), CASocket::getRecvBuff(), CASocket::getSendBuff(), CACmdLnOptions::getTargetInterface(), CACmdLnOptions::getTargetInterfaceCount(), CATargetInterface::getTargetType(), CASocketAddr::getType(), CAAccountingDBInterface::init(), CAAccountingInstance::init(), initCountryStats(), isShuttingDown(), m_arrSocketsIn, m_bRestart, m_nMixedPackets, m_nSocketsIn, m_pChannelList, m_pIPBlockList, m_pIPList, m_pMuxOut, CAMix::m_pMuxOutControlChannelDispatcher, m_pQueueReadFromMix, m_pQueueSendToMix, CAMixWithReplayDB::m_pReplayDB, CAMixWithReplayDB::m_pReplayMsgProc, m_psocketgroupUsersRead, m_psocketgroupUsersWrite, m_pthreadAcceptUsers, m_pthreadReadFromMix, m_pthreadSendToMix, m_pthreadsLogin, m_templatesOwner, m_u64LastTimestampReceived, CAMixWithReplayDB::m_u64ReferenceTime, MAX_LOGIN_QUEUE, MIXPACKET_SIZE, MONITORING_FIRE_NET_EVENT, NUM_LOGIN_WORKER_TRHEADS, OFB, CAMsg::printMsg(), processKeyExchange(), CASocket::setKeepAlive(), CAThread::setMainLoop(), CASocket::setNonBlocking(), CASocket::setRecvBuff(), CASocket::setSendBuff(), CADatabase::start(), CAThread::start(), and TARGET_MIX.

◆ initCountryStats()

SINT32 CAFirstMix::initCountryStats	(	char *	db_host,
		char *	db_user,
		char *	db_passwd
	)

private

References COUNTRY_STATS_DB, E_SUCCESS, E_UNKNOWN, CACmdLnOptions::getCascadeName(), CALibProxytest::getOptions(), iplist_loopDoLogCountries, m_bRunLogCountries, m_CountryStats, m_mysqlCon, m_PacketsPerCountryIN, m_PacketsPerCountryOUT, m_threadLogLoop, mysqlEscapeTableName(), NR_OF_COUNTRIES, CAMsg::printMsg(), CAThread::setMainLoop(), and CAThread::start().

Referenced by init().

◆ initMixParameters()

SINT32 CAFirstMix::initMixParameters ( DOMElement * elemMixes )

protected

Initialises the MixParameters info for each mix form the <Mixes> element received from the second mix.

set u32MixCount and m_arMixParameters from the <Mixes> element received from the second mix.

References E_SUCCESS, getDOMElementAttribute(), getElementsByTagName(), CACmdLnOptions::getMixId(), CALibProxytest::getOptions(), len, m_arMixParameters, t_mix_parameters::m_strMixID, and m_u32MixCount.

◆ initOnce()

SINT32 CAFirstMix::initOnce ( )

protectedvirtual

Reimplemented from CAMix.

References E_SUCCESS, E_UNKNOWN, CACmdLnOptions::getListenerInterface(), CACmdLnOptions::getListenerInterfaceCount(), CACmdLnOptions::getMultiSigner(), CALibProxytest::getOptions(), CAMix::initOnce(), CAListenerInterface::isVirtual(), m_nSocketsIn, CAMix::m_pMultiSignature, and CAMsg::printMsg().

◆ isAllowedToPassRestrictions()

SINT32 CAFirstMix::isAllowedToPassRestrictions ( CASocket * pNewMuxSocket )

private

◆ isShuttingDown()

bool CAFirstMix::isShuttingDown ( )

protected

References m_bIsShuttingDown.

Referenced by init().

◆ loop()

virtual SINT32 CAFirstMix::loop ( )

protectedpure virtual

Implements CAMix.

Implemented in CAFirstMixB, and CAFirstMixA.

◆ processKeyExchange()

SINT32 CAFirstMix::processKeyExchange ( )

protectedvirtual

Getting the KeepAlive Traffic...

initialises MixParameters struct

Implements CAMix.

Referenced by init().

◆ reconfigure()

SINT32 CAFirstMix::reconfigure ( )

protectedvirtual

Reimplemented from CAMix.

References E_SUCCESS, CALibProxytest::getOptions(), m_pChannelList, CAMsg::printMsg(), and CAFirstMixChannelList::setDelayParameters().

◆ sendReplayTimestampRequestsToAllMixes()

SINT32 CAFirstMix::sendReplayTimestampRequestsToAllMixes ( )

private

References E_SUCCESS, m_arMixParameters, CAMixWithReplayDB::m_pReplayMsgProc, m_u32MixCount, and CAReplayCtrlChannelMsgProc::sendGetTimestamp().

◆ setMixParameters()

SINT32 CAFirstMix::setMixParameters ( const tMixParameters & params )

Sets the parameters for the mix specified in the params.m_strMixID field.

Only the values which are set are copied to the stored parameters of the mixes of this cascade.

References E_SUCCESS, m_arMixParameters, t_mix_parameters::m_strMixID, m_u32MixCount, t_mix_parameters::m_u32ReplayBase, t_mix_parameters::m_u32ReplayOffset, and m_u64LastTimestampReceived.

◆ updateCountryStats()

SINT32 CAFirstMix::updateCountryStats	(	const UINT8	ip[4],
		UINT32	a_countryID,
		bool	bRemove
	)

private

Update the statisitics of the countries users come from.

The dependency between the argumenst is as follow:

Parameters

bRemove	if true the number of users of a given country is decreased, if false it is increased
a_countryID	the country the user comes from. Must be set if bRemove==true. If bRemove==false and ip==NULL, than if also must be set to the country the user comes from. In case ip!=NULL if holdes the default country id, if no country for the ip could be found
ip	the ip the user comes from. this ip is looked up in the databse to find the corresponding country. it is only used if bRemove==false. If no country for that ip could be found a_countryID is used as default value