CAFirstMix Class Reference

#include <CAFirstMix.hpp>

Inheritance diagram for CAFirstMix:

Collaboration 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

Detailed Description

Definition at line 229 of file CAFirstMix.hpp.

Constructor & Destructor Documentation

CAFirstMix()

CAFirstMix::CAFirstMix ( )

inline

Definition at line 237 of file CAFirstMix.hpp.

        {
          m_pmutexUser=new CAMutex();
          m_pmutexMixedPackets=new CAMutex();
          m_pmutexLoginThreads=new CAMutex();
          m_pmutexNewConnections=new CAMutex();
#ifdef CH_LOG_STUDY
          //log nr of opened channels per minute
          nrOfChOpMutex = new CAMutex();
          nrOfChThread = NULL;
          nrOfOpenedChannels = 0;
          currentOpenedChannels = 0;
          lastLogTime = 0;
#endif //CH_LOG_STUDY
          m_nMixedPackets=0;
          m_nUser=0;
          m_nSocketsIn=0;
          m_pQueueSendToMix=NULL;
          m_pQueueReadFromMix=NULL;
          m_pIPList=NULL;
          m_arrSocketsIn=NULL;
          m_pRSA=NULL;
          m_pInfoService=NULL;
#ifndef MULTI_THREADED_PACKET_PROCESSING
          m_psocketgroupUsersRead=NULL;
          m_psocketgroupUsersWrite=NULL;
          m_pChannelList=NULL;
#else
          m_numThreads = 10;
#endif
          m_pMuxOut=NULL;
          m_docMixCascadeInfo=NULL;
          m_xmlKeyInfoBuff=NULL;
          m_pthreadSendToMix=NULL;
          m_pthreadReadFromMix=NULL;
          m_pthreadAcceptUsers=NULL;
          m_pthreadsLogin=NULL;
          m_nrOfTermsAndConditionsDefs = 0;
          m_tnCDefs = NULL;
          m_nrOfTermsAndConditionsTemplates = 0;
          m_templatesOwner = NULL;
          m_tcTemplates = NULL;
          m_bIsShuttingDown=false;
          m_pIPBlockList = NULL;
#ifdef LOG_PACKET_TIMES
          m_pLogPacketStats=NULL;
#endif
#ifdef COUNTRY_STATS
          m_PacketsPerCountryIN=m_PacketsPerCountryOUT=NULL;
          m_CountryStats=NULL;
          m_mysqlCon=NULL;
          m_threadLogLoop=NULL;
#endif
          m_arMixParameters=NULL;
#ifdef DYNAMIC_MIX
          m_bBreakNeeded = false;
#endif
          TNC_REQUEST = XMLString::transcode(TNC_SREQUEST);
          TNC_CONFIRM = XMLString::transcode(TNC_CONFIRM_REQ);
          TNC_INTERRUPT =  XMLString::transcode(TNC_SINTERRUPT);
#ifdef PAYMENT
          m_pmutexLogin=new CAMutex();
#endif
        }

References m_arMixParameters, m_arrSocketsIn, m_bIsShuttingDown, m_CountryStats, m_docMixCascadeInfo, m_mysqlCon, m_nMixedPackets, m_nrOfTermsAndConditionsDefs, m_nrOfTermsAndConditionsTemplates, m_nSocketsIn, m_nUser, m_PacketsPerCountryIN, m_PacketsPerCountryOUT, m_pChannelList, CAMix::m_pInfoService, m_pIPBlockList, m_pIPList, m_pmutexLogin, m_pmutexLoginThreads, m_pmutexMixedPackets, m_pmutexNewConnections, m_pmutexUser, m_pMuxOut, m_pQueueReadFromMix, m_pQueueSendToMix, m_pRSA, m_psocketgroupUsersRead, m_psocketgroupUsersWrite, m_pthreadAcceptUsers, m_pthreadReadFromMix, m_pthreadSendToMix, m_pthreadsLogin, m_tcTemplates, m_templatesOwner, m_threadLogLoop, m_tnCDefs, m_xmlKeyInfoBuff, TNC_CONFIRM, TNC_CONFIRM_REQ, TNC_INTERRUPT, TNC_REQUEST, TNC_SINTERRUPT, and TNC_SREQUEST.

~CAFirstMix()

virtual CAFirstMix::~CAFirstMix ( )

inlinevirtual

Definition at line 303 of file CAFirstMix.hpp.

    {
      clean(); // speeds up shutdown
      delete m_pmutexUser;
      m_pmutexUser = NULL;
      delete m_pmutexMixedPackets;
      m_pmutexMixedPackets = NULL;
      delete m_pmutexLoginThreads;
      m_pmutexLoginThreads = NULL;
      delete m_pmutexNewConnections ;
      m_pmutexNewConnections=NULL;
#ifdef PAYMENT
      delete m_pmutexLogin;
#endif
    }

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

Here is the call graph for this function:

Member Function Documentation

clean()

SINT32 CAFirstMix::clean ( )

protectedvirtual

Implements CAMix.

Definition at line 2622 of file CAFirstMix.cpp.

  {
    //#ifdef _DEBUG
      CAMsg::printMsg(LOG_DEBUG,"CAFirstMix::clean() start\n");
    //#endif
    m_bRunLog=false;
    m_bRestart=true;
    if(m_pMuxOut!=NULL)
      {
        m_pMuxOut->close();
      }
 
    //writing some bytes to the queue...
    if(m_pQueueSendToMix!=NULL)
      {
        UINT8 b[sizeof(tQueueEntry)+1];
        m_pQueueSendToMix->add(b,sizeof(tQueueEntry)+1);
      }
 
    if(m_pthreadAcceptUsers!=NULL)
        {
          CAMsg::printMsg(LOG_CRIT,"Wait for LoopAcceptUsers!\n");
          m_pthreadAcceptUsers->join();
          delete m_pthreadAcceptUsers;
        }
    m_pthreadAcceptUsers=NULL;
    if(m_pthreadsLogin!=NULL)
      delete m_pthreadsLogin;
    m_pthreadsLogin=NULL;
    if(m_pInfoService!=NULL)
        {
            CAMsg::printMsg(LOG_CRIT,"Stopping InfoService....\n");
            CAMsg::printMsg (LOG_CRIT,"Memory usage before: %u\n",getMemoryUsage());
            m_pInfoService->stop();
            CAMsg::printMsg (LOG_CRIT,"Memory usage after: %u\n",getMemoryUsage());
            CAMsg::printMsg(LOG_CRIT,"Stopped InfoService!\n");
    //         delete m_pInfoService;
        }
    //     m_pInfoService=NULL;
 
  if(m_pthreadSendToMix!=NULL)
    {
      CAMsg::printMsg(LOG_CRIT,"Wait for LoopSendToMix!\n");
      m_pthreadSendToMix->join();
      delete m_pthreadSendToMix;
    }
  m_pthreadSendToMix=NULL;
  if(m_pthreadReadFromMix!=NULL)
    {
      CAMsg::printMsg(LOG_CRIT,"Wait for LoopReadFromMix!\n");
      m_pthreadReadFromMix->join();
      delete m_pthreadReadFromMix;
    }
  m_pthreadReadFromMix=NULL;
 
#ifdef CH_LOG_STUDY
  if(nrOfChThread != NULL)
  {
    nrOfChThread->join();
    delete nrOfChThread;
    nrOfChThread = NULL;
  }
#endif
 
#ifdef LOG_PACKET_TIMES
    if(m_pLogPacketStats!=NULL)
      {
        CAMsg::printMsg(LOG_CRIT,"Wait for LoopLogPacketStats to terminate!\n");
        m_pLogPacketStats->stop();
        delete m_pLogPacketStats;
      }
    m_pLogPacketStats=NULL;
#endif
    if(m_arrSocketsIn!=NULL)
      {
        for(UINT32 i=0;i<m_nSocketsIn;i++)
        {
          if (m_arrSocketsIn[i] != NULL)
          {
            m_arrSocketsIn[i]->close();
            delete m_arrSocketsIn[i];
            m_arrSocketsIn[i] = NULL;
          }
        }
        delete[] m_arrSocketsIn;
      }
    m_arrSocketsIn=NULL;
#ifdef REPLAY_DETECTION
    if(m_pReplayMsgProc!=NULL)
      {
        delete m_pReplayMsgProc;
      }
    m_pReplayMsgProc=NULL;
#endif
 
    if(m_pMuxOutControlChannelDispatcher!=NULL)
    {
      delete m_pMuxOutControlChannelDispatcher;
    }
    m_pMuxOutControlChannelDispatcher=NULL;
 
    if(m_pMuxOut!=NULL)
      {
        m_pMuxOut->close();
        delete m_pMuxOut;
      }
    m_pMuxOut=NULL;
#ifdef COUNTRY_STATS
    deleteCountryStats();
#endif
    if(m_pIPList!=NULL)
      delete m_pIPList;
    m_pIPList=NULL;
    if(m_pQueueSendToMix!=NULL)
      delete m_pQueueSendToMix;
    m_pQueueSendToMix=NULL;
    if(m_pQueueReadFromMix!=NULL)
      delete m_pQueueReadFromMix;
    m_pQueueReadFromMix=NULL;
 
#ifndef MULTI_THREADED_PACKET_PROCESSING
    if(m_pChannelList!=NULL)
      {
        CAMsg::printMsg(LOG_CRIT,"Before deleting CAFirstMixChannelList()!\n");
        CAMsg::printMsg (LOG_CRIT,"Memory usage before: %u\n",getMemoryUsage());
        fmHashTableEntry* pHashEntry=m_pChannelList->getFirst();
        while(pHashEntry!=NULL)
          {
            CAMuxSocket * pMuxSocket=pHashEntry->pMuxSocket;
            delete pHashEntry->pQueueSend;
            pHashEntry->pQueueSend = NULL;
            delete pHashEntry->pSymCipher;
            pHashEntry->pSymCipher = NULL;
 
            fmChannelListEntry* pEntry=m_pChannelList->getFirstChannelForSocket(pHashEntry->pMuxSocket);
            while(pEntry!=NULL)
              {
                delete pEntry->pCipher;
                pEntry->pCipher = NULL;
                pEntry=m_pChannelList->getNextChannel(pEntry);
              }
            m_pChannelList->remove(pHashEntry->pMuxSocket);
            pMuxSocket->close();
            delete pMuxSocket;
            pMuxSocket = NULL;
            pHashEntry=m_pChannelList->getNext();
          }
      }
 
    if(m_pChannelList!=NULL)
      delete m_pChannelList;
    m_pChannelList=NULL;
#endif
    CAMsg::printMsg (LOG_CRIT,"Memory usage after: %u\n",getMemoryUsage());
#ifdef PAYMENT
  CAAccountingInstance::clean();
  CAAccountingDBInterface::cleanup();
#endif
#ifndef MULTI_THREADED_PACKET_PROCESSING
    if(m_psocketgroupUsersRead!=NULL)
      delete m_psocketgroupUsersRead;
    m_psocketgroupUsersRead=NULL;
    if(m_psocketgroupUsersWrite!=NULL)
      delete m_psocketgroupUsersWrite;
    m_psocketgroupUsersWrite=NULL;
#endif
    if(m_pRSA!=NULL)
      delete m_pRSA;
    m_pRSA=NULL;
    if(m_xmlKeyInfoBuff!=NULL)
      delete[] m_xmlKeyInfoBuff;
    m_xmlKeyInfoBuff=NULL;
    m_docMixCascadeInfo=NULL;
    if(m_arMixParameters!=NULL)
    {
      for(UINT32 i=0;i<m_u32MixCount-1;i++)
        {
          delete[] m_arMixParameters[i].m_strMixID;
        }
      delete[] m_arMixParameters;
    }
    m_arMixParameters=NULL;
    m_u32MixCount=0;
    m_nMixedPackets=0; //reset to zero after each restart (at the moment neccessary for infoservice)
    m_nUser=0;
 
 
    delete m_pIPBlockList;
    m_pIPBlockList = NULL;
 
    CAMsg::printMsg (LOG_CRIT,"before tc cleanup\n");
    for (UINT32 i = 0; i < m_nrOfTermsAndConditionsDefs; i++)
    {
      delete m_tnCDefs[i];
      m_tnCDefs[i] = NULL;
    }
    delete [] m_tnCDefs;
    m_tnCDefs = NULL;
    m_nrOfTermsAndConditionsDefs = 0;
    CAMsg::printMsg (LOG_CRIT,"before template cleanup\n");
    for(UINT32 i = 0; i < m_nrOfTermsAndConditionsTemplates; i++)
    {
      m_tcTemplates[i]->release();
      m_tcTemplates[i] = NULL;
    }
    delete [] m_tcTemplates;
    m_tcTemplates = NULL;
    CAMsg::printMsg (LOG_CRIT,"before template owner release\n");
    if(m_templatesOwner != NULL)
    {
      m_templatesOwner->release();
      m_templatesOwner = NULL;
    }
    CAMsg::printMsg (LOG_CRIT,"after template owner release\n");
    m_nrOfTermsAndConditionsTemplates = 0;
    //#ifdef _DEBUG
      CAMsg::printMsg(LOG_DEBUG,"CAFirstMix::clean() finished\n");
    //#endif
 
    return E_SUCCESS;
  }

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

Here is the call graph for this function:

Here is the caller graph for this function:

connectToNextMix()

SINT32 CAFirstMix::connectToNextMix

(

CASocketAddr *

a_pAddrNext

)

Definition at line 307 of file CAFirstMix.cpp.

{
  UINT8 buff[255];
  a_pAddrNext->toString(buff,255);
  CAMsg::printMsg(LOG_INFO,"Try to connect to next Mix on %s ...\n",buff);
  SINT32 err = E_UNKNOWN;
  SINT32 errLast = E_SUCCESS;
  
  for(UINT32 i=0; i < 100; i++)
  {
#ifdef DYNAMIC_MIX
    if(m_bBreakNeeded != m_bReconfigured)
    {
      CAMsg::printMsg(LOG_DEBUG, "CAFirstMix::connectToNextMix - Broken the connect loop!\n");
      break;
    }
#endif
    err = m_pMuxOut->connect(*a_pAddrNext);
    if(err != E_SUCCESS)
    {
      err=GET_NET_ERROR;
      
      if(err!=ERR_INTERN_TIMEDOUT&&err!=ERR_INTERN_CONNREFUSED)
      {
        CAMsg::printMsg(LOG_ERR, "Cannot connect to next Mix on %s. Reason: %s (%i)\n",
          buff, GET_NET_ERROR_STR(err), err);
        break;
      }
        
      if (errLast != err || i % 10 == 0)
      {
        CAMsg::printMsg(LOG_ERR, "Cannot connect to next Mix on %s. Reason: %s (%i). Retrying...\n",
          buff, GET_NET_ERROR_STR(err), err);
        errLast = err;
      }
      else
      {
#ifdef _DEBUG
        CAMsg::printMsg(LOG_DEBUG,"Cannot connect... retrying\n");
#endif
      }
      sSleep(10);
    }
    else
    {
      break;
    }
  }
  return err;
}

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

Here is the call graph for this function:

Here is the caller graph for this function:

decNewConnections()

void CAFirstMix::decNewConnections ( )

inlineprivate

Definition at line 578 of file CAFirstMix.hpp.

    {
      m_pmutexNewConnections->lock();
      m_newConnections--;
      m_pmutexNewConnections->unlock();
    }

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

Here is the call graph for this function:

decUsers()

SINT32 CAFirstMix::decUsers ( LP_fmHashTableEntry  pHashEntry )

inlineprotected

Definition at line 415 of file CAFirstMix.hpp.

        {
          m_pmutexUser->lock();
          m_nUser--;
          #ifdef COUNTRY_STATS
            updateCountryStats(NULL,pHashEntry->countryID,true);
          #endif
          m_pmutexUser->unlock();
          return E_SUCCESS;
        }

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

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

Here is the call graph for this function:

Here is the caller graph for this function:

deleteCountryStats()

SINT32 CAFirstMix::deleteCountryStats ( )

protected

Definition at line 2979 of file CAFirstMix.cpp.

  {
    m_bRunLogCountries=false;
    if(m_threadLogLoop!=NULL)
      {
        m_threadLogLoop->join();
        delete m_threadLogLoop;
        m_threadLogLoop=NULL;
      }
    if(m_mysqlCon!=NULL)
      {
        mysql_thread_end();
        mysql_close(m_mysqlCon);
        m_mysqlCon=NULL;
      }
 
    delete[] m_CountryStats;
    m_CountryStats=NULL;
 
    delete[] m_PacketsPerCountryIN;
    m_PacketsPerCountryIN=NULL;
 
    delete[] m_PacketsPerCountryOUT;
    m_PacketsPerCountryOUT=NULL;
    return E_SUCCESS;
  }

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

Referenced by clean().

Here is the call graph for this function:

Here is the caller graph for this function:

doUserLogin()

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

protected

Definition at line 1742 of file CAFirstMix.cpp.

{
  INIT_STACK;
  SINT32 ret = doUserLogin_internal(pNewUser, peerIP);
  FINISH_STACK("CAFirstMix::doUserLogin");
  return ret;
}

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

Here is the call graph for this function:

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

Definition at line 1755 of file CAFirstMix.cpp.

  {
    SINT32 ret;
  
    INIT_STACK;
    BEGIN_STACK("CAFirstMix::doUserLogin");
 
#ifdef __BUILD_AS_SHADOW_PLUGIN__ //the shadow simulator seems to love non-blocking I/O...
    pNewUser->getCASocket()->setNonBlocking(true);
#endif
 
    ret=pNewUser->getCASocket()->setKeepAlive(true);
    if(ret!=E_SUCCESS)
      CAMsg::printMsg(LOG_DEBUG,"Error setting KeepAlive for user login connection!");
 
    #ifdef DEBUG
      CAMsg::printMsg(LOG_DEBUG,"User login: start\n");
    #endif
 
    SAVE_STACK("CAFirstMix::doUserLogin", "after setting keep alive");
 
    // send the mix-keys to JAP
    if ((ret = pNewUser->getCASocket()->sendFullyTimeOut(m_xmlKeyInfoBuff,m_xmlKeyInfoSize, 40000, 10000)) != E_SUCCESS)
    {
      if (ret != E_UNKNOWN)
      {
        CAMsg::printMsg(LOG_DEBUG,"User login: Sending login data to client %u.%u.x.x has been interrupted! Reason: '%s' (%i)\n", 
          peerIP[0],peerIP[1], GET_NET_ERROR_STR(GET_NET_ERROR), GET_NET_ERROR);
      }
      else
      {
        CAMsg::printMsg(LOG_DEBUG,"User login: Sending login data to client %u.%u.x.x has been interrupted!\n", peerIP[0],peerIP[1]);
      }
 
      m_pIPBlockList->insertIP(peerIP);
 
      delete pNewUser;
      pNewUser = NULL;
      m_pIPList->removeIP(peerIP);
      return E_UNKNOWN;
    }
    #ifdef DEBUG
      CAMsg::printMsg(LOG_DEBUG,"User login: login data sent\n");
    #endif
    SAVE_STACK("CAFirstMix::doUserLogin", "after sending login data");
 
    //(pNewUser)->send(m_xmlKeyInfoBuff,m_xmlKeyInfoSize);
    // es kann nicht blockieren unter der Annahme das der TCP-Sendbuffer > m_xmlKeyInfoSize ist....
 
    //wait for keys from user
    UINT16 xml_len=0;
    if(pNewUser->getCASocket()->isClosed())
    {
      CAMsg::printMsg(LOG_DEBUG,"User login: Socket was closed while waiting for first symmetric key from client!\n");
    }
    else if ((ret = pNewUser->getCASocket()->receiveFullyT((UINT8*)&xml_len,2,FIRST_MIX_RECEIVE_SYM_KEY_FROM_JAP_TIME_OUT)) != E_SUCCESS)
    {
      if (ret != E_UNKNOWN)
      {
        CAMsg::printMsg(LOG_DEBUG,"User login: Waiting for first symmetric key from client %u.%u.x.x! failed for reason: '%s' (%i)\n", 
        peerIP[0], peerIP[1], GET_NET_ERROR_STR(GET_NET_ERROR), GET_NET_ERROR);
      }
      else
      {
        CAMsg::printMsg(LOG_DEBUG,"User login: Waiting for first symmetric key from client %u.%u.x.x! failed.\n", 
          peerIP[0], peerIP[1]);
      }
      m_pIPBlockList->insertIP(peerIP);
      
      delete pNewUser;
      pNewUser = NULL;
      m_pIPList->removeIP(peerIP);
      return E_UNKNOWN;
    }
    #ifdef DEBUG
      CAMsg::printMsg(LOG_DEBUG,"User login: received first symmetric key from client\n");
    #endif
    SAVE_STACK("CAFirstMix::doUserLogin", "received first symmetric key");
 
    xml_len=ntohs(xml_len);
    UINT8* xml_buff=new UINT8[xml_len+2]; //+2 for size...
    if(pNewUser->getCASocket()->isClosed() ||
       (ret = pNewUser->getCASocket()->receiveFullyT(xml_buff+2,xml_len,FIRST_MIX_RECEIVE_SYM_KEY_FROM_JAP_TIME_OUT)) !=E_SUCCESS)
    {
      if (pNewUser->getCASocket()->isClosed())
      {
        SET_NET_ERROR(E_SOCKETCLOSED);
      }
    
 
      if (ret != E_UNKNOWN)
      {
        CAMsg::printMsg(LOG_DEBUG,"User login: Waiting for second symmetric key from client failed for reason: '%s' (%i)\n", 
          GET_NET_ERROR_STR(GET_NET_ERROR), GET_NET_ERROR);
      }
      else
      {
        CAMsg::printMsg(LOG_DEBUG,"User login: Waiting for second symmetric key from client failed.\n");
      }
 
      m_pIPBlockList->insertIP(peerIP);
 
      delete pNewUser;
      pNewUser = NULL;
      delete[] xml_buff;
      xml_buff = NULL;
      m_pIPList->removeIP(peerIP);
      return E_UNKNOWN;
    }
 
    #ifdef DEBUG
      CAMsg::printMsg(LOG_DEBUG,"User login: received second symmetric key from client\n");
    #endif
    SAVE_STACK("CAFirstMix::doUserLogin", "received second symmetric key");
 
    XERCES_CPP_NAMESPACE::DOMDocument* doc=parseDOMDocument(xml_buff+2,xml_len);
    DOMElement* elemRoot=NULL;
    if(doc==NULL||(elemRoot=doc->getDocumentElement())==NULL||
      decryptXMLElement(elemRoot,m_pRSA)!=E_SUCCESS)
      {
        delete[] xml_buff;
        xml_buff = NULL;
        delete pNewUser;
        pNewUser = NULL;
        m_pIPList->removeIP(peerIP);
        if(doc!=NULL)
        {
          doc->release();
          doc = NULL;
        }
        return E_UNKNOWN;
      }
    elemRoot=doc->getDocumentElement();
    if(!equals(elemRoot->getNodeName(),"JAPKeyExchange"))
      {
        if (doc != NULL)
        {
          doc->release();
          doc = NULL;
        }
        delete[] xml_buff;
        xml_buff = NULL;
        delete pNewUser;
        pNewUser = NULL;
        m_pIPList->removeIP(peerIP);
        return E_UNKNOWN;
      }
    DOMElement* elemLinkEnc=NULL;
    DOMElement* elemMixEnc=NULL;
    getDOMChildByName(elemRoot,"LinkEncryption",elemLinkEnc,false);
    getDOMChildByName(elemRoot,"MixEncryption",elemMixEnc,false);
    UINT8 linkKey[255],mixKey[255];
    UINT32 linkKeyLen=255,mixKeyLen=255;
    if( getDOMElementValue(elemLinkEnc,linkKey,&linkKeyLen)!=E_SUCCESS||
        getDOMElementValue(elemMixEnc,mixKey,&mixKeyLen)!=E_SUCCESS||
        CABase64::decode(linkKey,linkKeyLen,linkKey,&linkKeyLen)!=E_SUCCESS||
        CABase64::decode(mixKey,mixKeyLen,mixKey,&mixKeyLen)!=E_SUCCESS||
        linkKeyLen!=64||mixKeyLen!=32)
      {
        if (doc != NULL)
        {
          doc->release();
          doc = NULL;
        }
        delete[] xml_buff;
        xml_buff = NULL;
        delete pNewUser;
        pNewUser = NULL;
        m_pIPList->removeIP(peerIP);
        return E_UNKNOWN;
      }
    //Check access control credential if access control is enabled...
    if (CALibProxytest::getOptions()->isAccessControlEnabled())
      {
        DOMElement* elemCredential = NULL;
        UINT8 buffUserCredential[255], buffMixCredential[255];
        UINT32 lenUserCredential = 255, lenMixCredential = 255;
        getDOMChildByName(elemRoot, "AccessControlCredential", elemCredential, false);
        if(getDOMElementValue(elemCredential, buffUserCredential, &lenUserCredential)!=E_SUCCESS ||
          CALibProxytest::getOptions()->getAccessControlCredential(buffMixCredential, &lenMixCredential)!=E_SUCCESS ||
           lenUserCredential!= lenMixCredential || 
           memcmp(buffMixCredential, buffUserCredential, lenMixCredential)!=0)
          {
          if (doc != NULL)
            {
            doc->release();
            doc = NULL;
            }
          delete[] xml_buff;
          xml_buff = NULL;
          delete pNewUser;
          pNewUser = NULL;
          m_pIPList->removeIP(peerIP);
          return E_UNKNOWN;
          }
      }
 
 
    //Getting control channel keys if available
    DOMElement* elemControlChannelEnc=NULL;
    getDOMChildByName(elemRoot,"ControlChannelEncryption",elemControlChannelEnc,false);
    UINT8 controlchannelKey[255];
    UINT32 controlchannelKeyLen=255;
    UINT8* controlchannelRecvKey=NULL;
    UINT8* controlchannelSentKey=NULL;
    if( getDOMElementValue(elemControlChannelEnc,controlchannelKey,&controlchannelKeyLen)==E_SUCCESS&&
        CABase64::decode(controlchannelKey,controlchannelKeyLen,controlchannelKey,&controlchannelKeyLen)==E_SUCCESS&&
        controlchannelKeyLen==32)
      {
        controlchannelRecvKey=controlchannelKey;
        controlchannelSentKey=controlchannelKey+16;
      }
 
    //Sending Signature....
    xml_buff[0]=(UINT8)(xml_len>>8);
    xml_buff[1]=(UINT8)(xml_len&0xFF);
    UINT8* sig=new UINT8[255];
    UINT32 siglen=255;
    //TODO change me to fully support MultiSig
    //m_pSignature->sign(xml_buff,xml_len+2,sig,&siglen);
    m_pMultiSignature->sign(xml_buff,xml_len+2,sig,&siglen);
    XERCES_CPP_NAMESPACE::DOMDocument* docSig=createDOMDocument();
 
    DOMElement *elemSig=NULL;
 
#ifdef LOG_DIALOG
    DOMElement* elemDialog=NULL;
    getDOMChildByName(elemRoot,"Dialog",elemDialog,false);
    UINT8 strDialog[255];
    memset(strDialog,0,255);
    UINT32 dialogLen=255;
    getDOMElementValue(elemDialog,strDialog,&dialogLen);
#endif
#ifdef REPLAY_DETECTION
    //checking if Replay-Detection is enabled
    DOMElement *elemReplay=NULL;
    UINT8 replay[6];
    UINT32 replay_len=5;
    if( (getDOMChildByName(elemRoot,"ReplayDetection",elemReplay,false)==E_SUCCESS)&&
      (getDOMElementValue(elemReplay,replay,&replay_len)==E_SUCCESS)&&
      (strncmp((char*)replay,"true",5)==0)){
        elemRoot=createDOMElement(docSig,"MixExchange");
        elemReplay=createDOMElement(docSig,"Replay");
        docSig->appendChild(elemRoot);
        elemRoot->appendChild(elemReplay);
 
        UINT32 diff=(UINT32)(time(NULL)-m_u64LastTimestampReceived);
        for(SINT32 i=0;i<getMixCount()-1;i++)
        {
          DOMElement* elemMix=createDOMElement(docSig,"Mix");
          setDOMElementAttribute(elemMix,"id",m_arMixParameters[i].m_strMixID);
          DOMElement* elemReplayOffset=createDOMElement(docSig,"ReplayOffset");
          setDOMElementValue(elemReplayOffset,(UINT32) (m_arMixParameters[i].m_u32ReplayOffset+diff));
          elemMix->appendChild(elemReplayOffset);
          DOMElement* elemReplayBase=createDOMElement(docSig,"ReplayBase");
          setDOMElementValue(elemReplayBase,(UINT32) (m_arMixParameters[i].m_u32ReplayBase));
          elemMix->appendChild(elemReplayBase);
          elemReplay->appendChild(elemMix);
        }
 
        DOMElement* elemMix=createDOMElement(docSig,"Mix");
        UINT8 buff[255];
        CALibProxytest::getOptions()->getMixId(buff,255);
        setDOMElementAttribute(elemMix,"id",buff);
        DOMElement* elemReplayOffset=createDOMElement(docSig,"ReplayOffset");
        setDOMElementValue(elemReplayOffset,(UINT32) (time(NULL)-m_u64ReferenceTime));
        elemMix->appendChild(elemReplayOffset);
        DOMElement* elemReplayBase=createDOMElement(docSig,"ReplayBase");
        setDOMElementValue(elemReplayBase,(UINT32) (REPLAY_BASE));
        elemMix->appendChild(elemReplayOffset);
        elemReplay->appendChild(elemMix);
 
        elemSig=createDOMElement(docSig,"Signature");
        elemRoot->appendChild(elemSig);
 
        CAMsg::printMsg(LOG_DEBUG,"Replay Detection requested\n");
        }
    else {
        elemSig=createDOMElement(docSig,"Signature");
        docSig->appendChild(elemSig);
      }
#endif
#ifndef REPLAY_DETECTION
    elemSig=createDOMElement(docSig,"Signature");
    docSig->appendChild(elemSig);
#endif
    DOMElement* elemSigValue=createDOMElement(docSig,"SignatureValue");
    elemSig->appendChild(elemSigValue);
    UINT32 u32=siglen;
    CABase64::encode(sig,u32,sig,&siglen);
    sig[siglen]=0;
    setDOMElementValue(elemSigValue,sig);
    delete[] sig;
    u32=xml_len;
    DOM_Output::dumpToMem(docSig,xml_buff+2,&u32);
    if (docSig != NULL)
    {
      docSig->release();
      docSig = NULL;
    }
    xml_buff[0]=(UINT8)(u32>>8);
    xml_buff[1]=(UINT8)(u32&0xFF);
 
    if (pNewUser->getCASocket()->isClosed() ||
        pNewUser->getCASocket()->sendFullyTimeOut(xml_buff,u32+2, 30000, 10000) != E_SUCCESS)
    {
      if (doc != NULL)
      {
        doc->release();
        doc = NULL;
      }
      CAMsg::printMsg(LOG_DEBUG,"User login: Sending key exchange signature has been interrupted!\n");
      m_pIPBlockList->insertIP(peerIP);
      
      delete[] xml_buff;
      xml_buff = NULL;
      delete pNewUser;
      pNewUser = NULL;
      m_pIPList->removeIP(peerIP);
      return E_UNKNOWN;
    }
    #ifdef DEBUG
      CAMsg::printMsg(LOG_DEBUG,"User login: key exchange signature sent\n");
    #endif
    delete[] xml_buff;
    xml_buff = NULL;
#if 0 //terms and conditions sending disabled.
    /* handle Terms And Conditions */
    bool loginFailed = false;
    bool tcProcedureFinished = false;
 
    while( !(tcProcedureFinished || loginFailed) )
    {
      UINT16 tcRequestDataLen = 0;
      if (pNewUser->getCASocket()->isClosed() ||
        (ret = pNewUser->getCASocket()->receiveFullyT((UINT8*)&tcRequestDataLen, 2, 10000)) != E_SUCCESS)
      {
        if (pNewUser->getCASocket()->isClosed())
        {
          SET_NET_ERROR(E_SOCKETCLOSED);
        }
      
        loginFailed = true;
        if (ret != E_UNKNOWN)
        {
          CAMsg::printMsg(LOG_ERR,"User login: Receiving t&c protocol data size has been interrupted. Reason: '%s' (%i)\n",
            GET_NET_ERROR_STR(GET_NET_ERROR), GET_NET_ERROR);
        }
        else
        {
          CAMsg::printMsg(LOG_ERR,"User login: Receiving t&c protocol data size has been interrupted.\n");
        }
        break;
      }
 
      tcRequestDataLen = ntohs(tcRequestDataLen);
      //CAMsg::printMsg(LOG_DEBUG,"User login: expecting %u bytes!\n", tcRequestDataLen);
      UINT8 tcDataBuf[tcRequestDataLen+1];
      tcDataBuf[tcRequestDataLen] = 0;
      if (pNewUser->getCASocket()->isClosed() ||
        (ret = pNewUser->getCASocket()->receiveFullyT(tcDataBuf, tcRequestDataLen, 10000)) != E_SUCCESS)
      {
        if (pNewUser->getCASocket()->isClosed())
        {
          SET_NET_ERROR(E_SOCKETCLOSED);
        }
        
        loginFailed = true;
        
        if (ret != E_UNKNOWN)
        {
          CAMsg::printMsg(LOG_ERR,"User login: Receiving t&c protocol data has been interrupted. Reason: '%s' (%i)\n",
            GET_NET_ERROR_STR(GET_NET_ERROR), GET_NET_ERROR);
        }
        else
        {
          CAMsg::printMsg(LOG_ERR,"User login: Receiving t&c protocol data has been interrupted.\n");
        }
        break;
      }
 
      XERCES_CPP_NAMESPACE::DOMDocument *tcData = parseDOMDocument(tcDataBuf, tcRequestDataLen);
      if( (tcData == NULL) || (tcData->getDocumentElement() == NULL) )
      {
        CAMsg::printMsg(LOG_ERR,"Could not parse t&c data!\n");
        loginFailed = true;
        break;
      }
 
      termsAndConditionMixAnswer_t *answer = handleTermsAndConditionsLogin(tcData);
      if(answer == NULL)
      {
        loginFailed = true;
        tcData->release();
        tcData = NULL;
        break;
      }
 
      if( (answer->xmlAnswer != NULL) )
      {
        UINT32 size = 0;
        UINT8 *answerBuff = DOM_Output::dumpToMem(answer->xmlAnswer, &size);
        if(answerBuff != NULL)
        {
          //CAMsg::printMsg(LOG_DEBUG,"User login: answer %s\n", answerBuff);
 
          UINT32 netSize = htonl(size);
 
          if (pNewUser->getCASocket()->isClosed() ||
            pNewUser->getCASocket()->sendFullyTimeOut((UINT8 *) &netSize, 4, 30000, 10000) != E_SUCCESS)
          {
            CAMsg::printMsg(LOG_DEBUG,"User login: sending t&c protocol data size has been interrupted!\n");
            loginFailed = true;
          }
          else if (pNewUser->getCASocket()->isClosed() ||
            pNewUser->getCASocket()->sendFullyTimeOut(answerBuff, size, 30000, 10000) != E_SUCCESS)
          {
            CAMsg::printMsg(LOG_DEBUG,"User login: Sending t&c protocol data has been interrupted!\n");
            loginFailed = true;
          }
          delete [] answerBuff;
        }
      }
      tcProcedureFinished = (answer->result != TC_UNFINISHED);
      loginFailed = (answer->result == TC_FAILED);
      cleanupTnCMixAnswer(answer);
      delete answer;
      answer = NULL;
      tcData->release();
      tcData = NULL;
    }
 
    //Only if a positive confirm message was received, the client may pass!
 
    if(loginFailed)
    {
      if (doc != NULL)
      {
        doc->release();
        doc = NULL;
      }
      CAMsg::printMsg(LOG_DEBUG,"User login: failed!\n");
      delete[] xml_buff;
      xml_buff = NULL;
      delete pNewUser;
      pNewUser = NULL;
      m_pIPList->removeIP(peerIP);
      return E_UNKNOWN;
    }
    /* end Terms And Conditions negotiation */
#endif
    SAVE_STACK("CAFirstMix::doUserLogin", "sent key exchange signature");
 
    pNewUser->getCASocket()->setNonBlocking(true);
 
    SAVE_STACK("CAFirstMix::doUserLogin", "Creating CAQueue...");
    CAQueue* tmpQueue=new CAQueue(sizeof(tQueueEntry));
 
    SAVE_STACK("CAFirstMix::doUserLogin", "Adding user to connection list...");
#ifdef LOG_DIALOG
    fmHashTableEntry* pHashEntry=m_pChannelList->add(pNewUser,peerIP,tmpQueue,strDialog);
#else
#ifndef MULTI_THREADED_PACKET_PROCESSING
    fmHashTableEntry* pHashEntry=m_pChannelList->add(pNewUser,peerIP,tmpQueue,controlchannelSentKey,controlchannelRecvKey);
#else
    UINT32 threadID = pNewUser->getHashKey()%m_numThreads;
    CAFirstMixChannelList* pChannelList = m_arpChannelList[threadID];
    fmHashTableEntry* pHashEntry=pChannelList->add(pNewUser,peerIP,tmpQueue,controlchannelSentKey,controlchannelRecvKey);
#endif
#endif
    if( (pHashEntry == NULL) ||
      (pHashEntry->pControlMessageQueue == NULL) )// adding user connection to mix->JAP channel list (stefan: sollte das nicht connection list sein? --> es handelt sich um eine Datenstruktu fr Connections/Channels ).
    {
      if (doc != NULL)
      {
        doc->release();
        doc = NULL;
      }
      CAMsg::printMsg(LOG_ERR,"User login: Could not add new socket to connection list!\n");
      if (pHashEntry != NULL)
        {
#ifndef MULTI_THREADED_PACKET_PROCESSING
          m_pChannelList->remove(pNewUser);
#else
          pChannelList->remove(pNewUser);
#endif
        }
      m_pIPList->removeIP(peerIP);
      delete tmpQueue;
      tmpQueue = NULL;
      delete pNewUser;
      pNewUser = NULL;
      return E_UNKNOWN;
    }
 
    SAVE_STACK("CAFirstMix::doUserLogin", "socket added to connection list");
#ifdef PAYMENT
    #ifdef DEBUG
      CAMsg::printMsg(LOG_DEBUG,"User login: registering payment control channel\n");
    #endif
    pHashEntry->pControlChannelDispatcher->registerControlChannel(new CAAccountingControlChannel(pHashEntry));
    SAVE_STACK("CAFirstMix::doUserLogin", "payment registered");
#endif
    pHashEntry->pSymCipher=CASymChannelCipherFactory::createCipher(CALibProxytest::getOptions()->getSymChannelCipherAlgorithm());
    pHashEntry->pSymCipher->setKey(mixKey);
    pHashEntry->pSymCipher->setIVs(mixKey+16);
    pNewUser->setReceiveKey(linkKey,32);
    pNewUser->setSendKey(linkKey+32,32);
    pNewUser->setCrypt(true);
 
    if (doc != NULL)
    {
      doc->release();
      doc = NULL;
    }
#ifdef PAYMENT
 
    SAVE_STACK("CAFirstMix::doUserLogin", "Starting AI login procedure");
#ifdef DEBUG
    CAMsg::printMsg(LOG_DEBUG,"Starting AI login procedure for owner %x \n", pHashEntry);
#endif
    SINT32 ai_ret;
    MIXPACKET *paymentLoginPacket = new MIXPACKET;
    tQueueEntry *aiAnswerQueueEntry=new tQueueEntry;
    CAQueue *controlMessages = pHashEntry->pControlMessageQueue;
    UINT32 qlen=sizeof(tQueueEntry);
    SINT32 aiLoginStatus = 0;
    aiLoginStatus = CAAccountingInstance::loginProcessStatus(pHashEntry);
    while(aiLoginStatus & AUTH_LOGIN_NOT_FINISHED)
    {
      if(pNewUser->receive(paymentLoginPacket, AI_LOGIN_SO_TIMEOUT) != MIXPACKET_SIZE)
      {
        CAMsg::printMsg(LOG_INFO,"AI login: client receive timeout.\n");
        aiLoginStatus = AUTH_LOGIN_FAILED;
        break;
      }
      if(paymentLoginPacket->channel > 0 && paymentLoginPacket->channel < 256)
      {
        if(!pHashEntry->pControlChannelDispatcher->proccessMixPacket(paymentLoginPacket))
        {
          aiLoginStatus = AUTH_LOGIN_FAILED;
          break;
        }
 
        while(controlMessages->getSize()>0)
        {
          controlMessages->get((UINT8*)aiAnswerQueueEntry,&qlen);
          pNewUser->prepareForSend(&(aiAnswerQueueEntry->packet));
          ai_ret = pNewUser->getCASocket()->
            sendFullyTimeOut(((UINT8*)&(aiAnswerQueueEntry->packet)), MIXPACKET_SIZE, 3*(AI_LOGIN_SO_TIMEOUT), AI_LOGIN_SO_TIMEOUT);
          if (ai_ret != E_SUCCESS)
          {
            if(ai_ret == E_TIMEDOUT )
            {
              CAMsg::printMsg(LOG_INFO,"timeout occurred during AI login.");
            }
            aiLoginStatus = AUTH_LOGIN_FAILED;
            goto loop_break;
          }
        }
        if(aiLoginStatus == AUTH_LOGIN_FAILED)
        {
          break;
        }
      }
      aiLoginStatus = CAAccountingInstance::loginProcessStatus(pHashEntry);
    }
loop_break:
    SAVE_STACK("CAFirstMix::doUserLogin", "AI login packages exchanged.");
    /* We have exchanged all AI login packets:
     * 1. AccountCert
     * 2. ChallengeResponse
     * 3. Cost confirmation.
     * Now start settlement to ensure that the clients account is balanced
     */
    if(!(aiLoginStatus & AUTH_LOGIN_FAILED))
    {
      if(!(aiLoginStatus & (AUTH_LOGIN_SKIP_SETTLEMENT )) || (aiLoginStatus & (AUTH_WAITING_FOR_FIRST_SETTLED_CC)) )
      {
//#ifdef DEBUG
        CAMsg::printMsg(LOG_DEBUG,"AI login messages successfully exchanged: now starting settlement for user account balancing check\n");
//#endif
        if(CAAccountingInstance::newSettlementTransaction() != E_SUCCESS)
        {
          aiLoginStatus |= AUTH_LOGIN_FAILED;
        }
      }
//#ifdef DEBUG
      else
      {
        CAMsg::printMsg(LOG_DEBUG,"AI login messages successfully exchanged: skipping settlement, user has valid prepaid amount\n");
      }
//#endif
    }
 
    if(!(aiLoginStatus & AUTH_LOGIN_FAILED))
    {
      aiLoginStatus = CAAccountingInstance::finishLoginProcess(pHashEntry);
      if(pNewUser != NULL)
      {
        while(controlMessages->getSize()>0)
        {
          controlMessages->get((UINT8*)aiAnswerQueueEntry,&qlen);
          pNewUser->prepareForSend(&(aiAnswerQueueEntry->packet));
 
          //not really elegant but works: if the client closed the socket during the settlement
          //the first send will succeed but the second one will fail.
          ai_ret = pNewUser->getCASocket()->
              sendFullyTimeOut(((UINT8*)&(aiAnswerQueueEntry->packet)), 499, 3*(AI_LOGIN_SO_TIMEOUT), AI_LOGIN_SO_TIMEOUT);
 
          ai_ret =  pNewUser->getCASocket()->
              sendFullyTimeOut(((UINT8*)&(aiAnswerQueueEntry->packet)+499), 499, 3*(AI_LOGIN_SO_TIMEOUT), AI_LOGIN_SO_TIMEOUT);
          if (ai_ret != E_SUCCESS)
          {
            int errnum = errno;
            CAMsg::printMsg(LOG_INFO,"AI login: net error occured after settling: %s\n", strerror(errnum));
            aiLoginStatus |= AUTH_LOGIN_FAILED;
            break;
          }
        }
      }
      else
      {
        CAMsg::printMsg(LOG_DEBUG,"Socket was disposed.\n");
        aiLoginStatus |= AUTH_LOGIN_FAILED;
      }
    }
 
    delete paymentLoginPacket;
    paymentLoginPacket = NULL;
    delete aiAnswerQueueEntry;
    aiAnswerQueueEntry = NULL;
 
    SAVE_STACK("CAFirstMix::doUserLogin", "AI login procedure finished.");
 
    if((aiLoginStatus & AUTH_LOGIN_FAILED))
    {
#ifdef DEBUG
      CAMsg::printMsg(LOG_INFO,"User AI login failed: deleting socket %x\n", pHashEntry);
#endif
      CAAccountingInstance::unlockLogin(pHashEntry);
      m_pChannelList->remove(pNewUser);
      delete pNewUser;
      pNewUser = NULL;
      m_pIPList->removeIP(peerIP);
      return E_UNKNOWN;
    }
    /* Hot fix: push timeout entry only if login was succesful, otherwise
     * socket may be deleted due to timeout, login fails and the socket will be deleted
     * for second time causing a segfault.
     */
    m_pChannelList->pushTimeoutEntry(pHashEntry);
    
    
#ifdef LOG_CRIME
    UINT64 accountNumber = CAAccountingInstance::unlockLogin(pHashEntry);
    UINT64* surveillanceAccounts = CALibProxytest::getOptions()->getCrimeSurveillanceAccounts();
    UINT32 nrOfSurveillanceAccounts = CALibProxytest::getOptions()->getNrOfCrimeSurveillanceAccounts();
    
    for (UINT32 iAccount = 0; iAccount < nrOfSurveillanceAccounts; iAccount++)
    {
      if (accountNumber == surveillanceAccounts[iAccount])
      {
        CAMsg::printMsg(LOG_CRIT,"Crime detection: User logged in with account %llu has IP %u.%u.%u.%u\n",accountNumber, peerIP[0], peerIP[1], peerIP[2], peerIP[3]);
        break;
      }
    }
#else
    CAAccountingInstance::unlockLogin(pHashEntry);
#endif
    
#ifdef DEBUG
    CAMsg::printMsg(LOG_INFO,"User AI login successful for owner %x\n", pHashEntry);
#endif
#endif
 
#ifdef WITH_CONTROL_CHANNELS_TEST
    pHashEntry->pControlChannelDispatcher->registerControlChannel(new CAControlChannelTest());
#endif
#ifdef REPLAY_DETECTION
    pHashEntry->pControlChannelDispatcher->registerControlChannel(new CAReplayControlChannel(m_pReplayMsgProc));
#endif
#ifdef COUNTRY_STATS
    incUsers(pHashEntry);
#else
    incUsers();
#endif
#ifdef HAVE_EPOLL
#ifndef MULTI_THREADED_PACKET_PROCESSING
    m_psocketgroupUsersRead->add(*pNewUser,m_pChannelList->get(pNewUser)); // add user socket to the established ones that we read data from.
    m_psocketgroupUsersWrite->add(*pNewUser,m_pChannelList->get(pNewUser));
#else
    m_arpsocketgroupUsersRead[threadID]->add(*pNewUser,pChannelList->get(pNewUser)); // add user socket to the established ones that we read data from.
    m_arpsocketgroupUsersWrite[threadID]->add(*pNewUser,pChannelList->get(pNewUser));
#endif
#else //no E_POLL
#ifndef MULTI_THREADED_PACKET_PROCESSING
    if(m_psocketgroupUsersRead->add(*pNewUser)!=E_SUCCESS)// add user socket to the established ones that we read data from.
    {
      CAMsg::printMsg(LOG_DEBUG,"User login: Adding to m_psocketgroupUsersRead failed!\n");
    }
    if( m_psocketgroupUsersWrite->add(*pNewUser)!=E_SUCCESS)
    {
      CAMsg::printMsg(LOG_DEBUG,"User login: Adding to m_psocketgroupUsersWrite failed!\n");
    }
#else
    if(m_arpsocketgroupUsersRead[threadID]->add(*pNewUser)!=E_SUCCESS)// add user socket to the established ones that we read data from.
    {
      CAMsg::printMsg(LOG_DEBUG,"User login: Adding to m_psocketgroupUsersRead failed!\n");
    }
    if( m_arpsocketgroupUsersWrite[threadID]->add(*pNewUser)!=E_SUCCESS)
    {
      CAMsg::printMsg(LOG_DEBUG,"User login: Adding to m_psocketgroupUsersWrite failed!\n");
    }
#endif
#endif
 
#ifndef LOG_DIALOG
    CAMsg::printMsg(LOG_INFO,"User login: finished\n");
#else
    CAMsg::printMsg(LOG_INFO,"User login: finished -- connection-ID: %Lu -- country-id: %u -- dialog: %s\n",pHashEntry->id,pHashEntry->countryID,pHashEntry->strDialog);
#endif
    return E_SUCCESS;
  }

References 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(), 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, CAQueue::get(), GET_NET_ERROR, GET_NET_ERROR_STR, CAMuxSocket::getCASocket(), getDOMChildByName(), getDOMElementValue(), CAMuxSocket::getHashKey(), getMixCount(), CACmdLnOptions::getMixId(), CALibProxytest::getOptions(), CAQueue::getSize(), handleTermsAndConditionsLogin(), INIT_STACK, CATempIPBlockList::insertIP(), CASocket::isClosed(), CAAccountingInstance::loginProcessStatus(), m_arMixParameters, m_pChannelList, m_pIPBlockList, m_pIPList, CAMix::m_pMultiSignature, m_pRSA, 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, 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(), TC_FAILED, TC_UNFINISHED, and termsAndConditionMixAnswer_t::xmlAnswer.

Referenced by doUserLogin().

Here is the call graph for this function:

Here is the caller graph for this function:

forceKickout()

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

Definition at line 2482 of file CAFirstMix.cpp.

{
  return m_pChannelList->forceKickout(pHashTableEntry, pErrDoc);
}

References CAFirstMixChannelList::forceKickout(), and m_pChannelList.

Referenced by CAAccountingInstance::handleChallengeResponse_internal().

Here is the call graph for this function:

Here is the caller graph for this function:

getLevel()

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

Definition at line 2901 of file CAFirstMix.cpp.

{
  *puser=(SINT32)getNrOfUsers();
  *prisk=-1;
  *ptraffic=-1;
  return E_SUCCESS;
}

References E_SUCCESS, and getNrOfUsers().

Here is the call graph for this function:

getLoginMutex()

CAMutex* CAFirstMix::getLoginMutex ( )

inline

Definition at line 325 of file CAFirstMix.hpp.

      {
        return m_pmutexLogin;
      }

References m_pmutexLogin.

Referenced by CAAccountingInstance::handleChallengeResponse_internal().

Here is the caller graph for this function:

getMixCount()

SINT32 CAFirstMix::getMixCount ( )

inline

Definition at line 374 of file CAFirstMix.hpp.

      {
        return m_u32MixCount;
      }

References m_u32MixCount.

Referenced by doUserLogin_internal().

Here is the caller graph for this function:

getMixedPackets()

SINT32 CAFirstMix::getMixedPackets

(

UINT64 &

ppackets

)

Definition at line 2895 of file CAFirstMix.cpp.

{
  set64(ppackets,m_nMixedPackets);
  return E_SUCCESS;
}

References E_SUCCESS, m_nMixedPackets, and set64().

Here is the call graph for this function:

getMixParameters()

tMixParameters* CAFirstMix::getMixParameters ( )

inline

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

Definition at line 379 of file CAFirstMix.hpp.

      {
        return m_arMixParameters;
      }

References m_arMixParameters.

getNrOfUsers()

UINT32 CAFirstMix::getNrOfUsers

(

)

Definition at line 2886 of file CAFirstMix.cpp.

{
  #ifdef PAYMENT
  return CAAccountingInstance::getNrOfUsers();
  #else
  return m_nUser;
  #endif
}

References CAAccountingInstance::getNrOfUsers(), and m_nUser.

Referenced by getLevel().

Here is the call graph for this function:

Here is the caller graph for this function:

getTermsAndConditions()

TermsAndConditions * CAFirstMix::getTermsAndConditions

(

const UINT8 *

opSki

)

Definition at line 932 of file CAFirstMix.cpp.

{
  if( (m_tnCDefs == NULL) || (opSki == NULL) )
  {
    return NULL;
  }
  for(UINT32 i = 0; i < m_nrOfTermsAndConditionsDefs; i++)
  {
    if(m_tnCDefs[i] != NULL)
    {
      if(strncasecmp((char *) m_tnCDefs[i]->getID(),
              (const char *) opSki,
              strlen((char *) m_tnCDefs[i]->getID())) == 0)
      {
        return m_tnCDefs[i];
      }
    }
  }
  return NULL;
}

References m_nrOfTermsAndConditionsDefs, and m_tnCDefs.

Referenced by handleTermsAndConditionsLogin().

Here is the caller graph for this function:

getTermsAndConditionsTemplate()

DOMNode * CAFirstMix::getTermsAndConditionsTemplate

(

UINT8 *

templateRefID

)

Definition at line 953 of file CAFirstMix.cpp.

{
  UINT8 *currentRefId = NULL;
  bool match = false;
 
  for (UINT32 i = 0; i < m_nrOfTermsAndConditionsTemplates; i++)
  {
    currentRefId = getTermsAndConditionsTemplateRefId(m_tcTemplates[i]);
    match = (currentRefId != NULL) &&
         (strncmp((char *)templateRefID, (char *)currentRefId, TEMPLATE_REFID_MAXLEN ) == 0);
    delete [] currentRefId;
    currentRefId = NULL;
    if(match)
    {
      return m_tcTemplates[i];
    }
  }
  return NULL;
}

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

Referenced by handleTermsAndConditionsExtension().

Here is the call graph for this function:

Here is the caller graph for this function:

getType()

tMixType CAFirstMix::getType ( ) const

inlinevirtual

Implements CAMix.

Definition at line 319 of file CAFirstMix.hpp.

      {
        return CAMix::FIRST_MIX;
      }

References CAMix::FIRST_MIX.

handleKeyInfoExtensions()

SINT32 CAFirstMix::handleKeyInfoExtensions

(

DOMElement *

root

)

Definition at line 805 of file CAFirstMix.cpp.

{
  if(root == NULL)
  {
    return E_UNKNOWN;
  }
 
  SINT32 ret = E_SUCCESS;
  DOMElement *extensionRoot = NULL;
  getDOMChildByName(root, KEYINFO_NODE_EXTENSIONS, extensionRoot);
 
  if(extensionRoot != NULL)
  {
    extensionRoot = (DOMElement *) root->removeChild(extensionRoot);
    ret = handleTermsAndConditionsExtension(extensionRoot);
    extensionRoot->release();
  }
  return ret;
}

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

Here is the call graph for this function:

handleTermsAndConditionsExtension()

SINT32 CAFirstMix::handleTermsAndConditionsExtension

(

DOMElement *

extensionRoot

)

Definition at line 825 of file CAFirstMix.cpp.

{
  if(extensionsRoot == NULL)
  {
    return E_UNKNOWN;
  }
 
  DOMElement *tncDefs = NULL;
  DOMElement *tncTemplates = NULL;
  getDOMChildByName(extensionsRoot, KEYINFO_NODE_TNC_EXTENSION, tncDefs);
  if(tncDefs == NULL)
  {
    CAMsg::printMsg(LOG_CRIT,"No TNCs in TNC extension found.\n");
    return E_UNKNOWN;
  }
  getDOMChildByName(tncDefs, OPTIONS_NODE_TNCS_TEMPLATES, tncTemplates);
 
  UINT8 currentTnC_id[TMP_BUFF_SIZE];
  UINT32 currentTnC_id_len = TMP_BUFF_SIZE;
 
  UINT8 currentTnCEntry_templateRefid[TMP_BUFF_SIZE];
  UINT32 currentTnCEntry_templateRefid_len = TMP_BUFF_SIZE;
 
  UINT8 currentTnCEntry_locale[TMP_LOCALE_SIZE];
  UINT32 currentTnCEntry_locale_len = TMP_LOCALE_SIZE;
 
  DOMElement *currentTnCList = NULL;
  DOMElement *currentTnCEntry = NULL;
  memset(currentTnC_id, 0, TMP_BUFF_SIZE);
  memset(currentTnCEntry_templateRefid, 0, TMP_BUFF_SIZE);
 
  if(tncTemplates != NULL)
  {
    DOMNodeList *tncTemplateList = getElementsByTagName(tncDefs, TNC_TEMPLATE_ROOT_ELEMENT);
    m_nrOfTermsAndConditionsTemplates = tncTemplateList->getLength();
    CAMsg::printMsg(LOG_INFO, "Storing %u TC Templates.\n", m_nrOfTermsAndConditionsTemplates);
    if(m_nrOfTermsAndConditionsTemplates > 0)
    {
      m_tcTemplates = new DOMNode *[m_nrOfTermsAndConditionsTemplates];
      for (UINT32 i = 0; i < m_nrOfTermsAndConditionsTemplates; i++)
      {
        m_tcTemplates[i] = m_templatesOwner->importNode(tncTemplateList->item(i), true);
      }
    }
    else
    {
      CAMsg::printMsg(LOG_ERR, "Not a single TC Template specified! the Cascade is not properly configured.\n");
      return E_UNKNOWN;
    }
  }
  else
  {
    CAMsg::printMsg(LOG_ERR, "No TC Template node found! Cascade is not properly configured.\n");
    return E_UNKNOWN;
  }
 
  DOMNodeList *tncDefList = getElementsByTagName(tncDefs, OPTIONS_NODE_TNCS);
  if(tncDefList->getLength() == 0)
  {
    CAMsg::printMsg(LOG_CRIT, "No TNCs definitions found.\n");
    return E_UNKNOWN;
  }
 
  m_nrOfTermsAndConditionsDefs = tncDefList->getLength();
  m_tnCDefs = new TermsAndConditions *[m_nrOfTermsAndConditionsDefs];
  memset(m_tnCDefs, 0, (sizeof(TermsAndConditions*)*m_nrOfTermsAndConditionsDefs) );
 
  for (UINT32 i = 0; i < m_nrOfTermsAndConditionsDefs; i++)
  {
    currentTnCList = (DOMElement *) tncDefList->item(i);
    DOMNodeList *tncDefEntryList = getElementsByTagName(currentTnCList, OPTIONS_NODE_TNCS_TRANSLATION);
    getDOMElementAttribute(currentTnCList, OPTIONS_ATTRIBUTE_TNC_ID, currentTnC_id, &currentTnC_id_len);
 
    m_tnCDefs[i] = new TermsAndConditions(currentTnC_id, tncDefEntryList->getLength());
 
    for (XMLSize_t j = 0; j < tncDefEntryList->getLength(); j++)
    {
      currentTnCEntry = (DOMElement *) tncDefEntryList->item(j);
 
      getDOMElementAttribute(currentTnCEntry, OPTIONS_ATTRIBUTE_TNC_TEMPLATE_REFID,
          currentTnCEntry_templateRefid, &currentTnCEntry_templateRefid_len);
      getDOMElementAttribute(currentTnCEntry, OPTIONS_ATTRIBUTE_TNC_LOCALE,
          currentTnCEntry_locale, &currentTnCEntry_locale_len);
 
      DOMNode *templateNode = getTermsAndConditionsTemplate(currentTnCEntry_templateRefid);
      if(templateNode != NULL)
      {
        //m_tnCDefs[i]->synchLock->lock();
        m_tnCDefs[i]->addTranslation(currentTnCEntry_locale, currentTnCEntry, templateNode);
        //m_tnCDefs[i]->synchLock->unlock();
      }
      else
      {
        CAMsg::printMsg(LOG_CRIT,"Could not find template %s for T&C %s.\n", currentTnCEntry_templateRefid, currentTnC_id);
        return E_UNKNOWN;
      }
      memset(currentTnCEntry_templateRefid, 0, TMP_BUFF_SIZE);
      currentTnCEntry_templateRefid_len = TMP_BUFF_SIZE;
      memset(currentTnCEntry_locale, 0, TMP_LOCALE_SIZE);
      currentTnCEntry_locale_len = TMP_LOCALE_SIZE;
    }
    memset(currentTnC_id, 0, TMP_BUFF_SIZE);
    currentTnC_id_len = TMP_BUFF_SIZE;
  }
  return E_SUCCESS;
}

References TermsAndConditions::addTranslation(), E_SUCCESS, E_UNKNOWN, getDOMChildByName(), getDOMElementAttribute(), getElementsByTagName(), getTermsAndConditionsTemplate(), KEYINFO_NODE_TNC_EXTENSION, m_nrOfTermsAndConditionsDefs, m_nrOfTermsAndConditionsTemplates, m_tcTemplates, m_templatesOwner, m_tnCDefs, OPTIONS_ATTRIBUTE_TNC_ID, OPTIONS_ATTRIBUTE_TNC_LOCALE, OPTIONS_ATTRIBUTE_TNC_TEMPLATE_REFID, OPTIONS_NODE_TNCS, OPTIONS_NODE_TNCS_TEMPLATES, OPTIONS_NODE_TNCS_TRANSLATION, CAMsg::printMsg(), TMP_BUFF_SIZE, TMP_LOCALE_SIZE, and TNC_TEMPLATE_ROOT_ELEMENT.

Referenced by handleKeyInfoExtensions().

Here is the call graph for this function:

Here is the caller graph for this function:

handleTermsAndConditionsLogin()

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

private

Definition at line 1573 of file CAFirstMix.cpp.

{
  termsAndConditionMixAnswer_t *answer =
    new termsAndConditionMixAnswer_t;
 
  const XMLCh* reqName = request->getDocumentElement()->getTagName();
 
  //Client requests lacking T&C resources.
  if(XMLString::equals(reqName, TNC_REQUEST))
  {
    answer->result = TC_UNFINISHED;
    CAMsg::printMsg(LOG_DEBUG,"Handling TC request.\n");
    XERCES_CPP_NAMESPACE::DOMDocument *response = createDOMDocument();
    DOMElement *responseRoot = createDOMElement(response, TNC_RESPONSE);
    response->appendChild(responseRoot);
    //All elements with tag name 'Resources' (direct children of 'TermsAndConditionsRequest')
    DOMNodeList *requestedResources = getElementsByTagName(request->getDocumentElement(), TNC_RESOURCES);
    //All elements with tag name 'Translation' (direct children of 'Resources')
    DOMNodeList *requestedResourceItems = NULL;
 
    DOMNode *currentNode = NULL;
    DOMNode *currentAnswerNode = NULL;
    DOMNode *currentAnswerResourceNode = NULL;
 
    UINT32 idLen = TMP_BUFF_SIZE;
    UINT8 id[TMP_BUFF_SIZE];
    memset(id, 0, idLen);
 
    UINT32 localeLen = TMP_LOCALE_SIZE;
    UINT8 locale[TMP_LOCALE_SIZE];
    memset(locale, 0, localeLen);
 
    bool resourceError = false;
 
    if(requestedResources->getLength() == 0)
    {
      response->release();
      response = createDOMDocument();
      response->appendChild(createDOMElement(response, TNC_RESPONSE_INVALID_REQUEST));
      answer->result = TC_FAILED;
    }
 
    for (XMLSize_t i = 0; i < requestedResources->getLength(); i++)
    {
      idLen = TMP_BUFF_SIZE;
      localeLen = TMP_LOCALE_SIZE;
      bool validResource = false;
 
      currentNode = requestedResources->item(i);
      //check validity of the T&C resource request. attributes "id" and locale must be proper set.
      if( (getDOMElementAttribute(currentNode, OPTIONS_ATTRIBUTE_TNC_ID, id, &idLen) != E_SUCCESS) ||
        (strlen((char *)id) < 1)  )
      {
        CAMsg::printMsg(LOG_DEBUG,"Error: invalid id.\n");
        resourceError = true;
      }
 
      if(!currentNode->hasChildNodes())
      {
        //Empty Resource node is invalid!
        CAMsg::printMsg(LOG_DEBUG,"Error: No children.\n");
        resourceError = true;
      }
 
      if(!resourceError)
      {
 
        TermsAndConditions *requestedTnC = getTermsAndConditions(id);
        if(requestedTnC != NULL)
        {
          requestedResourceItems = getElementsByTagName((DOMElement *)currentNode, TNC_REQ_TRANSLATION);
          for(XMLSize_t j = 0; j < requestedResourceItems->getLength(); j++)
          {
            validResource = false;
            localeLen = TMP_LOCALE_SIZE;
            if( (getDOMElementAttribute(requestedResourceItems->item(j),
                OPTIONS_ATTRIBUTE_TNC_LOCALE,
                locale, &localeLen) != E_SUCCESS) ||
              (strlen((char *)locale) != ((TMP_LOCALE_SIZE) - 1) ) )
            {
              CAMsg::printMsg(LOG_DEBUG,"Error: Invalid locale for tnc %s\n", id);
              break;
            }
 
            const termsAndConditionsTranslation_t *requestedTranslation =
                requestedTnC->getTranslation(locale);
            //NOTE: No need to lock while working with the TC translation
            //because the translation containers are only modified during
            //inter-mix-keyexchange and cleanup.
            //Both must never run concurrently to this method
            if(requestedTranslation != NULL)
            {
 
              currentAnswerNode = response->importNode(currentNode, false);
              responseRoot->appendChild(currentAnswerNode);
              if( getDOMChildByName(requestedResourceItems->item(j), TNC_RESOURCE_TEMPLATE,
                  currentAnswerResourceNode, false) == E_SUCCESS)
              {
                currentAnswerResourceNode = response->importNode(currentAnswerResourceNode, true);
                currentAnswerResourceNode->appendChild(
                    response->importNode(requestedTranslation->tnc_template, true));
                currentAnswerNode->appendChild(currentAnswerResourceNode);
                validResource = true;
              }
 
              if( getDOMChildByName(requestedResourceItems->item(j), TNC_RESOURCE_CUSTOMIZED_SECT,
                          currentAnswerResourceNode, false) == E_SUCCESS)
              {
                currentAnswerResourceNode = response->importNode(currentAnswerResourceNode, true);
                currentAnswerResourceNode->appendChild(
                    response->importNode(requestedTranslation->tnc_customized, true));
                currentAnswerNode->appendChild(currentAnswerResourceNode);
                validResource = true;
              }
            }
            else
            {
              CAMsg::printMsg(LOG_DEBUG,"Error: no translation def found.\n");
              break;
            }
          }
        }
        else
        {
          CAMsg::printMsg(LOG_DEBUG,"Error: no tc def found.\n");
        }
      }
 
      if(!validResource)
      {
        //only a manipulated client sends an invalid T&C resource request.
        //Manipulation is interpreted as a rejection of the terms & conditions,
        //so abort login immediately.
        response->release();
        response = createDOMDocument();
        response->appendChild(createDOMElement(response, TNC_RESPONSE_INVALID_REQUEST));
        answer->result = TC_FAILED;
        break;
      }
    }
    answer->xmlAnswer = response;
  }
  //Client accepts/rejects the T&Cs.
  else if(XMLString::equals(reqName, TNC_CONFIRM))
  {
    CAMsg::printMsg(LOG_DEBUG,"handling TC confirm.\n");
    bool tcAccepted = false;
    getDOMElementAttribute(request->getDocumentElement(), "accepted", tcAccepted);
    CAMsg::printMsg(LOG_DEBUG,"Client has%s accepted the T&Cs.\n", (tcAccepted ? "" : " not")  );
 
    answer->xmlAnswer = NULL;
    answer->result = tcAccepted ? TC_CONFIRMED : TC_FAILED;
  }
  //stops the message exchange (if client needs time for showing the T & Cs, etc.)
  else if(XMLString::equals(reqName, TNC_INTERRUPT))
  {
    CAMsg::printMsg(LOG_DEBUG,"client requested interrupting the tc login.\n");
    answer->xmlAnswer = NULL;
    answer->result = TC_FAILED;
  }
  //Client sends an invalid message
  else
  {
    answer->xmlAnswer = NULL; //TODO: set errorMessage here
    answer->result = TC_FAILED;
  }
  return answer;
}

References createDOMDocument(), createDOMElement(), E_SUCCESS, equals(), getDOMChildByName(), getDOMElementAttribute(), getElementsByTagName(), getTermsAndConditions(), TermsAndConditions::getTranslation(), OPTIONS_ATTRIBUTE_TNC_ID, OPTIONS_ATTRIBUTE_TNC_LOCALE, CAMsg::printMsg(), termsAndConditionMixAnswer_t::result, TC_CONFIRMED, TC_FAILED, TC_UNFINISHED, TMP_BUFF_SIZE, TMP_LOCALE_SIZE, TNC_CONFIRM, termsAndConditionsTranslation_t::tnc_customized, TNC_INTERRUPT, TNC_REQ_TRANSLATION, TNC_REQUEST, TNC_RESOURCE_CUSTOMIZED_SECT, TNC_RESOURCE_TEMPLATE, TNC_RESOURCES, TNC_RESPONSE, TNC_RESPONSE_INVALID_REQUEST, termsAndConditionsTranslation_t::tnc_template, and termsAndConditionMixAnswer_t::xmlAnswer.

Referenced by doUserLogin_internal().

Here is the call graph for this function:

Here is the caller graph for this function:

incMixedPackets()

SINT32 CAFirstMix::incMixedPackets ( )

inlineprotected

Definition at line 427 of file CAFirstMix.hpp.

        {
          m_pmutexMixedPackets->lock();
          inc64(m_nMixedPackets);
          m_pmutexMixedPackets->unlock();
          return E_SUCCESS;
        }

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

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

Here is the call graph for this function:

Here is the caller graph for this function:

incNewConnections()

void CAFirstMix::incNewConnections ( )

inlineprivate

Definition at line 571 of file CAFirstMix.hpp.

    {
      m_pmutexNewConnections->lock();
      m_newConnections++;
      m_pmutexNewConnections->unlock();
    }

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

Here is the call graph for this function:

incUsers()

SINT32 CAFirstMix::incUsers ( LP_fmHashTableEntry  pHashEntry )

inlineprotected

Definition at line 400 of file CAFirstMix.hpp.

        {
          m_pmutexUser->lock();
          m_nUser++;
          #ifdef COUNTRY_STATS
            pHashEntry->countryID=updateCountryStats(pHashEntry->peerIP,0,false);
          #endif
          m_pmutexUser->unlock();
          return E_SUCCESS;
        }

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

Here is the call graph for this function:

init()

SINT32 CAFirstMix::init ( )

protectedvirtual

Connect to the next mix

Implements CAMix.

Definition at line 108 of file CAFirstMix.cpp.

  {
    if (isShuttingDown())
    {
      return E_SHUTDOWN;
    }
 
#ifdef DYNAMIC_MIX
    m_bBreakNeeded = m_bReconfigured;
#endif
 
    CAMsg::printMsg(LOG_DEBUG,"Starting FirstMix Init\n");
    m_nMixedPackets=0; //reset to zero after each restart (at the moment neccessary for infoservice)
    m_bRestart=false;
    //Establishing all Listeners
    UINT32 i;
    m_arrSocketsIn=new CASocket*[m_nSocketsIn];
    for (i = 0; i < m_nSocketsIn; i++)
    {
      m_arrSocketsIn[i] = NULL;
    }
    //initiate ownerDocument for tc templates
    m_templatesOwner = createDOMDocument();
 
    SINT32 retSockets = CALibProxytest::getOptions()->createSockets(true, m_arrSocketsIn, m_nSocketsIn);
 
 
    if (retSockets != E_SUCCESS)
    {
      return retSockets;
    }
 
    CASocketAddr* pAddrNext=NULL;
    for(i=0;i<CALibProxytest::getOptions()->getTargetInterfaceCount();i++)
      {
        CATargetInterface oNextMix;
        CALibProxytest::getOptions()->getTargetInterface(oNextMix,i+1);
        if(oNextMix.getTargetType()==TARGET_MIX)
        {
          pAddrNext=oNextMix.getAddr();
          break;
        }
        oNextMix.cleanAddr();
      }
    if(pAddrNext==NULL)
      {
        CAMsg::printMsg(LOG_CRIT,"No next Mix specified! Please insert the address of a next mix into your configuration.\n");
        return E_UNKNOWN;
      }
    m_pMuxOut = new CAMuxSocket(OFB);
    if(m_pMuxOut->getCASocket()->create(pAddrNext->getType())!=E_SUCCESS)
      {
        CAMsg::printMsg(LOG_CRIT,
          "Cannot create SOCKET for connection to next Mix! Please check if the network and socket settings in your system are correct.\n");
        return E_UNKNOWN;
      }
    m_pMuxOut->getCASocket()->setSendBuff(500*MIXPACKET_SIZE);
    m_pMuxOut->getCASocket()->setRecvBuff(500*MIXPACKET_SIZE);
    //if(((*m_pMuxOut))->setSendLowWat(MIXPACKET_SIZE)!=E_SUCCESS)
    //  CAMsg::printMsg(LOG_INFO,"SOCKET Option SENDLOWWAT not set!\n");
    CAMsg::printMsg(LOG_INFO,"MUXOUT-SOCKET RecvBuffSize: %i\n",m_pMuxOut->getCASocket()->getRecvBuff());
    CAMsg::printMsg(LOG_INFO,"MUXOUT-SOCKET SendBuffSize: %i\n",m_pMuxOut->getCASocket()->getSendBuff());
    //CAMsg::printMsg(LOG_INFO,"MUXOUT-SOCKET SendLowWatSize: %i\n",((*m_pMuxOut))->getSendLowWat());
 
    if((retSockets = connectToNextMix(pAddrNext)) != E_SUCCESS)
    {
      delete pAddrNext;
      pAddrNext = NULL;
      CAMsg::printMsg(LOG_DEBUG, "CAFirstMix::init - Unable to connect to next mix. Reason: %s (%i)\n", GET_NET_ERROR_STR(retSockets), retSockets);       
      return E_UNKNOWN;
    }
    delete pAddrNext;
    pAddrNext = NULL;
    MONITORING_FIRE_NET_EVENT(ev_net_nextConnected);
    CAMsg::printMsg(LOG_INFO,"Established socket connection to next mix. Starting key exchange...\n");
    m_pMuxOut->getCASocket()->setKeepAlive((UINT32)1800);
#ifdef __BUILD_AS_SHADOW_PLUGIN__
    m_pMuxOut->getCASocket()->setNonBlocking(true);
#endif
 
 
    if(processKeyExchange()!=E_SUCCESS)
    {
      MONITORING_FIRE_NET_EVENT(ev_net_nextConnectionClosed);
      CAMsg::printMsg(LOG_CRIT,"Error in establishing secure communication with next Mix. Disconnecting...\n");
        return E_UNKNOWN;
    }
  else
  {
    CAMsg::printMsg(LOG_INFO,"Secure connection to next Mix was established successfully.\n");
  }
    m_pIPList=new CAIPList();
    m_pIPBlockList = new CATempIPBlockList(1000 * 60 * 2); 
#ifdef COUNTRY_STATS
    char* db_host;
    char* db_user;
    char* db_passwd;
    CALibProxytest::getOptions()->getCountryStatsDBConnectionLoginData(&db_host,&db_user,&db_passwd);
    SINT32 retcountrydb=initCountryStats(db_host,db_user,db_passwd);
    delete[] db_host;
    db_host = NULL;
    delete[] db_user;
    db_user = NULL;
    delete[] db_passwd;
    db_passwd = NULL;
    if(retcountrydb!=E_SUCCESS)
      return E_UNKNOWN;
#endif
    m_pQueueSendToMix=new CAQueue(sizeof(tQueueEntry));
    m_pQueueReadFromMix=new CAQueue(sizeof(tQueueEntry));
#ifndef MULTI_THREADED_PACKET_PROCESSING
    m_pChannelList=new CAFirstMixChannelList();
#ifdef HAVE_EPOLL
    m_psocketgroupUsersRead=new CASocketGroupEpoll(false);
    m_psocketgroupUsersWrite=new CASocketGroupEpoll(true);
#else
    m_psocketgroupUsersRead=new CASocketGroup(false);
    m_psocketgroupUsersWrite=new CASocketGroup(true);
#endif
#else // with MULTI_THREADED_PACKET_PROCESSING
    m_pChannelToQueueList=new CAFirstMixChannelToQueueList() ;
 
    m_arpChannelList = new CAFirstMixChannelList*[m_numThreads];
#ifdef HAVE_EPOLL
    m_arpsocketgroupUsersRead=new CASocketGroupEpoll*[m_numThreads];
    m_arpsocketgroupUsersWrite=new CASocketGroupEpoll*[m_numThreads];
#else
    m_arpsocketgroupUsersRead=new CASocketGroup*[m_numThreads];
    m_arpsocketgroupUsersWrite=new CASocketGroup*[m_numThreads];
#endif
    for (UINT32 i = 0; i < m_numThreads; i++)
      {
        m_arpChannelList[i] = new CAFirstMixChannelList();
#ifdef HAVE_EPOLL
      m_arpsocketgroupUsersRead[i] = new CASocketGroupEpoll(false);
      m_arpsocketgroupUsersWrite[i] = new CASocketGroupEpoll(true);
#else
      m_arpsocketgroupUsersRead[i] = new CASocketGroup(false);
      m_arpsocketgroupUsersWrite[i] = new CASocketGroup(true);
#endif
      }
 
 
#endif //with MULTI_THREADED_PACKET_PROCESSING
 
    m_pMuxOutControlChannelDispatcher=new CAControlChannelDispatcher(m_pQueueSendToMix,NULL,NULL);
#ifdef REPLAY_DETECTION
    m_pReplayDB=new CADatabase();
    m_pReplayDB->start();
    m_pReplayMsgProc=new CAReplayCtrlChannelMsgProc(this);
    m_u64ReferenceTime=time(NULL);
    m_u64LastTimestampReceived=time(NULL);
#endif
 
#ifdef PAYMENT
    if (CAAccountingDBInterface::init() != E_SUCCESS)
    {
      return E_UNKNOWN;
    }
    CAAccountingInstance::init(this);
#endif
 
    m_pthreadsLogin=new CAThreadPool(NUM_LOGIN_WORKER_TRHEADS,MAX_LOGIN_QUEUE,false);
 
    //Starting thread for Step 1
    m_pthreadAcceptUsers=new CAThread((UINT8*)"CAFirstMix - AcceptUsers");
    m_pthreadAcceptUsers->setMainLoop(fm_loopAcceptUsers);
    m_pthreadAcceptUsers->start(this);
 
    //Starting thread for Step 3
    m_pthreadSendToMix=new CAThread((UINT8*)"CAFirstMix - SendToMix");
    m_pthreadSendToMix->setMainLoop(fm_loopSendToMix);
    m_pthreadSendToMix->start(this);
 
    //Startting thread for Step 4a
    m_pthreadReadFromMix=new CAThread((UINT8*)"CAFirstMix - ReadFromMix");
    m_pthreadReadFromMix->setMainLoop(fm_loopReadFromMix);
    m_pthreadReadFromMix->start(this);
#ifdef CH_LOG_STUDY
    nrOfChThread = new CAThread((UINT8*)"CAFirstMix - Channel open logging thread");
    nrOfChThread->setMainLoop(fm_loopLogChannelsOpened);
    nrOfChThread->start(this);
    currentOpenedChannels = 0;
#endif //CH_LOG_STUDY
    //Starting thread for logging
#ifdef LOG_PACKET_TIMES
    m_pLogPacketStats=new CALogPacketStats();
    m_pLogPacketStats->setLogIntervallInMinutes(FM_PACKET_STATS_LOG_INTERVALL);
    m_pLogPacketStats->start();
#endif
#ifdef REPLAY_DETECTION
//    sendReplayTimestampRequestsToAllMixes();
#endif
    CAMsg::printMsg(LOG_DEBUG,"CAFirstMix init() succeeded\n");
    MONITORING_FIRE_NET_EVENT(ev_net_keyExchangeNextSuccessful);
    return E_SUCCESS;
}

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.

Here is the call graph for this function:

initCountryStats()

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

private

Definition at line 2937 of file CAFirstMix.cpp.

  {
    m_CountryStats=NULL;
    m_mysqlCon=mysql_init(NULL);
#ifdef HAVE_MYSQL_OPT_RECONNECT
    my_bool thetrue=1;
    mysql_options(m_mysqlCon,MYSQL_OPT_RECONNECT,&thetrue);
#endif
    MYSQL* tmp=NULL;
    tmp=mysql_real_connect(m_mysqlCon,db_host,db_user,db_passwd,COUNTRY_STATS_DB,0,NULL,0);
    if(tmp==NULL)
      {
        CAMsg::printMsg(LOG_DEBUG,"Could not connect to CountryStats DB!\n");
        mysql_thread_end();
        mysql_close(m_mysqlCon);
        m_mysqlCon=NULL;
        return E_UNKNOWN;
      }
    CAMsg::printMsg(LOG_DEBUG,"Connected to CountryStats DB!\n");
    char query[1024];
    UINT8 buff[255];
    CALibProxytest::getOptions()->getCascadeName(buff,255);
    mysqlEscapeTableName(buff);
    sprintf(query,"CREATE TABLE IF NOT EXISTS `stats_%s` (date timestamp,id int,count int,packets_in int,packets_out int)",buff);
    SINT32 ret=mysql_query(m_mysqlCon,query);
    if(ret!=0)
    {
        CAMsg::printMsg(LOG_INFO,"CountryStats DB - create table for %s failed!\n",buff);
    }
    m_CountryStats=new UINT32[NR_OF_COUNTRIES+1];
    memset((void*)m_CountryStats,0,sizeof(UINT32)*(NR_OF_COUNTRIES+1));
    m_PacketsPerCountryIN=new tUINT32withLock[NR_OF_COUNTRIES+1];
    //memset((void*)m_PacketsPerCountryIN,0,sizeof(UINT32)*(NR_OF_COUNTRIES+1));
    m_PacketsPerCountryOUT=new tUINT32withLock[NR_OF_COUNTRIES+1];
    //memset((void*)m_PacketsPerCountryOUT,0,sizeof(UINT32)*(NR_OF_COUNTRIES+1));
    m_threadLogLoop=new CAThread((UINT8*)"Country Logger Thread");
    m_threadLogLoop->setMainLoop(iplist_loopDoLogCountries);
    m_bRunLogCountries=true;
    m_threadLogLoop->start(this,true);
    return E_SUCCESS;
  }

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

Here is the call graph for this function:

Here is the caller graph for this function:

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.

Definition at line 2862 of file CAFirstMix.cpp.

  {
    DOMNodeList* nl=getElementsByTagName(elemMixes,"Mix");
    m_u32MixCount=nl->getLength();
    m_arMixParameters=new tMixParameters[m_u32MixCount];
    memset(m_arMixParameters,0,sizeof(tMixParameters)*m_u32MixCount);
    UINT8 buff[255];
    CALibProxytest::getOptions()->getMixId(buff,255);
    UINT32 len=strlen((char*)buff)+1;
    UINT32 aktMix=0;
    for (UINT32 i = 0; i<m_u32MixCount; i++)
    {
      DOMNode* child=nl->item(i);
      len=255;
      getDOMElementAttribute(child,"id",buff,&len);
      m_arMixParameters[aktMix].m_strMixID=new UINT8[len+1];
      memcpy(m_arMixParameters[aktMix].m_strMixID,buff,len);
      m_arMixParameters[aktMix].m_strMixID[len]=0;
      aktMix++;
    }
    m_u32MixCount++;
    return E_SUCCESS;
  }

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

Here is the call graph for this function:

initOnce()

SINT32 CAFirstMix::initOnce ( )

protectedvirtual

Reimplemented from CAMix.

Definition at line 69 of file CAFirstMix.cpp.

  {
    SINT32 ret=CAMix::initOnce();
    if(ret!=E_SUCCESS)
      return ret;
    CAMsg::printMsg(LOG_DEBUG,"Starting FirstMix InitOnce\n");
    /*m_pSignature=CALibProxytest::getOptions()->getSignKey();
    if(m_pSignature==NULL)*/
    m_pMultiSignature = CALibProxytest::getOptions()->getMultiSigner();
    if(m_pMultiSignature == NULL)
      return E_UNKNOWN;
    //Try to find out how many (real) ListenerInterfaces are specified
    UINT32 tmpSocketsIn=CALibProxytest::getOptions()->getListenerInterfaceCount();
    m_nSocketsIn=0;
    for(UINT32 i=1;i<=tmpSocketsIn;i++)
    {
      CAListenerInterface* pListener=NULL;
      pListener=CALibProxytest::getOptions()->getListenerInterface(i);
      if(pListener==NULL)
        continue;
      if(!pListener->isVirtual())
      {
        m_nSocketsIn++;
      }
      delete pListener;
      pListener = NULL;
    }
    if(m_nSocketsIn<1)
    {
      CAMsg::printMsg(LOG_CRIT,"No usable ListenerInterfaces specified (maybe wrong values or all are 'virtual'!\n");
      return E_UNKNOWN;
    }
 
    CAMsg::printMsg(LOG_DEBUG,"Starting FirstMix InitOnce - finished\n");
    return E_SUCCESS;
  }

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

Here is the call graph for this function:

isAllowedToPassRestrictions()

SINT32 CAFirstMix::isAllowedToPassRestrictions ( CASocket *  pNewMuxSocket )

private

isShuttingDown()

bool CAFirstMix::isShuttingDown ( )

protected

Definition at line 64 of file CAFirstMix.cpp.

{
  return m_bIsShuttingDown;
}

References m_bIsShuttingDown.

Referenced by init().

Here is the caller graph for this function:

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.

Definition at line 362 of file CAFirstMix.cpp.

  {
    UINT8* recvBuff=NULL;
    UINT32 len;
    SINT32 ret;
    CAMsg::printMsg(LOG_INFO, "Try to read the Key Info length from next Mix...\n");
    if((ret = m_pMuxOut->receiveFully((UINT8*) &len, sizeof(len), TIMEOUT_MIX_CONNECTION_ESTABLISHEMENT)) != E_SUCCESS)
      {
        if (ret != E_UNKNOWN)
          {
            CAMsg::printMsg(LOG_CRIT,"Error receiving Key Info length from next mix! Reason: '%s' (%i)\n",GET_NET_ERROR_STR(GET_NET_ERROR), GET_NET_ERROR);
          }
        else
          {
            CAMsg::printMsg(LOG_CRIT,"Error receiving Key Info length from next mix!\n");
          }
        return ret;
      }
    len=ntohl(len);
    CAMsg::printMsg(LOG_INFO, "Received next mix Key Info length %u\n",len);
  
    if (len > 100000)
      {
        CAMsg::printMsg(LOG_WARNING,"Unrealistic length for key info: %u We might not be able to get a connection.\n",len);
      }
  
    recvBuff=new UINT8[len+1];
 
    if ((ret =m_pMuxOut->receiveFully(recvBuff, len, TIMEOUT_MIX_CONNECTION_ESTABLISHEMENT)) != E_SUCCESS)
      {
        if (ret != E_UNKNOWN)
          {
            CAMsg::printMsg(LOG_CRIT,"Error receiving Key Info from next mix! Reason: '%s' (%i)\n",GET_NET_ERROR_STR(GET_NET_ERROR), GET_NET_ERROR);
          }
        else
          {
            CAMsg::printMsg(LOG_CRIT,"Error receiving Key Info from next mix!\n");
          }
        delete []recvBuff;
        recvBuff = NULL;
        return E_UNKNOWN;
      }
    recvBuff[len]=0;
    //get the Keys from the other mixes (and the Mix-Id's...!)
    CAMsg::printMsg(LOG_INFO,"Received Key Info from next mix...\n");
    CAMsg::printMsg(LOG_DEBUG,"%s\n",recvBuff);
 
    XERCES_CPP_NAMESPACE::DOMDocument* doc=parseDOMDocument(recvBuff, len);
    delete []recvBuff;
    recvBuff = NULL;
    DOMElement* elemMixes=doc->getDocumentElement();
    if(elemMixes == NULL)
    {
    if(doc != NULL)
    {
      doc->release();
      doc = NULL;
    }
    CAMsg::printMsg(LOG_INFO,"before returning...\n");
    return E_UNKNOWN;
    }
    SINT32 count=0;
    if(getDOMElementAttribute(elemMixes,"count",&count)!=E_SUCCESS)
    {
      if(doc != NULL)
    {
      doc->release();
      doc = NULL;
    }
        return E_UNKNOWN;
    }
 /*
    @todo Do not know why we do this here - probably it has something todo with the
    dynamic mix config, but makes not sense at all for me...
 
    getDOMElementAttribute(elemMixescascadeNaem
    char *cascadeName;
    cascadeName = elemMixes.getAttribute("cascadeName").transcode();
    if(cascadeName == NULL)
        return E_UNKNOWN;
    CALibProxytest::getOptions()->setCascadeName(cascadeName);
*/
#ifdef PAYMENT
    if(CALibProxytest::getOptions()->getTermsAndConditions() != NULL)
    {
      appendTermsAndConditionsExtension(doc, elemMixes);
    }
#endif
    SINT32 extRet = handleKeyInfoExtensions(elemMixes);
    if(extRet != E_SUCCESS)
    {
      if(doc != NULL)
    {
      doc->release();
      doc = NULL;
    }
    return E_UNKNOWN;
    }
    m_pRSA=new CAASymCipher;
 
#ifdef EXPORT_ASYM_PRIVATE_KEY
    if(CALibProxytest::getOptions()->isImportKey())
      {
        UINT32 keyFileBuffLen=8096;
        UINT8* keyFileBuff=new UINT8[keyFileBuffLen];
        CALibProxytest::getOptions()->getEncryptionKeyImportFile(keyFileBuff,keyFileBuffLen);
        UINT8* keyBuff=readFile(keyFileBuff,&keyFileBuffLen);
        m_pRSA->setPrivateKeyAsXML(keyBuff,keyFileBuffLen);
        delete[] keyFileBuff;
        delete[] keyBuff;
      }
    else
#endif
      {
        m_pRSA->generateKeyPair(1024);
      }
#ifdef EXPORT_ASYM_PRIVATE_KEY
    if(CALibProxytest::getOptions()->isExportKey())
      {
        UINT32 keyFileBuffLen=8096;
        UINT8* keyFileBuff=new UINT8[keyFileBuffLen];
        UINT8* keyBuff=new UINT8[keyFileBuffLen];
        CALibProxytest::getOptions()->getEncryptionKeyExportFile(keyFileBuff,keyFileBuffLen);
        m_pRSA->getPrivateKeyAsXML(keyBuff,&keyFileBuffLen);
        saveFile(keyFileBuff,keyBuff,keyFileBuffLen);
        delete[] keyFileBuff;
        delete[] keyBuff;
      }
#endif
    DOMNode* child=elemMixes->getLastChild();
 
    //tmp XML-Structure for constructing the XML which is sent to each user
    XERCES_CPP_NAMESPACE::DOMDocument* docXmlKeyInfo=createDOMDocument();
    DOMElement* elemRootKey=createDOMElement(docXmlKeyInfo,"MixCascade");
    setDOMElementAttribute(elemRootKey,"version",(UINT8*)"0.2"); //set the Version of the XML to 0.2
    setDOMElementAttribute(elemRootKey, "maxOpenChannels", CHANNELS_PER_CLIENT);
#ifdef LOG_DIALOG
    setDOMElementAttribute(elemRootKey,"study",(UINT8*)"true");
#endif
    docXmlKeyInfo->appendChild(elemRootKey);
    DOMElement* elemMixProtocolVersion=createDOMElement(docXmlKeyInfo,"MixProtocolVersion");
    setDOMElementValue(elemMixProtocolVersion,(UINT8*)MIX_CASCADE_PROTOCOL_VERSION);
    elemRootKey->appendChild(elemMixProtocolVersion);
    DOMNode* elemMixesKey=docXmlKeyInfo->importNode(elemMixes,true);
    elemRootKey->appendChild(elemMixesKey);
 
    //UINT32 tlen;
    /* //remove because it seems to be useless...
    while(child!=NULL)
    {
        if(child.getNodeName().equals("Mix"))
        {
            DOM_Node rsaKey=child.getFirstChild();
            CAASymCipher oRSA;
            oRSA.setPublicKeyAsDOMNode(rsaKey);
            tlen=256;
        }
        child=child.getPreviousSibling();
    }*/
    //tlen=256;
 
    //Inserting own Key in XML-Key struct
    DOMElement* elemKey=NULL;
    m_pRSA->getPublicKeyAsDOMElement(elemKey,docXmlKeyInfo);
    addMixInfo(elemMixesKey, true);
    DOMElement* elemOwnMix=NULL;
    getDOMChildByName(elemMixesKey, "Mix", elemOwnMix, false);
    elemOwnMix->appendChild(elemKey);
#ifdef PAYMENT
    CAMsg::printMsg(LOG_INFO,"before T&Cs1...\n");
    if(CALibProxytest::getOptions()->getTermsAndConditions() != NULL)
    {
      elemOwnMix->appendChild(termsAndConditionsInfoNode(docXmlKeyInfo));
    }
    CAMsg::printMsg(LOG_INFO,"after T&Cs1...\n");
#endif
  elemOwnMix->appendChild(createDOMElement(docXmlKeyInfo,"SupportsEncrypedControlChannels"));
  CAMsg::printMsg(LOG_INFO,"after SupportEncChannels...\n");
  if (signXML(elemOwnMix) != E_SUCCESS)
  {
    CAMsg::printMsg(LOG_DEBUG,"Could not sign MixInfo sent to users...\n");
  }
 
  setDOMElementAttribute(elemMixesKey,"count",count+1);
 
 
  DOMNode* elemPayment=createDOMElement(docXmlKeyInfo,"Payment");
  elemRootKey->appendChild(elemPayment);
#ifdef PAYMENT
  setDOMElementAttribute(elemPayment,"required",(UINT8*)"true");
  setDOMElementAttribute(elemPayment,"version",(UINT8*)PAYMENT_VERSION);
  setDOMElementAttribute(elemPayment,"prepaidInterval", CALibProxytest::getOptions()->getPrepaidInterval());
  setDOMElementAttribute(elemPayment,"piid", CALibProxytest::getOptions()->getBI()->getID());
 
#else
  setDOMElementAttribute(elemPayment,"required",(UINT8*)"false");
#endif
 
  // create signature
  if (signXML(elemRootKey) != E_SUCCESS)
    {
    CAMsg::printMsg(LOG_DEBUG,"Could not sign KeyInfo sent to users...\n");
  }
 
 
  UINT32 tmp32Len = 0;
    UINT8* tmpB=DOM_Output::dumpToMem(docXmlKeyInfo, &tmp32Len);
    if (docXmlKeyInfo != NULL)
    {
      docXmlKeyInfo->release();
      docXmlKeyInfo = NULL;
    }
 
    if(tmp32Len > 0xFFFD) //too bytes are reserved for the length
    {
    CAMsg::printMsg(LOG_CRIT, "The key info size of %u bytes is too large for the clients. (maximum is %u)\n", 0xFFFD);
    if (doc != NULL)
    {
      doc->release();
      doc = NULL;
    }
    return E_UNKNOWN;
    }
 
    UINT16 tlen = (UINT16) tmp32Len;
    m_xmlKeyInfoBuff = new UINT8[tlen+sizeof(tlen)];
    memcpy(m_xmlKeyInfoBuff+sizeof(tlen), tmpB, tlen);
    UINT16 s = htons(tlen);
    memcpy(m_xmlKeyInfoBuff, &s, sizeof(s));
    m_xmlKeyInfoSize=tlen + sizeof(tlen);
    delete []tmpB;
    tmpB = NULL;
    SINT32 result=E_UNKNOWN;
 
    //Sending symmetric key...
    child=elemMixes->getFirstChild();
    while(child!=NULL)
    {
      if(equals(child->getNodeName(),"Mix"))
        {
        //verify certificate from next mix if enabled
        if(CALibProxytest::getOptions()->verifyMixCertificates())
        {
          CACertificate* nextMixCert = CALibProxytest::getOptions()->getTrustedCertificateStore()->verifyMixCert(child);
          if(nextMixCert != NULL)
          {
            CAMsg::printMsg(LOG_DEBUG, "Next mix certificate was verified by a trusted root CA.\n");
            CALibProxytest::getOptions()->setNextMixTestCertificate(nextMixCert);
          }
          else
          {
            CAMsg::printMsg(LOG_ERR, "Could not verify certificate received from next mix!\n");
            return E_UNKNOWN;
          }
        }
            //check Signature....
            CAMsg::printMsg(LOG_DEBUG,"Try to verify next mix signature...\n");
            //CASignature oSig;
            CACertificate* nextCert=CALibProxytest::getOptions()->getNextMixTestCertificate();
            /*oSig.setVerifyKey(nextCert);
            SINT32 ret=oSig.verifyXML(child,NULL);*/
            result = CAMultiSignature::verifyXML(child, nextCert);
            delete nextCert;
            nextCert = NULL;
            if(result != E_SUCCESS)
            {     
                //CAMsg::printMsg(LOG_CRIT,"Could not verify the symmetric key from next mix! The operator of the next mix has to send you his current mix certificate, and you will have to import it in your configuration. Alternatively, you might import the proper root certification authority for verifying the certificate.\n");
                CAMsg::printMsg(LOG_CRIT,"Could not verify the symmetric key from next mix! The operator of the next mix has to send you his current mix certificate, and you will have to import it in your configuration.\n");
                if (doc != NULL)
                {
                  doc->release();
                  doc = NULL;
                }
                return E_UNKNOWN;
            }
            CAMsg::printMsg(LOG_DEBUG,"Successfully verified XML signature of next mix!\n");
 
            result = checkCompatibility(child, "next");
          
 
            DOMNode* rsaKey=child->getFirstChild();
            CAASymCipher oRSA;
            oRSA.setPublicKeyAsDOMNode(rsaKey);
            DOMElement* elemNonce=NULL;
            getDOMChildByName(child,"Nonce",elemNonce,false);
            UINT8 arNonce[1024];
            if(elemNonce!=NULL)
            {
                UINT32 lenNonce=1024;
                UINT32 tmpLen=1024;
                getDOMElementValue(elemNonce,arNonce,&lenNonce);
                CABase64::decode(arNonce,lenNonce,arNonce,&tmpLen);
                lenNonce=tmpLen;
                tmpLen=1024;
                CABase64::encode(SHA1(arNonce,lenNonce,NULL),SHA_DIGEST_LENGTH,
                                 arNonce,&tmpLen);
                arNonce[tmpLen]=0;
            }
            UINT8 key[64];
#ifdef SET_STATIC_MUX_SOCKET_KEY
            CAMsg::printMsg(LOG_CRIT, "Warning! Will use an all zero MuxSocket key - do not use this Mix in a productive environment -- only for testing!\n");
            memset(key,0,64);
#else
            getRandom(key, 64);
#endif
            //UINT8 buff[400];
            //UINT32 bufflen=400;
            XERCES_CPP_NAMESPACE::DOMDocument* docSymKey=createDOMDocument();
            DOMElement* elemRoot=NULL;
            encodeXMLEncryptedKey(key,64,elemRoot,docSymKey,&oRSA);
            docSymKey->appendChild(elemRoot);
            if(elemNonce!=NULL)
            {
                DOMElement* elemNonceHash=createDOMElement(docSymKey,"Nonce");
                setDOMElementValue(elemNonceHash,arNonce);
                elemRoot->appendChild(elemNonceHash);
            }
 
            appendCompatibilityInfo(elemRoot);
 
      DOMElement* elemKeepAlive=NULL;
      DOMElement* elemKeepAliveSendInterval=NULL;
      DOMElement* elemKeepAliveRecvInterval=NULL;
      getDOMChildByName(child,"KeepAlive",elemKeepAlive,false);
      getDOMChildByName(elemKeepAlive,"SendInterval",elemKeepAliveSendInterval,false);
      getDOMChildByName(elemKeepAlive,"ReceiveInterval",elemKeepAliveRecvInterval,false);
      UINT32 tmpSendInterval,tmpRecvInterval;
      getDOMElementValue(elemKeepAliveSendInterval,tmpSendInterval,0xFFFFFFFF); //if no send interval was given set it to "infinite"
      getDOMElementValue(elemKeepAliveRecvInterval,tmpRecvInterval,0xFFFFFFFF); //if no recv interval was given --> set it to "infinite"
      CAMsg::printMsg(LOG_DEBUG,"KeepAlive-Traffic: Getting offer -- SendInterval %u -- ReceiveInterval %u\n",tmpSendInterval,tmpRecvInterval);
      // Add Info about KeepAlive traffic
      UINT32 u32KeepAliveSendInterval=CALibProxytest::getOptions()->getKeepAliveSendInterval();
      UINT32 u32KeepAliveRecvInterval=CALibProxytest::getOptions()->getKeepAliveRecvInterval();
      elemKeepAlive=createDOMElement(docSymKey,"KeepAlive");
      elemKeepAliveSendInterval=createDOMElement(docSymKey,"SendInterval");
      elemKeepAliveRecvInterval=createDOMElement(docSymKey,"ReceiveInterval");
      elemKeepAlive->appendChild(elemKeepAliveSendInterval);
      elemKeepAlive->appendChild(elemKeepAliveRecvInterval);
      setDOMElementValue(elemKeepAliveSendInterval,u32KeepAliveSendInterval);
      setDOMElementValue(elemKeepAliveRecvInterval,u32KeepAliveRecvInterval);
      elemRoot->appendChild(elemKeepAlive);
      CAMsg::printMsg(LOG_DEBUG,"KeepAlive-Traffic: Offering -- SendInterval %u -- Receive Interval %u\n",u32KeepAliveSendInterval,u32KeepAliveRecvInterval);
      m_u32KeepAliveSendInterval = u32KeepAliveSendInterval;
      if (m_u32KeepAliveSendInterval > tmpRecvInterval - 10000)
        m_u32KeepAliveSendInterval-=10000; //make the send interval a little bit smaller than the related receive interval
      m_u32KeepAliveRecvInterval=max(u32KeepAliveRecvInterval,tmpSendInterval);
      if (m_u32KeepAliveRecvInterval - 10000 < tmpSendInterval)
        {
          m_u32KeepAliveRecvInterval += 10000;
        }
      CAMsg::printMsg(LOG_DEBUG,"KeepAlive-Traffic: Calculated -- SendInterval %u -- Receive Interval %u\n",m_u32KeepAliveSendInterval,m_u32KeepAliveRecvInterval);
 
      //m_pSignature->signXML(elemRoot);
      m_pMultiSignature->signXML(elemRoot, true);
      UINT32 outlen=0;
      UINT8* out=DOM_Output::dumpToMem(docSymKey,&outlen);
      if (docSymKey != NULL)
        {
          docSymKey->release();
          docSymKey = NULL;
        }
      m_pMuxOut->setSendKey(key,32);
      m_pMuxOut->setReceiveKey(key+32,32);
      UINT32 size = htonl(outlen);
      CAMsg::printMsg(LOG_DEBUG,"Sending symmetric key to next Mix! Size: %i\n", outlen);
      m_pMuxOut->getCASocket()->send((UINT8*) &size, sizeof(size));
      m_pMuxOut->getCASocket()->send(out, outlen);
      m_pMuxOut->setCrypt(true);
      delete[] out;
      out = NULL;
      break;
        }
        child=child->getNextSibling();
    }
  
   if (result != E_SUCCESS)
  {
    if (doc != NULL)
    {
      doc->release();
      doc = NULL;
    }
    return result;
  }
  
  
  if(initMixParameters(elemMixes)!=E_SUCCESS)
  {
    if (doc != NULL)
    {
      doc->release();
      doc = NULL;
    }
    return E_UNKNOWN;
  }
    if(initMixCascadeInfo(elemMixes)!=E_SUCCESS)
    {
      if (doc != NULL)
      {
        doc->release();
        doc = NULL;
      }
      CAMsg::printMsg(LOG_CRIT,"Error initializing cascade info.\n");
        return E_UNKNOWN;
    }
/*    else
    {
        if(m_pInfoService != NULL)
            m_pInfoService->sendCascadeHelo();
    }*/
    CAMsg::printMsg(LOG_DEBUG,"Key exchange finished!\n");
    if (doc != NULL)
    {
      doc->release();
      doc = NULL;
    }
    return E_SUCCESS;
}

Referenced by init().

Here is the caller graph for this function:

reconfigure()

SINT32 CAFirstMix::reconfigure ( )

protectedvirtual

Reimplemented from CAMix.

Definition at line 2845 of file CAFirstMix.cpp.

  {
    CAMsg::printMsg(LOG_DEBUG,"Reconfiguring First Mix\n");
#ifdef DELAY_USERS
    CAMsg::printMsg(LOG_DEBUG,"Set new ressources limitation parameters\n");
#ifndef MULTI_THREADED_PACKET_PROCESSING
    if(m_pChannelList!=NULL)
      m_pChannelList->setDelayParameters( CALibProxytest::getOptions()->getDelayChannelUnlimitTraffic(),
                                          CALibProxytest::getOptions()->getDelayChannelBucketGrow(),
                                          CALibProxytest::getOptions()->getDelayChannelBucketGrowIntervall());
#endif
#endif
    return E_SUCCESS;
  }

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

Here is the call graph for this function:

sendReplayTimestampRequestsToAllMixes()

SINT32 CAFirstMix::sendReplayTimestampRequestsToAllMixes ( )

private

Definition at line 2910 of file CAFirstMix.cpp.

  {
    for(UINT32 i=0;i<m_u32MixCount-1;i++)
      {
        m_pReplayMsgProc->sendGetTimestamp(m_arMixParameters[i].m_strMixID);
      }
    return E_SUCCESS;
  }

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

Here is the call graph for this function:

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.

Definition at line 784 of file CAFirstMix.cpp.

  {
#ifdef REPLAY_DETECTION
    UINT32 diff=time(NULL)-m_u64LastTimestampReceived;
    for(UINT32 i=0;i<m_u32MixCount-1;i++)
      {
//@todo dangerous strcmp
        if(strcmp((char*)m_arMixParameters[i].m_strMixID,(char*)params.m_strMixID)==0)
          {
            m_arMixParameters[i].m_u32ReplayOffset=params.m_u32ReplayOffset;
            m_arMixParameters[i].m_u32ReplayBase=params.m_u32ReplayBase;
          }
        else{
            if (m_arMixParameters[i].m_u32ReplayOffset!=0) m_arMixParameters[i].m_u32ReplayOffset+=diff;
          }
      }
#endif
    return E_SUCCESS;
  }

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

Returns

the countryID which was asigned to the user. This may be the default value a_countryID, if no country could be found.

Definition at line 3014 of file CAFirstMix.cpp.

  {
    if(!bRemove)
      {
        UINT32 countryID=a_countryID;
        if(ip!=NULL)
          {
            UINT32 u32ip=ip[0]<<24|ip[1]<<16|ip[2]<<8|ip[3];
            char query[1024];
            sprintf(query,"SELECT id FROM ip2c WHERE ip_lo<=\"%u\" and ip_hi>=\"%u\" LIMIT 1",u32ip,u32ip);
            int ret=mysql_query(m_mysqlCon,query);
            if(ret!=0)
              {
                CAMsg::printMsg(LOG_INFO,"CountryStatsDB - updateCountryStats - error (%i) in finding countryid for ip %u\n",ret,u32ip);
                goto RET;
              }
            MYSQL_RES* result=mysql_store_result(m_mysqlCon);
            if(result==NULL)
              {
                CAMsg::printMsg(LOG_INFO,"CountryStatsDB - updateCountryStats - error in retriving results of the query\n");
                goto RET;
              }
            MYSQL_ROW row=mysql_fetch_row(result);
            SINT32 t;
            if(row!=NULL&&(t=atoi(row[0]))>0&&t<=NR_OF_COUNTRIES)
              {
                countryID=t;
                #ifdef DEBUG
                  CAMsg::printMsg(LOG_DEBUG,"Country ID for ip %u is %u\n",u32ip,countryID);
                #endif
                //temp hack
                if(countryID==99)
                {
                  CAMsg::printMsg(LOG_DEBUG,"Country ID for ip %u.%u.%u.%u is %u\n",ip[0],ip[1],ip[2],ip[3],countryID);
                }
              }
            else
              {
                CAMsg::printMsg(LOG_DEBUG,"DO country stats query result no result for ip %u)\n",u32ip);
              }
            mysql_free_result(result);
          }
RET:
        m_CountryStats[countryID]++;
        return countryID;
      }
    else//bRemove
      {
        m_CountryStats[a_countryID]--;
      }
    return a_countryID;
  }

References m_CountryStats, m_mysqlCon, NR_OF_COUNTRIES, and CAMsg::printMsg().

Referenced by decUsers(), and incUsers().

Here is the call graph for this function:

Here is the caller graph for this function:

Friends And Related Function Documentation

fm_loopAcceptUsers

THREAD_RETURN fm_loopAcceptUsers ( void *  )

friend

Definition at line 1276 of file CAFirstMix.cpp.

  {
    INIT_STACK;
    BEGIN_STACK("CAFirstMix::fm_loopAcceptUsers");
    CAMsg::printMsg(LOG_DEBUG, "Start acceptusers\n");
 
    CAFirstMix* pFirstMix=(CAFirstMix*)param;
    CASocket** socketsIn=pFirstMix->m_arrSocketsIn;
    CAIPList* pIPList=pFirstMix->m_pIPList;
    CATempIPBlockList* pIPBlockList = pFirstMix->m_pIPBlockList;
    CAThreadPool* pthreadsLogin=pFirstMix->m_pthreadsLogin;
    UINT32 nSocketsIn=pFirstMix->m_nSocketsIn;
#ifdef __BUILD_AS_SHADOW_PLUGIN__
    CASocketGroupEpoll* psocketgroupAccept=new CASocketGroupEpoll(false);
#else
    CASocketGroup* psocketgroupAccept = new CASocketGroup(false);
#endif
    CAMuxSocket* pNewMuxSocket;
    UINT8* peerIP=new UINT8[4];
    UINT32 i=0;
    SINT32 countRead;
    SINT32 ret;
    SINT32 retPeerIP = E_SUCCESS;
 
    pFirstMix->m_newConnections = 0;
 
    // kick out users that already have connected
    for(i=0;i<nSocketsIn;i++)
    {
        while (socketsIn[i]->close() != E_SUCCESS)
        {
          sSleep(1);
        }
        delete socketsIn[i];
    }
    CAMsg::printMsg(LOG_DEBUG, "Creating incoming sockets\n");
 
    if (CALibProxytest::getOptions()->createSockets(false,pFirstMix-> m_arrSocketsIn, pFirstMix->m_nSocketsIn) != E_SUCCESS)
    {
      goto END_THREAD;
    }
    CAMsg::printMsg(LOG_DEBUG, "Add sockets to select group\n");
    for(i=0;i<nSocketsIn;i++)
    {
      psocketgroupAccept->add(*socketsIn[i]);
    }
#ifdef REPLAY_DETECTION //before we can start to accept users we have to ensure that we received the replay timestamps form the over mixes
    CAMsg::printMsg(LOG_DEBUG,"Waiting for Replay Timestamp from next mixes\n");
    i=0;
    while(!pFirstMix->m_bRestart && i < pFirstMix->m_u32MixCount-1)
    {
      if(pFirstMix->m_arMixParameters[i].m_u32ReplayOffset==0)//not set yet
        {
          msSleep(100);//wait a little bit and try again
          continue;
        }
      i++;
    }
    CAMsg::printMsg(LOG_DEBUG,"All Replay Timestamp received\n");
#endif
    CAMsg::printMsg(LOG_DEBUG, "Start accept users inner loop\n");
 
    while(!pFirstMix->m_bRestart)
      {
        if (pIPBlockList->count()>40)
        {
          CAMsg::printMsg(LOG_DEBUG,"UserAcceptLoop: login timeout list counts %d. We have %d users, %d open sockets and %d new connections. Restarting server sockets...\n",pIPBlockList->count(), pFirstMix->getNrOfUsers() ,CASocket::countOpenSockets(), pFirstMix->m_newConnections);
          for(i=0;i<nSocketsIn;i++)
          {
            psocketgroupAccept->remove(*socketsIn[i]);
            while (socketsIn[i]->close() != E_SUCCESS)
            {
              sSleep(1);
            }
          }
  
          if (CALibProxytest::getOptions()->createSockets(false,pFirstMix-> m_arrSocketsIn, pFirstMix->m_nSocketsIn) != E_SUCCESS)
          {
            // could not listen
            goto END_THREAD;
          }
          for(i=0;i<nSocketsIn;i++)
          {
            psocketgroupAccept->add(*socketsIn[i]);
          }
          sSleep(1);
        }
#ifdef  __BUILD_AS_SHADOW_PLUGIN__
        CAMsg::printMsg(LOG_DEBUG, "Before acceptusers->select()\n");
        countRead=psocketgroupAccept->select();
        CAMsg::printMsg(LOG_DEBUG, "after acceptusers->select()\n");
#else
        countRead = psocketgroupAccept->select(10000);
#endif
        if(countRead<0)
          { //check for Error - are we restarting ?
            if(pFirstMix->m_bRestart ||countRead!=E_TIMEDOUT)
              goto END_THREAD;
          }
        i=0;
#ifdef _DEBUG
        CAMsg::printMsg(LOG_DEBUG,"UserAcceptLoop: countRead=%i\n",countRead);
#endif
        while(countRead>0&&i<nSocketsIn)
        {
          if(psocketgroupAccept->isSignaled(*socketsIn[i]))
          {
            countRead--;
            #ifdef _DEBUG
              CAMsg::printMsg(LOG_DEBUG,"New direct Connection from Client!\n");
            #endif
            #ifdef SYM_CHANNEL_CIPHER_CTR
              pNewMuxSocket=new CAMuxSocket(CTR);
            #elif defined NO_ENCRYPTION
              pNewMuxSocket = new CAMuxSocket(NULL_CIPHER);
#else
              pNewMuxSocket=new CAMuxSocket(OFB);
            #endif
            ret=socketsIn[i]->accept(*(pNewMuxSocket->getCASocket()));
            pFirstMix->incNewConnections();
 
            if(ret!=E_SUCCESS)
            {
              // may return E_SOCKETCLOSED or E_SOCKET_LIMIT
              CAMsg::printMsg(LOG_ERR,"Accept Error %u - direct Connection from Client!\n",GET_NET_ERROR);
            }
            else if( (CALibProxytest::getOptions()->getMaxNrOfUsers() > 0 &&
                pFirstMix->getNrOfUsers() >= CALibProxytest::getOptions()->getMaxNrOfUsers())
                && (isAllowedToPassRestrictions(pNewMuxSocket->getCASocket()) != E_SUCCESS)
 
                )
            {
              CAMsg::printMsg(LOG_DEBUG,"CAFirstMix User control: Too many users (Maximum:%d)! Rejecting user...\n", pFirstMix->getNrOfUsers(),CALibProxytest::getOptions()->getMaxNrOfUsers());
              ret = E_UNKNOWN;
            }
            else if ((pFirstMix->m_newConnections > CAFirstMix::MAX_CONCURRENT_NEW_CONNECTIONS)
                && (isAllowedToPassRestrictions(pNewMuxSocket->getCASocket()) != E_SUCCESS)
                )
 
            {
              /* This should protect the mix from flooding attacks
               * No more than MAX_CONCURRENT_NEW_CONNECTIONS are allowed.
               */
#ifdef _DEBUG
              CAMsg::printMsg(LOG_DEBUG,"CAFirstMix Flooding protection: Too many concurrent new connections (Maximum:%d)! Rejecting user...\n", CAFirstMix::MAX_CONCURRENT_NEW_CONNECTIONS);
#endif
              ret = E_UNKNOWN;
            }
//#ifndef PAYMENT
            else if ((ret = pNewMuxSocket->getCASocket()->getPeerIP(peerIP)) != E_SUCCESS ||
                (retPeerIP = pIPList->insertIP(peerIP)) < 0) 
                // || (pIPBlockList->checkIP(peerIP) == E_UNKNOWN && isAllowedToPassRestrictions(pNewMuxSocket->getCASocket()) != E_SUCCESS))
            {
              if (ret != E_SUCCESS)
              {
                CAMsg::printMsg(LOG_DEBUG,"Could not insert IP address as IP could not be retrieved! We have %d login threads currently running.\n", pthreadsLogin->countRequests()); 
  
              }
              else if (retPeerIP < 0)
              {
                CAMsg::printMsg(LOG_DEBUG,"CAFirstMix Flooding protection: Could not insert IP address! We have %d login threads currently running.\n", pthreadsLogin->countRequests()); 
                pIPBlockList->insertIP(peerIP);
              }
              else if (pIPBlockList->checkIP(peerIP) == E_UNKNOWN)
              {
                CAMsg::printMsg(LOG_DEBUG, "Client IP address %u.%u.x.x is temporarily blocked! User login denied. We have %d open sockets and %d new connections.\n", peerIP[0],peerIP[1], CASocket::countOpenSockets(), pFirstMix->m_newConnections);
                pIPList->removeIP(peerIP);
              } 
              ret = E_UNKNOWN;
            }
//#endif
            else
            {
              t_UserLoginData* d=new t_UserLoginData;
              d->pNewUser=pNewMuxSocket;
              d->pMix=pFirstMix;
              memcpy(d->peerIP,peerIP,4);
#ifdef DEBUG
              CAMsg::printMsg(LOG_DEBUG,"%d concurrent client connections.\n", pFirstMix->m_newConnections);
#endif
              if(pthreadsLogin->addRequest(fm_loopDoUserLogin,d)!=E_SUCCESS)
              {
                CAMsg::printMsg(LOG_ERR,"Could not add an login request to the login thread pool!\n");
                ret=E_UNKNOWN;
              }
            }
 
            if (ret != E_SUCCESS)
            {
              delete pNewMuxSocket;
              pNewMuxSocket = NULL;
              pFirstMix->decNewConnections();
              if(ret==E_SOCKETCLOSED&&pFirstMix->m_bRestart) //Hm, should we restart ??
              {
                goto END_THREAD;
              }
              else //if(ret==E_SOCKET_LIMIT) // Hm no free sockets - wait some time to hope to get a free one...
              {
                msSleep(400);
              }
            }
          }
          i++;
        }
      }
END_THREAD:
    FINISH_STACK("CAFirstMix::fm_loopAcceptUsers");
 
    delete[] peerIP;
    peerIP = NULL;
    delete psocketgroupAccept;
    psocketgroupAccept = NULL;
 
    CAMsg::printMsg(LOG_DEBUG,"Exiting Thread AcceptUser\n");
    THREAD_RETURN_SUCCESS;
  }

Referenced by init().

fm_loopDoUserLogin

THREAD_RETURN fm_loopDoUserLogin ( void *  param )

friend

Definition at line 1549 of file CAFirstMix.cpp.

  {
    INIT_STACK;
    BEGIN_STACK("CAFirstMix::fm_loopDoUserLogin");
#ifdef COUNTRY_STATS
    my_thread_init();
#endif
 
    t_UserLoginData* d=(t_UserLoginData*)param;
    d->pMix->doUserLogin(d->pNewUser,d->peerIP);
 
    SAVE_STACK("CAFirstMix::fm_loopDoUserLogin", "after user login");
    d->pMix->decNewConnections();
    delete d;
    d = NULL;
 
#ifdef COUNTRY_STATS
    my_thread_end();
#endif
    FINISH_STACK("CAFirstMix::fm_loopDoUserLogin");
 
    THREAD_RETURN_SUCCESS;
  }

fm_loopLog

THREAD_RETURN fm_loopLog ( void *  )

friend

Definition at line 1494 of file CAFirstMix.cpp.

  {
    CAFirstMix* pFirstMix=(CAFirstMix*)param;
    pFirstMix->m_bRunLog=true;
    UINT32 countLog=0;
    while(pFirstMix->m_bRunLog)
      {
        if(countLog==0)
          {
            logMemoryUsage();
            countLog=10;
          }
        sSleep(30);
        countLog--;
      }
    THREAD_RETURN_SUCCESS;
  }

Referenced by CAFirstMixA::loop().

fm_loopReadFromMix

THREAD_RETURN fm_loopReadFromMix ( void *  )

friend

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

Definition at line 1092 of file CAFirstMix.cpp.

  {
    INIT_STACK;
    BEGIN_STACK("CAFirstMix::fm_loopReadFromMix");
 
    CAFirstMix* pFirstMix=(CAFirstMix*)pParam;
    CAMuxSocket* pMuxSocket=pFirstMix->m_pMuxOut;
    CAQueue* pQueue=pFirstMix->m_pQueueReadFromMix;
    tQueueEntry* pQueueEntry=new tQueueEntry;
    MIXPACKET* pMixPacket=&pQueueEntry->packet;
    CASingleSocketGroup* pSocketGroup=new CASingleSocketGroup(false);
    pSocketGroup->add(*pMuxSocket);
    #ifdef USE_POOL
      CAPool* pPool=new CAPool(MIX_POOL_SIZE);
    #endif
    UINT64 keepaliveNow,keepaliveLast;
    UINT32 u32KeepAliveRecvInterval=pFirstMix->m_u32KeepAliveRecvInterval;
    getcurrentTimeMillis(keepaliveLast);
    CAControlChannelDispatcher* pControlChannelDispatcher=pFirstMix->m_pMuxOutControlChannelDispatcher;
    while (!pFirstMix->m_bRestart)
      {
      if (pQueue->getSize() > MAX_READ_FROM_NEXT_MIX_QUEUE_SIZE)
        {
#ifdef DEBUG
        CAMsg::printMsg(LOG_DEBUG, "CAFirstMix::Queue is full!\n");
#endif
        msSleep(200);
        getcurrentTimeMillis(keepaliveLast);
        continue;
        }
      //check if the connection is broken because we did not received a Keep_alive-Message
      getcurrentTimeMillis(keepaliveNow);
      UINT32 keepaliveDiff = diff64(keepaliveNow, keepaliveLast);
      if (keepaliveDiff > u32KeepAliveRecvInterval)
        {
        CAMsg::printMsg(LOG_DEBUG, "CAFirstMix::loopReadFromMix() -- restart because of KeepAlive-Traffic Timeout!\n");
        pFirstMix->m_bRestart = true;
        MONITORING_FIRE_NET_EVENT(ev_net_nextConnectionClosed);
        break;
        }
      SINT32 ret = pSocketGroup->select(MIX_POOL_TIMEOUT);
      if (ret < 0)
        {
        if (ret == E_TIMEDOUT)
          {
#ifdef USE_POOL
          pMixPacket->flags=CHANNEL_DUMMY;
          pMixPacket->channel=DUMMY_CHANNEL;
          getRandom(pMixPacket->data,DATA_SIZE);
#ifdef LOG_PACKET_TIMES
          setZero64(pQueueEntry->timestamp_proccessing_start);
#endif
#else
          continue;
#endif
          }
        else
          {
          /* another error occured (happens sometimes while debugging because
          * of interruption, if a breakpoint is reached -> poll() returns
          * errorcode EINTR)
          * Note: Any Error on select() does not mean, that the underliny connections have some error state, because
          * in this case select() returns the socket and than this socket returns the error
          */
#ifdef DEBUG
          CAMsg::printMsg(LOG_DEBUG, "CAFirstMix::loopReadFromMix() - socket select error: %i\n",ret);
#endif
          continue;
          }
        }
      else if (ret > 0)
        {
        ret = pMuxSocket->receive(pMixPacket);
#ifdef LOG_PACKET_TIMES
        getcurrentTimeMicros(pQueueEntry->timestamp_proccessing_start);
#endif
        if (ret != MIXPACKET_SIZE)
          {
          pFirstMix->m_bRestart = true;
          CAMsg::printMsg(LOG_ERR, "CAFirstMix::lm_loopReadFromMix - received returned: %i -- restarting!\n", ret);
          MONITORING_FIRE_NET_EVENT(ev_net_nextConnectionClosed);
          break;
        }
        if (pMixPacket->channel > 0 && pMixPacket->channel < 256)
          {
#ifdef DEBUG
          CAMsg::printMsg(LOG_DEBUG, "CAFirstMix - sent a packet from the next mix to the ControlChanelDispatcher... \n");
#endif
          pControlChannelDispatcher->proccessMixPacket(pMixPacket);
          getcurrentTimeMillis(keepaliveLast);
          continue;
          }
      }
#ifdef USE_POOL
#ifdef LOG_PACKET_TIMES
        getcurrentTimeMicros(pQueueEntry->pool_timestamp_in);
#endif
        pPool->pool((tPoolEntry*)pQueueEntry);
#ifdef LOG_PACKET_TIMES
        getcurrentTimeMicros(pQueueEntry->pool_timestamp_out);
#endif
#endif
#ifdef ANON_DEBUG_MODE
        if (pMixPacket->flags&CHANNEL_DEBUG)
          {
          UINT8 base64Payload[DATA_SIZE << 1];
          EVP_EncodeBlock(base64Payload, pMixPacket->data, DATA_SIZE);//base64 encoding (without newline!)
          CAMsg::printMsg(LOG_DEBUG, "Received Downstream AN.ON packet from previous Mix debug: %s\n", base64Payload);
          }
 
#endif
        pQueue->add(pQueueEntry, sizeof(tQueueEntry));
        getcurrentTimeMillis(keepaliveLast); 
        }
    delete pQueueEntry;
    pQueueEntry = NULL;
    delete pSocketGroup;
    pSocketGroup = NULL;
    #ifdef USE_POOL
      delete pPool;
      pPool = NULL;
    #endif
 
    FINISH_STACK("CAFirstMix::fm_loopReadFromMix");
    THREAD_RETURN_SUCCESS;
  }

Referenced by init().

fm_loopSendToMix

THREAD_RETURN fm_loopSendToMix ( void *  )

friend

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

Definition at line 978 of file CAFirstMix.cpp.

  {
    INIT_STACK;
    BEGIN_STACK("CAFirstMix::fm_loopSendToMix");
 
    CAFirstMix* pFirstMix=(CAFirstMix*)param;
    CAQueue* pQueue=((CAFirstMix*)param)->m_pQueueSendToMix;
    CAMuxSocket* pMuxSocket=pFirstMix->m_pMuxOut;
 
    UINT32 len;
    SINT32 ret;
 
/*#ifdef DATA_RETENTION_LOG
    t_dataretentionLogEntry* pDataRetentionLogEntry=new t_dataretentionLogEntry;
#endif
*/
#ifndef USE_POOL
    tQueueEntry* pQueueEntry=new tQueueEntry;
    MIXPACKET* pMixPacket=&pQueueEntry->packet;
    UINT32 u32KeepAliveSendInterval=pFirstMix->m_u32KeepAliveSendInterval;
    while(!pFirstMix->m_bRestart)
      {
        len=sizeof(tQueueEntry);
        ret=pQueue->getOrWait((UINT8*)pQueueEntry,&len,u32KeepAliveSendInterval);
        if(ret==E_TIMEDOUT)
          {//send a dummy as keep-alvie-traffic
            pMixPacket->flags=CHANNEL_DUMMY;
            pMixPacket->channel=DUMMY_CHANNEL;
            getRandom(pMixPacket->data,DATA_SIZE);
          }
        else if(ret!=E_SUCCESS||len!=sizeof(tQueueEntry))
          {
            CAMsg::printMsg(LOG_ERR,"CAFirstMix::lm_loopSendToMix - Error in dequeueing MixPaket\n");
            CAMsg::printMsg(LOG_ERR,"ret=%i len=%i\n",ret,len);
            break;
          }
 
        if(pMuxSocket->send(pMixPacket)!=MIXPACKET_SIZE)
          {
            CAMsg::printMsg(LOG_ERR,"CAFirstMix::lm_loopSendToMix - Error in sending MixPaket\n");
            break;
          }
#if defined (LOG_PACKET_TIMES)
        if(!isZero64(pQueueEntry->timestamp_proccessing_start))
          {
            getcurrentTimeMicros(pQueueEntry->timestamp_proccessing_end);
            pFirstMix->m_pLogPacketStats->addToTimeingStats(*pQueueEntry,pMixPacket->flags,true);
          }
#endif
#ifdef DATA_RETENTION_LOG
        if((pQueueEntry->packet.flags&CHANNEL_OPEN)!=0)
          {
            pQueueEntry->dataRetentionLogEntry.t_out=htonl(time(NULL));
            pFirstMix->m_pDataRetentionLog->log(&(pQueueEntry->dataRetentionLogEntry));
          }
#endif
      }
    delete pQueueEntry;
    pQueueEntry = NULL;
#else
    CAPool* pPool=new CAPool(MIX_POOL_SIZE);
    tPoolEntry* pPoolEntry=new tPoolEntry;
    MIXPACKET* pMixPacket=&pPoolEntry->packet;
    while(!pFirstMix->m_bRestart)
      {
        len=sizeof(tQueueEntry);
        ret=pQueue->getOrWait((UINT8*)pPoolEntry,&len,MIX_POOL_TIMEOUT);
        if(ret==E_TIMEDOUT)
          {
            pMixPacket->flags=CHANNEL_DUMMY;
            pMixPacket->channel=DUMMY_CHANNEL;
            getRandom(pMixPacket->data,DATA_SIZE);
            #ifdef LOG_PACKET_TIMES
              setZero64(pPoolEntry->timestamp_proccessing_start);
            #endif
          }
        else if(ret!=E_SUCCESS||len!=sizeof(tQueueEntry))
          break;
        #ifdef LOG_PACKET_TIMES
          getcurrentTimeMicros(pPoolEntry->pool_timestamp_in);
        #endif
        pPool->pool(pPoolEntry);
        #ifdef LOG_PACKET_TIMES
          getcurrentTimeMicros(pPoolEntry->pool_timestamp_out);
        #endif
        if(pMuxSocket->send(pMixPacket)!=MIXPACKET_SIZE)
          break;
        #ifdef LOG_PACKET_TIMES
          if(!isZero64(pPoolEntry->timestamp_proccessing_start))
            {
              getcurrentTimeMicros(pPoolEntry->timestamp_proccessing_end);
              pFirstMix->m_pLogPacketStats->addToTimeingStats(*pPoolEntry,pMixPacket->flags,true);
            }
        #endif
      }
    delete pPoolEntry;
    pPoolEntry = NULL;
    delete pPool;
    pPool = NULL;
#endif
 
/*#ifdef DATA_RETENTION_LOG
    delete pDataRetentionLogEntry;
#endif
*/
    FINISH_STACK("CAFirstMix::fm_loopSendToMix");
 
    CAMsg::printMsg(LOG_DEBUG,"Exiting Thread SendToMix\n");
    THREAD_RETURN_SUCCESS;
  }

Referenced by init().

iplist_loopDoLogCountries

THREAD_RETURN iplist_loopDoLogCountries ( void *  param )

friend

Definition at line 3067 of file CAFirstMix.cpp.

  {
    mysql_thread_init();
    CAMsg::printMsg(LOG_DEBUG,"Starting iplist_loopDoLogCountries\n");
    CAFirstMix* pFirstMix=(CAFirstMix*)param;
    UINT32 s=0;
    UINT8 buff[255];
    memset(buff,0,255);
    CALibProxytest::getOptions()->getCascadeName(buff,255);
    mysqlEscapeTableName(buff);
    while(pFirstMix->m_bRunLogCountries)
      {
        if(s==LOG_COUNTRIES_INTERVALL)
          {
            UINT8 aktDate[255];
            time_t aktTime=time(NULL);
            strftime((char*)aktDate,255,"%Y%m%d%H%M%S",gmtime(&aktTime));
            char query[1024];
            sprintf(query,"INSERT into `stats_%s` (date,id,count,packets_in,packets_out) VALUES (\"%s\",\"%%u\",\"%%u\",\"%%u\",\"%%u\")",buff,aktDate);
            pFirstMix->m_pmutexUser->lock();
            for(UINT32 i=0;i<NR_OF_COUNTRIES+1;i++)
              {
                if(pFirstMix->m_CountryStats[i]>0)
                  {
                    char aktQuery[1024];
                    sprintf(aktQuery,query,i,pFirstMix->m_CountryStats[i],pFirstMix->m_PacketsPerCountryIN[i].getAndzero(),pFirstMix->m_PacketsPerCountryOUT[i].getAndzero());
                    SINT32 ret=mysql_query(pFirstMix->m_mysqlCon,aktQuery);
                    if(ret!=0)
                    {
                      CAMsg::printMsg(LOG_INFO,"CountryStats DB - failed to update CountryStats DB with new values - error %i\n",ret);
                    }
                  }
              }
            pFirstMix->m_pmutexUser->unlock();
            s=0;
          }
        sSleep(10);
        s++;
      }
    CAMsg::printMsg(LOG_DEBUG,"Exiting iplist_loopDoLogCountries\n");
    mysql_thread_end();
    THREAD_RETURN_SUCCESS;
  }

Referenced by initCountryStats().

Member Data Documentation

m_arMixParameters

tMixParameters* CAFirstMix::m_arMixParameters

protected

Definition at line 461 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), doUserLogin_internal(), getMixParameters(), initMixParameters(), sendReplayTimestampRequestsToAllMixes(), and setMixParameters().

m_arrSocketsIn

CASocket** CAFirstMix::m_arrSocketsIn

protected

Definition at line 457 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), init(), and CAFirstMixB::loop().

m_bIsShuttingDown

bool CAFirstMix::m_bIsShuttingDown

protected

Definition at line 550 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), isShuttingDown(), and CAFirstMixA::shutDown().

m_bRestart

volatile bool CAFirstMix::m_bRestart

protected

Definition at line 456 of file CAFirstMix.hpp.

Referenced by clean(), init(), CAFirstMixA::loop(), CAFirstMixB::loop(), and CAFirstMixA::shutDown().

m_bRunLog

volatile bool CAFirstMix::m_bRunLog

protected

Definition at line 552 of file CAFirstMix.hpp.

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

m_bRunLogCountries

volatile bool CAFirstMix::m_bRunLogCountries

private

Definition at line 532 of file CAFirstMix.hpp.

Referenced by deleteCountryStats(), and initCountryStats().

m_CountryStats

volatile UINT32* CAFirstMix::m_CountryStats

private

Definition at line 533 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), deleteCountryStats(), initCountryStats(), and updateCountryStats().

m_docMixCascadeInfo

XERCES_CPP_NAMESPACE::DOMDocument* CAFirstMix::m_docMixCascadeInfo

protected

Definition at line 495 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), and clean().

m_mysqlCon

MYSQL* CAFirstMix::m_mysqlCon

private

Definition at line 540 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), deleteCountryStats(), initCountryStats(), and updateCountryStats().

m_newConnections

volatile UINT32 CAFirstMix::m_newConnections

private

Definition at line 568 of file CAFirstMix.hpp.

Referenced by decNewConnections(), and incNewConnections().

m_nMixedPackets

UINT64 CAFirstMix::m_nMixedPackets

protected

Definition at line 496 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), getMixedPackets(), incMixedPackets(), and init().

m_nrOfTermsAndConditionsDefs

UINT32 CAFirstMix::m_nrOfTermsAndConditionsDefs

protected

Definition at line 509 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), getTermsAndConditions(), and handleTermsAndConditionsExtension().

m_nrOfTermsAndConditionsTemplates

UINT32 CAFirstMix::m_nrOfTermsAndConditionsTemplates

protected

Definition at line 511 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), getTermsAndConditionsTemplate(), and handleTermsAndConditionsExtension().

m_nSocketsIn

UINT32 CAFirstMix::m_nSocketsIn

protected

Definition at line 455 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), init(), initOnce(), and CAFirstMixB::loop().

m_nUser

volatile UINT32 CAFirstMix::m_nUser

protected

Definition at line 454 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), decUsers(), getNrOfUsers(), incUsers(), CAFirstMixA::loop(), and CAFirstMixB::loop().

m_PacketsPerCountryIN

tUINT32withLock* CAFirstMix::m_PacketsPerCountryIN

protected

Definition at line 536 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), deleteCountryStats(), initCountryStats(), CAFirstMixA::loop(), and CAFirstMixB::loop().

m_PacketsPerCountryOUT

tUINT32withLock* CAFirstMix::m_PacketsPerCountryOUT

protected

Definition at line 537 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), deleteCountryStats(), initCountryStats(), CAFirstMixA::loop(), and CAFirstMixB::loop().

m_pChannelList

CAFirstMixChannelList* CAFirstMix::m_pChannelList

protected

Definition at line 464 of file CAFirstMix.hpp.

Referenced by CAFirstMixA::accountTrafficDownstream(), CAFirstMixA::accountTrafficUpstream(), CAFirstMix(), CAFirstMixA::checkUserConnections(), clean(), CAFirstMixA::closeConnection(), doUserLogin_internal(), CAFirstMixA::finishPacket(), forceKickout(), init(), CAFirstMixA::loop(), CAFirstMixB::loop(), CAFirstMixA::notifyAllUserChannels(), reconfigure(), CAFirstMixA::sendToUsers(), and CAFirstMixA::shutDown().

m_pIPBlockList

CATempIPBlockList* CAFirstMix::m_pIPBlockList

protected

Definition at line 447 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), doUserLogin_internal(), and init().

m_pIPList

CAIPList* CAFirstMix::m_pIPList

protected

Definition at line 446 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), CAFirstMixA::closeConnection(), doUserLogin_internal(), init(), and CAFirstMixB::loop().

m_pmutexLogin

CAMutex* CAFirstMix::m_pmutexLogin

protected

Definition at line 555 of file CAFirstMix.hpp.

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

m_pmutexLoginThreads

CAMutex* CAFirstMix::m_pmutexLoginThreads

protected

Definition at line 502 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), and ~CAFirstMix().

m_pmutexMixedPackets

CAMutex* CAFirstMix::m_pmutexMixedPackets

protected

Definition at line 501 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), incMixedPackets(), and ~CAFirstMix().

m_pmutexNewConnections

CAMutex* CAFirstMix::m_pmutexNewConnections

private

Definition at line 569 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), decNewConnections(), incNewConnections(), and ~CAFirstMix().

m_pmutexUser

CAMutex* CAFirstMix::m_pmutexUser

protected

Definition at line 500 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), decUsers(), incUsers(), and ~CAFirstMix().

m_pMuxOut

CAMuxSocket* CAFirstMix::m_pMuxOut

protected

Definition at line 490 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), connectToNextMix(), init(), and CAFirstMixB::loop().

m_pQueueReadFromMix

CAQueue* CAFirstMix::m_pQueueReadFromMix

protected

Definition at line 449 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), init(), CAFirstMixA::loop(), and CAFirstMixB::loop().

m_pQueueSendToMix

CAQueue* CAFirstMix::m_pQueueSendToMix

protected

Definition at line 448 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), CAFirstMixA::closeConnection(), init(), CAFirstMixA::loop(), CAFirstMixB::loop(), and CAFirstMixA::notifyAllUserChannels().

m_pRSA

CAASymCipher* CAFirstMix::m_pRSA

protected

Definition at line 497 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), and doUserLogin_internal().

m_psocketgroupUsersRead

CASocketGroupEpoll* CAFirstMix::m_psocketgroupUsersRead

protected

Definition at line 466 of file CAFirstMix.hpp.

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

m_psocketgroupUsersWrite

CASocketGroupEpoll* CAFirstMix::m_psocketgroupUsersWrite

protected

Definition at line 467 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), CAFirstMixA::closeConnection(), init(), CAFirstMixA::loop(), CAFirstMixB::loop(), and CAFirstMixA::sendToUsers().

m_pthreadAcceptUsers

CAThread* CAFirstMix::m_pthreadAcceptUsers

protected

Definition at line 504 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), init(), CAFirstMixB::loop(), and CAFirstMixA::shutDown().

m_pthreadReadFromMix

CAThread* CAFirstMix::m_pthreadReadFromMix

protected

Definition at line 507 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), init(), and CAFirstMixB::loop().

m_pthreadSendToMix

CAThread* CAFirstMix::m_pthreadSendToMix

protected

Definition at line 506 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), init(), and CAFirstMixB::loop().

m_pthreadsLogin

CAThreadPool* CAFirstMix::m_pthreadsLogin

protected

Definition at line 505 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), init(), and CAFirstMixB::loop().

m_tcTemplates

DOMNode** CAFirstMix::m_tcTemplates

protected

Definition at line 512 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), getTermsAndConditionsTemplate(), and handleTermsAndConditionsExtension().

m_templatesOwner

XERCES_CPP_NAMESPACE::DOMDocument* CAFirstMix::m_templatesOwner

protected

Definition at line 513 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), handleTermsAndConditionsExtension(), and init().

m_threadLogLoop

CAThread* CAFirstMix::m_threadLogLoop

private

Definition at line 539 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), deleteCountryStats(), and initCountryStats().

m_tnCDefs

TermsAndConditions** CAFirstMix::m_tnCDefs

protected

Definition at line 510 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), getTermsAndConditions(), and handleTermsAndConditionsExtension().

m_u32MixCount

UINT32 CAFirstMix::m_u32MixCount

protected

Definition at line 459 of file CAFirstMix.hpp.

Referenced by clean(), getMixCount(), initMixParameters(), sendReplayTimestampRequestsToAllMixes(), and setMixParameters().

m_u64LastTimestampReceived

UINT64 CAFirstMix::m_u64LastTimestampReceived

Definition at line 393 of file CAFirstMix.hpp.

Referenced by doUserLogin_internal(), init(), and setMixParameters().

m_xmlKeyInfoBuff

UINT8* CAFirstMix::m_xmlKeyInfoBuff

protected

Definition at line 492 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), clean(), and doUserLogin_internal().

m_xmlKeyInfoSize

UINT16 CAFirstMix::m_xmlKeyInfoSize

protected

Definition at line 493 of file CAFirstMix.hpp.

Referenced by doUserLogin_internal().

MAX_CONCURRENT_NEW_CONNECTIONS

const UINT32 CAFirstMix::MAX_CONCURRENT_NEW_CONNECTIONS = NUM_LOGIN_WORKER_TRHEADS * 2

staticprivate

Definition at line 566 of file CAFirstMix.hpp.

TNC_CONFIRM

const XMLCh* CAFirstMix::TNC_CONFIRM

protected

Definition at line 517 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), and handleTermsAndConditionsLogin().

TNC_INTERRUPT

const XMLCh* CAFirstMix::TNC_INTERRUPT

protected

Definition at line 518 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), and handleTermsAndConditionsLogin().

TNC_REQUEST

const XMLCh* CAFirstMix::TNC_REQUEST

protected

Definition at line 516 of file CAFirstMix.hpp.

Referenced by CAFirstMix(), and handleTermsAndConditionsLogin().

---

The documentation for this class was generated from the following files:

• CAFirstMix.hpp
• CAFirstMix.cpp