CALastMix Class Reference

Inheritance diagram for CALastMix:

Public Member Functions
	CALastMix ()
virtual	~CALastMix ()
SINT32	reconfigure ()
tMixType	getType () const
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 ()

Protected Member Functions
virtual SINT32	loop ()=0
SINT32	init ()
virtual SINT32	initOnce ()
SINT32	clean ()
SINT32	initMixCascadeInfo (DOMElement *)
	This will initialize the XML Cascade Info struct XMLFirstMixToInfoService that is sent to the InfoService in CAInfoService::sendCascadeHelo() More...
virtual SINT32	processKeyExchange ()
	Processes the startup communication with the preceeding mix. More...
SINT32	setTargets ()
	Reads the configured proxies from options. More...
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)
SINT32	signXML (DOMNode *a_element)

Protected Attributes
volatile bool	m_bRestart
CAMuxSocket *	m_pMuxIn
CAQueue *	m_pQueueSendToMix
CAQueue *	m_pQueueReadFromMix
CACacheLoadBalancing *	m_pCacheLB
CACacheLoadBalancing *	m_pSocksLB
CACacheLoadBalancing *	m_pVPNLB
CAASymCipher *	m_pRSA
CAThread *	m_pthreadSendToMix
CAThread *	m_pthreadReadFromMix
CALastMixChannelList *	m_pChannelList
volatile bool	m_bRunLog
volatile UINT32	m_logUploadedPackets
volatile UINT64	m_logUploadedBytes
volatile UINT32	m_logDownloadedPackets
volatile UINT64	m_logDownloadedBytes
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

Friends
THREAD_RETURN	lm_loopSendToMix (void *param)
	How to end this thread: 0. More...
THREAD_RETURN	lm_loopReadFromMix (void *pParam)
THREAD_RETURN	lm_loopLog (void *)

Additional Inherited Members
Public Types inherited from CAMix
enum	tMixType { FIRST_MIX , MIDDLE_MIX , LAST_MIX , JAP }
Public Attributes inherited from CAMixWithReplayDB
UINT64	m_u64ReferenceTime
Static Public Attributes inherited from CAMix
static const UINT32	TIMEOUT_MIX_CONNECTION_ESTABLISHEMENT = 60000

Constructor & Destructor Documentation

CALastMix()

CALastMix::CALastMix

(

)

References m_pCacheLB, m_pChannelList, CAMix::m_pInfoService, CAMix::m_pMultiSignature, m_pMuxIn, m_pQueueReadFromMix, m_pQueueSendToMix, m_pRSA, m_pSocksLB, m_pthreadReadFromMix, m_pthreadSendToMix, and m_pVPNLB.

~CALastMix()

virtual CALastMix::~CALastMix ( )

virtual

References clean(), m_pCacheLB, m_pSocksLB, and m_pVPNLB.

Member Function Documentation

clean()

SINT32 CALastMix::clean ( )

protectedvirtual

Implements CAMix.

References CAQueue::add(), CAMuxSocket::close(), CASocket::close(), E_SUCCESS, ev_net_prevConnectionClosed, CALastMixChannelList::getFirstSocket(), CALastMixChannelList::getNextSocket(), CAThread::join(), m_bRestart, m_bRunLog, m_pChannelList, m_pMuxIn, CAMix::m_pMuxInControlChannelDispatcher, m_pQueueReadFromMix, m_pQueueSendToMix, CAMixWithReplayDB::m_pReplayMsgProc, m_pRSA, m_pthreadReadFromMix, m_pthreadSendToMix, MONITORING_FIRE_NET_EVENT, t_lastmixchannellist::pCipher, t_lastmixchannellist::pQueueSend, CAMsg::printMsg(), and t_lastmixchannellist::pSocket.

Referenced by CALastMixA::loop(), and ~CALastMix().

getType()

tMixType CALastMix::getType ( ) const

virtual

Implements CAMix.

References CAMix::LAST_MIX.

init()

SINT32 CALastMix::init ( )

protectedvirtual

Implements CAMix.

References CAMuxSocket::accept(), E_SUCCESS, E_UNKNOWN, ev_net_keyExchangePrevFailed, ev_net_prevConnected, CAASymCipher::generateKeyPair(), GET_NET_ERROR, GET_NET_ERROR_STR, CAListenerInterface::getAddr(), CAMuxSocket::getCASocket(), CACmdLnOptions::getListenerInterface(), CACmdLnOptions::getListenerInterfaceCount(), CALibProxytest::getOptions(), CAListenerInterface::isVirtual(), m_pMuxIn, m_pRSA, MIXPACKET_SIZE, MONITORING_FIRE_NET_EVENT, OFB, CAMsg::printMsg(), processKeyExchange(), readFile(), saveFile(), CASocket::setKeepAlive(), CASocket::setNonBlocking(), CASocket::setRecvBuff(), CASocket::setSendBuff(), and CASocketAddr::toString().

initMixCascadeInfo()

SINT32 CALastMix::initMixCascadeInfo ( DOMElement *  mixes )

protectedvirtual

This will initialize the XML Cascade Info struct XMLFirstMixToInfoService that is sent to the InfoService in CAInfoService::sendCascadeHelo()

Parameters

mixes

the <Mixes> element of the XML struct we received from the succeeding mix.

Return values

E_UNKNOWN	if processing produces an error
E_SUCCESS	otherwise

Reimplemented from CAMix.

References CAMix::initMixCascadeInfo(), CAMix::m_docMixCascadeInfo, and setDOMElementAttribute().

Referenced by initOnce().

initOnce()

SINT32 CALastMix::initOnce ( )

protectedvirtual

TODO: Check what is done her and if this is important for any last mix or only in case of dynamic mixes...

Reimplemented from CAMix.

References E_SUCCESS, E_UNKNOWN, CACmdLnOptions::getMultiSigner(), CALibProxytest::getOptions(), initMixCascadeInfo(), CAMix::initOnce(), CAMix::m_pMultiSignature, CAMsg::printMsg(), and setTargets().

loop()

virtual SINT32 CALastMix::loop ( )

protectedpure virtual

Implements CAMix.

Implemented in CALastMixB, and CALastMixA.

processKeyExchange()

SINT32 CALastMix::processKeyExchange ( )

protectedvirtual

Processes the startup communication with the preceeding mix.

• Step 1: Mix n-1 open a TCP/IP Connection
  
• Step 2: LastMix sends XML struct describing itself, containing PubKey of LastMix, signed by LastMix (see XML structs)
  
• Step 3: Mix n-1 sends XML struct containing encrpyted (with PubKey) Symetric Key used for interlink encryption between Mix n-1 <—> LastMix, signed by Mix n-1 (see XML structs)
  

Getting and calculating the KeepAlive Traffice...

Implements CAMix.

References CAMix::addMixInfo(), CAMix::appendCompatibilityInfo(), CHAIN_TIMEOUT, CHANNEL_DOWNSTREAM_PACKETS, CHANNEL_TIMEOUT, CAMix::checkCompatibility(), createDOMDocument(), createDOMElement(), CABase64::decode(), decodeXMLEncryptedKey(), DOM_Output::dumpToMem(), E_SUCCESS, E_UNKNOWN, CABase64::encode(), FLOW_CONTROL_SENDME_SOFT_LIMIT, GET_NET_ERROR, GET_NET_ERROR_STR, CAMuxSocket::getCASocket(), getDOMChildByName(), getDOMElementValue(), CACmdLnOptions::getKeepAliveRecvInterval(), CACmdLnOptions::getKeepAliveSendInterval(), CALibProxytest::getOptions(), CACmdLnOptions::getPrevMixTestCertificate(), CAASymCipher::getPublicKeyAsDOMElement(), getRandom(), CACmdLnOptions::getTrustedCertificateStore(), len, m_pMuxIn, m_pRSA, CAMix::m_u32KeepAliveRecvInterval, CAMix::m_u32KeepAliveSendInterval, max, parseDOMDocument(), CAMsg::printMsg(), CAMuxSocket::receiveFully(), CASocket::send(), CAMuxSocket::setCrypt(), setDOMElementAttribute(), setDOMElementValue(), CACmdLnOptions::setPrevMixTestCertificate(), CAMuxSocket::setReceiveKey(), CAMuxSocket::setSendKey(), CAMix::signXML(), CAMix::TIMEOUT_MIX_CONNECTION_ESTABLISHEMENT, CACertStore::verifyMixCert(), and CAMultiSignature::verifyXML().

Referenced by init().

reconfigure()

SINT32 CALastMix::reconfigure ( )

virtual

Reimplemented from CAMix.

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

setTargets()

SINT32 CALastMix::setTargets ( )

protected

Reads the configured proxies from options.

Return values

E_UNKNOWN	if no proxies are specified
E_SUCCESS	if successfully configured the proxies

References CACacheLoadBalancing::add(), CACacheLoadBalancing::clean(), CATargetInterface::cleanAddr(), E_SUCCESS, E_UNKNOWN, CACacheLoadBalancing::get(), CATargetInterface::getAddr(), CACacheLoadBalancing::getElementCount(), CASocketAddrINet::getIP(), CALibProxytest::getOptions(), CASocketAddrINet::getPort(), CACmdLnOptions::getTargetInterface(), CACmdLnOptions::getTargetInterfaceCount(), CATargetInterface::getTargetType(), m_pCacheLB, m_pSocksLB, m_pVPNLB, CAMsg::printMsg(), TARGET_HTTP_PROXY, TARGET_SOCKS_PROXY, and TARGET_VPN_PROXY.

Referenced by initOnce(), and reconfigure().

Friends And Related Function Documentation

lm_loopLog

THREAD_RETURN lm_loopLog ( void *  )

friend

Referenced by CALastMixA::loop(), and CALastMixB::loop().

lm_loopReadFromMix

THREAD_RETURN lm_loopReadFromMix ( void *  pParam )

friend

ToDo: check if keep-alive is really correct here - should it not be moved upwards?

lm_loopSendToMix

THREAD_RETURN lm_loopSendToMix ( void *  param )

friend

How to end this thread: 0.

set m_bRestart=true;

1. Close connection to next mix
2. put a byte in the Mix-Output-Queue

Member Data Documentation

m_bRestart

volatile bool CALastMix::m_bRestart

protected

Referenced by clean(), CALastMixA::loop(), and CALastMixB::loop().

m_bRunLog

volatile bool CALastMix::m_bRunLog

protected

Referenced by clean(), CALastMixA::loop(), and CALastMixB::loop().

m_logDownloadedBytes

volatile UINT64 CALastMix::m_logDownloadedBytes

protected

Referenced by CALastMixA::loop(), and CALastMixB::loop().

m_logDownloadedPackets

volatile UINT32 CALastMix::m_logDownloadedPackets

protected

Referenced by CALastMixA::loop(), and CALastMixB::loop().

m_logUploadedBytes

volatile UINT64 CALastMix::m_logUploadedBytes

protected

Referenced by CALastMixA::loop(), and CALastMixB::loop().

m_logUploadedPackets

volatile UINT32 CALastMix::m_logUploadedPackets

protected

Referenced by CALastMixA::loop(), and CALastMixB::loop().

m_pCacheLB

CACacheLoadBalancing* CALastMix::m_pCacheLB

protected

Referenced by CALastMix(), CALastMixA::loop(), CALastMixB::loop(), setTargets(), and ~CALastMix().

m_pChannelList

CALastMixChannelList* CALastMix::m_pChannelList

protected

Referenced by CALastMix(), clean(), CALastMixA::loop(), and reconfigure().

m_pMuxIn

CAMuxSocket* CALastMix::m_pMuxIn

protected

Referenced by CALastMix(), clean(), init(), CALastMixA::loop(), CALastMixB::loop(), and processKeyExchange().

m_pQueueReadFromMix

CAQueue* CALastMix::m_pQueueReadFromMix

protected

Referenced by CALastMix(), clean(), CALastMixA::loop(), and CALastMixB::loop().

m_pQueueSendToMix

CAQueue* CALastMix::m_pQueueSendToMix

protected

Referenced by CALastMix(), clean(), CALastMixA::loop(), and CALastMixB::loop().

m_pRSA

CAASymCipher* CALastMix::m_pRSA

protected

Referenced by CALastMix(), clean(), init(), CALastMixA::loop(), CALastMixB::loop(), and processKeyExchange().

m_pSocksLB

CACacheLoadBalancing* CALastMix::m_pSocksLB

protected

Referenced by CALastMix(), CALastMixA::loop(), CALastMixB::loop(), setTargets(), and ~CALastMix().

m_pthreadReadFromMix

CAThread* CALastMix::m_pthreadReadFromMix

protected

Referenced by CALastMix(), clean(), and CALastMixB::loop().

m_pthreadSendToMix

CAThread* CALastMix::m_pthreadSendToMix

protected

Referenced by CALastMix(), clean(), and CALastMixB::loop().

m_pVPNLB

CACacheLoadBalancing* CALastMix::m_pVPNLB

protected

Referenced by CALastMix(), CALastMixA::loop(), setTargets(), and ~CALastMix().