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.
SINT32	setMixParameters (const tMixParameters &params)
	Sets the parameters for the mix specified in the params.m_strMixID field.
SINT32	handleKeyInfoExtensions (DOMElement *root)
SINT32	handleTermsAndConditionsExtension (DOMElement *extensionRoot)
Public Attributes
UINT64	m_u64LastTimestampReceived
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.
SINT32	incUsers (LP_fmHashTableEntry pHashEntry)
SINT32	decUsers (LP_fmHashTableEntry pHashEntry)
SINT32	incMixedPackets ()
SINT32	doUserLogin (CAMuxSocket *pNewUSer, UINT8 perrIP[4])
SINT32	reconfigure ()
SINT32	deleteCountryStats ()
Protected Attributes
CAIPList *	m_pIPList
CATempIPBlockList *	m_pIPBlockList
CAQueue *	m_pQueueSendToMix
CAQueue *	m_pQueueReadFromMix
CAFirstMixChannelList *	m_pChannelList
volatile UINT32	m_nUser
UINT32	m_nSocketsIn
volatile bool	m_bRestart
CASocket **	m_arrSocketsIn
UINT32	m_u32MixCount
tMixParameters *	m_arMixParameters
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
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.
SINT32	sendReplayTimestampRequestsToAllMixes ()
SINT32	doUserLogin_internal (CAMuxSocket *pNewUSer, UINT8 perrIP[4])
	Sends and receives all data neccessary for a User to "login".
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.
THREAD_RETURN	fm_loopReadFromMix (void *)
THREAD_RETURN	fm_loopAcceptUsers (void *)
THREAD_RETURN	fm_loopReadFromUsers (void *)
THREAD_RETURN	fm_loopDoUserLogin (void *param)
THREAD_RETURN	iplist_loopDoLogCountries (void *param)
THREAD_RETURN	fm_loopLog (void *)

Constructor & Destructor Documentation

CAFirstMix::CAFirstMix ( )

virtual CAFirstMix::~CAFirstMix ( ) [virtual]

References m_pmutexLogin, m_pmutexLoginThreads, m_pmutexMixedPackets, and m_pmutexUser.

Member Function Documentation

SINT32 CAFirstMix::clean ( ) [protected, virtual]

Implements CAMix.

References CAQueue::add(), cleanup(), CASocket::close(), CAMuxSocket::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, 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, and CAFirstMixChannelList::remove().

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

void CAFirstMix::decNewConnections ( ) [private]

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

Referenced by fm_loopAcceptUsers(), and fm_loopDoUserLogin().

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

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

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

References doUserLogin_internal(), FINISH_STACK, and INIT_STACK.

Referenced by fm_loopDoUserLogin().

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 CASocketGroupEpoll::add(), CAFirstMixChannelList::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, 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, CAQueue::get(), CAFirstMixChannelList::get(), GET_NET_ERROR, GET_NET_ERROR_STR, CAMuxSocket::getCASocket(), getDOMChildByName(), getDOMElementValue(), 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::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(), CASymCipher::setIVs(), CASocket::setKeepAlive(), CASymCipher::setKey(), CASocket::setNonBlocking(), CAMuxSocket::setReceiveKey(), CAMuxSocket::setSendKey(), CAMultiSignature::sign(), strerror(), TC_FAILED, TC_UNFINISHED, CAAccountingInstance::unlockLogin(), and termsAndConditionMixAnswer_t::xmlAnswer.

Referenced by doUserLogin().

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

References CAFirstMixChannelList::forceKickout(), and m_pChannelList.

Referenced by CAAccountingInstance::handleChallengeResponse_internal().

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

References E_SUCCESS, and getNrOfUsers().

CAMutex* CAFirstMix::getLoginMutex ( )

References m_pmutexLogin.

Referenced by CAAccountingInstance::handleChallengeResponse_internal().

SINT32 CAFirstMix::getMixCount ( )

References m_u32MixCount.

Referenced by doUserLogin_internal().

SINT32 CAFirstMix::getMixedPackets ( UINT64 & ppackets )

References E_SUCCESS, m_nMixedPackets, and set64().

tMixParameters* CAFirstMix::getMixParameters ( )

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

References m_arMixParameters.

UINT32 CAFirstMix::getNrOfUsers ( )

References m_nUser.

Referenced by fm_loopAcceptUsers(), and getLevel().

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

References m_nrOfTermsAndConditionsDefs, and m_tnCDefs.

Referenced by handleTermsAndConditionsLogin(), and processKeyExchange().

DOMNode * CAFirstMix::getTermsAndConditionsTemplate ( UINT8 * templateRefID )

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

Referenced by handleTermsAndConditionsExtension().

tMixType CAFirstMix::getType ( ) const [virtual]

Implements CAMix.

References CAMix::FIRST_MIX.

SINT32 CAFirstMix::handleKeyInfoExtensions ( DOMElement * root )

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

Referenced by processKeyExchange().

termsAndConditionMixAnswer_t * CAFirstMix::handleTermsAndConditionsLogin ( XERCES_CPP_NAMESPACE::DOMDocument * request ) [private]

SINT32 CAFirstMix::incMixedPackets ( ) [protected]

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

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

void CAFirstMix::incNewConnections ( ) [private]

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

Referenced by fm_loopAcceptUsers().

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

SINT32 CAFirstMix::init ( ) [protected, virtual]

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(), 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, CAMsg::printMsg(), processKeyExchange(), CASocket::setKeepAlive(), CAThread::setMainLoop(), CASocket::setRecvBuff(), CASocket::setSendBuff(), CADatabase::start(), CAThread::start(), and TARGET_MIX.

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

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.

Referenced by processKeyExchange().

SINT32 CAFirstMix::initOnce ( ) [protected, virtual]

Reimplemented from CAMix.

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

SINT32 CAFirstMix::isAllowedToPassRestrictions ( CASocket * pNewMuxSocket ) [private]

bool CAFirstMix::isShuttingDown ( ) [protected]

References m_bIsShuttingDown.

Referenced by init().

virtual SINT32 CAFirstMix::loop ( ) [protected, pure virtual]

Implements CAMix.

Implemented in CAFirstMixA, and CAFirstMixB.

SINT32 CAFirstMix::processKeyExchange ( ) [protected, virtual]

Getting the KeepAlive Traffic...

initialises MixParameters struct

Implements CAMix.

References CAMix::addMixInfo(), CAMix::appendCompatibilityInfo(), CAMix::appendTermsAndConditionsExtension(), CAMix::checkCompatibility(), createDOMDocument(), createDOMElement(), CABase64::decode(), DOM_Output::dumpToMem(), E_SUCCESS, E_UNKNOWN, CABase64::encode(), encodeXMLEncryptedKey(), equals(), CAASymCipher::generateKeyPair(), GET_NET_ERROR, GET_NET_ERROR_STR, CAMuxSocket::getCASocket(), getDOMChildByName(), getDOMElementAttribute(), getDOMElementValue(), CACmdLnOptions::getKeepAliveRecvInterval(), CACmdLnOptions::getKeepAliveSendInterval(), CACmdLnOptions::getNextMixTestCertificate(), CALibProxytest::getOptions(), CAASymCipher::getPublicKeyAsDOMElement(), getRandom(), getTermsAndConditions(), CACmdLnOptions::getTrustedCertificateStore(), handleKeyInfoExtensions(), CAMix::initMixCascadeInfo(), initMixParameters(), len, CAMix::m_pMultiSignature, m_pMuxOut, m_pRSA, CAMix::m_u32KeepAliveRecvInterval, CAMix::m_u32KeepAliveSendInterval, m_xmlKeyInfoBuff, m_xmlKeyInfoSize, MIX_CASCADE_PROTOCOL_VERSION, parseDOMDocument(), PAYMENT_VERSION, CAMsg::printMsg(), readFile(), CAMuxSocket::receiveFully(), saveFile(), CASocket::send(), CAMuxSocket::setCrypt(), setDOMElementAttribute(), setDOMElementValue(), CACmdLnOptions::setNextMixTestCertificate(), CAASymCipher::setPublicKeyAsDOMNode(), CAMuxSocket::setReceiveKey(), CAMuxSocket::setSendKey(), CAMultiSignature::signXML(), CAMix::signXML(), CAMix::termsAndConditionsInfoNode(), CAMix::TIMEOUT_MIX_CONNECTION_ESTABLISHEMENT, CACertStore::verifyMixCert(), CACmdLnOptions::verifyMixCertificates(), and CAMultiSignature::verifyXML().

Referenced by init().

SINT32 CAFirstMix::reconfigure ( ) [protected, virtual]

Reimplemented from CAMix.

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

SINT32 CAFirstMix::sendReplayTimestampRequestsToAllMixes ( ) [private]

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

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.

Referenced by CAReplayCtrlChannelMsgProc::proccessGotTimestamp().

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