CAMix Class Reference

#include <CAMix.hpp>

Inheritance diagram for CAMix:

Collaboration diagram for CAMix:

Public Types
enum	tMixType { FIRST_MIX , MIDDLE_MIX , LAST_MIX , JAP }

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

Static Public Attributes
static const UINT32	TIMEOUT_MIX_CONNECTION_ESTABLISHEMENT = 60000

Protected Member Functions
virtual SINT32	clean ()=0
virtual SINT32	initOnce ()
virtual SINT32	init ()=0
virtual SINT32	loop ()=0
SINT32	checkCompatibility (DOMNode *a_parent, const char *a_mixPosition)
SINT32	appendCompatibilityInfo (DOMNode *a_parent)
SINT32	addMixInfo (DOMNode *a_element, bool a_bForceFirstNode)
virtual SINT32	processKeyExchange ()=0
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
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
bool	needAutoConfig ()
	This method checks if target interfaces (network adress and port of next mix) have been specified in the config file. More...

Detailed Description

Definition at line 48 of file CAMix.hpp.

Member Enumeration Documentation

tMixType

enum CAMix::tMixType

Enumerator
FIRST_MIX
MIDDLE_MIX
LAST_MIX
JAP

Definition at line 51 of file CAMix.hpp.

      {
      FIRST_MIX,
      MIDDLE_MIX,
      LAST_MIX,
      JAP
      };

Constructor & Destructor Documentation

CAMix()

CAMix::CAMix

(

)

Definition at line 39 of file CAMix.cpp.

  {
  m_acceptReconfiguration = CALibProxytest::getOptions()->acceptReconfiguration();
  //m_pSignature=NULL;
  m_pMultiSignature=NULL;
  m_pInfoService=NULL;
  m_pMuxOutControlChannelDispatcher=NULL;
  m_pMuxInControlChannelDispatcher=NULL;
  m_u32KeepAliveSendInterval=0;//zero means --> do not use
  m_u32KeepAliveRecvInterval=0;//zero means --> do not use
  m_bShutDown = false;
  m_docMixCascadeInfo=NULL;
  m_bConnected = false;
  m_lLastConnectionTime = 0;
//#ifdef DYNAMIC_MIX
  /* LERNGRUPPE: Run by default */
  m_bLoop = true;
#ifdef DYNAMIC_MIX
  m_bReconfiguring = false;
  m_bCascadeEstablished = false;
  m_bReconfigured = false;
#endif
#ifdef DATA_RETENTION_LOG
  m_pDataRetentionLog=NULL;
#endif
  }

References CACmdLnOptions::acceptReconfiguration(), CALibProxytest::getOptions(), m_acceptReconfiguration, m_bConnected, m_bLoop, m_bReconfiguring, m_bShutDown, m_docMixCascadeInfo, m_lLastConnectionTime, m_pInfoService, m_pMultiSignature, m_pMuxInControlChannelDispatcher, m_pMuxOutControlChannelDispatcher, m_u32KeepAliveRecvInterval, and m_u32KeepAliveSendInterval.

Here is the call graph for this function:

~CAMix()

CAMix::~CAMix ( )

virtual

Definition at line 66 of file CAMix.cpp.

  {
#ifdef DATA_RETENTION_LOG
  if(m_pDataRetentionLog!=NULL)
    {
    delete m_pDataRetentionLog;
    m_pDataRetentionLog=NULL;
    }
#endif
 
  }

Member Function Documentation

acceptsReconfiguration()

bool CAMix::acceptsReconfiguration ( )

inline

Definition at line 110 of file CAMix.hpp.

      {
        return m_acceptReconfiguration;
      }

References m_acceptReconfiguration.

addMixInfo()

SINT32 CAMix::addMixInfo ( DOMNode *  a_element, bool  a_bForceFirstNode  )

protected

Definition at line 437 of file CAMix.cpp.

  {
    // this is a complete mixinfo node to be sent to the InfoService
    XERCES_CPP_NAMESPACE::DOMDocument* docMixInfo=NULL;
    if(CALibProxytest::getOptions()->getMixXml(docMixInfo)!=E_SUCCESS)
      {
        return E_UNKNOWN;
      }
    DOMNode* nodeMixInfo = a_element->getOwnerDocument()->importNode(docMixInfo->getDocumentElement(), true);
    if (a_bForceFirstNode && a_element->hasChildNodes())
      {
        a_element->insertBefore(nodeMixInfo, a_element->getFirstChild());
      }
    else
      {
        a_element->appendChild(nodeMixInfo);
      }
    return E_SUCCESS;
  }

References E_SUCCESS, E_UNKNOWN, and CALibProxytest::getOptions().

Referenced by initMixCascadeInfo(), CALastMix::processKeyExchange(), and CAMiddleMix::processKeyExchange().

Here is the call graph for this function:

Here is the caller graph for this function:

appendCompatibilityInfo()

SINT32 CAMix::appendCompatibilityInfo ( DOMNode *  a_parent )

protected

EDIT HERE FOR INTRODUCING NEW FLAGS!

Definition at line 634 of file CAMix.cpp.

  {
  DOMElement* elemCompatibility=createDOMElement(a_parent->getOwnerDocument(),"Compatibility");
  setDOMElementAttribute(elemCompatibility,"version",(UINT8*)MIX_VERSION);
  a_parent->appendChild(elemCompatibility);
 
  DOMElement* elemFlags=NULL;
  DOMElement* elemFlag=NULL;
 
  elemFlags = createDOMElement(a_parent->getOwnerDocument(), "Flags");
  elemCompatibility->appendChild(elemFlags);
 
#ifdef PAYMENT
  elemFlag = createDOMElement(a_parent->getOwnerDocument(), PAYMENT_COMPATIBILITY);
  //setDOMElementValue(elemFlag,(UINT8*)"true"); // you might add a version number here for a protocol etc.
  elemFlags->appendChild(elemFlag);
#endif
 
  elemFlag = createDOMElement(a_parent->getOwnerDocument(), NEW_FLOW_CONTROL_COMPATIBILITY);
  //setDOMElementValue(elemFlag,(UINT8*)"true");
  elemFlags->appendChild(elemFlag);
 
  elemFlag = createDOMElement(a_parent->getOwnerDocument(), NEW_CHANNEL_ENCRYPTION_COMPATIBILITY);
  //setDOMElementValue(elemFlag,(UINT8*)"true");
  elemFlags->appendChild(elemFlag);
 
#ifdef WITH_INTEGRITY_CHECK
  elemFlag = createDOMElement(a_parent->getOwnerDocument(), WITH_INTEGRITY_CHECK_COMPATIBILITY);
  //setDOMElementValue(elemFlag,(UINT8*)"true");
  elemFlags->appendChild(elemFlag);
#endif
 
  return E_SUCCESS;
  }

References createDOMElement(), E_SUCCESS, MIX_VERSION, NEW_CHANNEL_ENCRYPTION_COMPATIBILITY, NEW_FLOW_CONTROL_COMPATIBILITY, PAYMENT_COMPATIBILITY, setDOMElementAttribute(), and WITH_INTEGRITY_CHECK_COMPATIBILITY.

Referenced by CALastMix::processKeyExchange(), and CAMiddleMix::processKeyExchange().

Here is the call graph for this function:

Here is the caller graph for this function:

checkCompatibility()

SINT32 CAMix::checkCompatibility ( DOMNode *  a_parent, const char *  a_mixPosition  )

protected

EDIT HERE FOR ADDING INCOMPATIBLE VERSIONS!

EDIT HERE FOR INTRODUCING NEW FLAGS!

EDIT HERE FOR INTRODUCING NEW FLAGS!

Definition at line 670 of file CAMix.cpp.

  {
  // get compatibility info
  DOMElement* elemCompatibility=NULL;
  DOMElement* elemFlags=NULL;
  DOMElement* elemDummy=NULL;
  UINT8 strAllFlags[500];
  UINT32 lenAllFlags;
  UINT8 strNodeName[50];
  UINT32 lenNodeName=50;
  UINT8 strVersion[50];
  UINT32 len=50;
  SINT32 iCompare;
  UINT8* strComment;
  UINT32 iCountFlags = 0;
  UINT32 iLogLevel = LOG_INFO;
  bool bCompatible = true;
  bool bCompatibleFlags = true;
 
  if (getDOMChildByName(a_parent,"Compatibility",elemCompatibility,false) != E_SUCCESS ||
      getDOMElementAttribute(elemCompatibility, "version", strVersion, &len) != E_SUCCESS)
    {
    CAMsg::printMsg(LOG_WARNING,"Could not get any compatibility information from the %s mix. It may or may not be compatible. If the connection fails for an unknown reason, the %s mix should be updated.\n", a_mixPosition, a_mixPosition);
    return E_SUCCESS;
    }
 
  iCompare = strncmp (MIX_VERSION, (char*)strVersion, len);
 
  if (iCompare == 0)
    {
    strComment = (UINT8*)" We have the same version.";
    }
  else if (iCompare < 0)
    {
    strComment = (UINT8*)" Our version (" MIX_VERSION ") might be too old. If the connection fails for an unknown reason, you should think about an update.";
    iLogLevel = LOG_WARNING;
    }
  else
    {
    if (strncmp ("00.08.71", (char*)strVersion, len) > 0)
      {
      strComment = (UINT8*)" This version is NOT COMPATIBLE with our version (" MIX_VERSION ")! The mixes will not work together in a cascade.";
      bCompatible = false;
      iLogLevel = LOG_CRIT;
      }
    else
      {
      strComment = (UINT8*)" We have a newer version (" MIX_VERSION "), but both are known to work fine together.";
      }
    }
 
  CAMsg::printMsg(iLogLevel,"The software version of the %s mix is %s.%s\n", a_mixPosition, strVersion, strComment);
 
#ifdef PAYMENT
  iCountFlags++;
#endif
 
  iCountFlags++;
 
  iCountFlags++;
 
#ifdef WITH_INTEGRITY_CHECK
  iCountFlags++;
#endif
 
  if (getDOMChildByName(elemCompatibility, "Flags", elemFlags, false) == E_SUCCESS)
    {
    DOMNodeList* flags = elemFlags->getChildNodes();
    if (flags->getLength() != iCountFlags)
      {
      bCompatibleFlags = false;
      }
 
    // Hint: We might also check for a version of the compile flags if available; it should be set in the content of each tag instead of 'true'.
#ifdef PAYMENT
    if (getDOMChildByName(elemFlags, PAYMENT_COMPATIBILITY, elemDummy, false) != E_SUCCESS)
      {
      bCompatibleFlags = false;
      }
#endif
    if (getDOMChildByName(elemFlags, NEW_FLOW_CONTROL_COMPATIBILITY, elemDummy, false) != E_SUCCESS)
      {
      bCompatibleFlags = false;
      }
    if (getDOMChildByName(elemFlags, NEW_CHANNEL_ENCRYPTION_COMPATIBILITY, elemDummy, false) != E_SUCCESS)
      {
      bCompatibleFlags = false;
      }
#ifdef WITH_INTEGRITY_CHECK
    if (getDOMChildByName(elemFlags, WITH_INTEGRITY_CHECK_COMPATIBILITY, elemDummy, false) != E_SUCCESS)
      {
      bCompatibleFlags = false;
      }
#endif
 
    if (!bCompatibleFlags)
      {
      // get the flags of the other mix
      strAllFlags[0] = 0;
      lenAllFlags = 1;
      for (UINT32 i = 0; i < flags->getLength(); i++)
        {
        if (::getNodeName(flags->item(i), strNodeName, &lenNodeName) == E_SUCCESS)
          {
 
          lenAllFlags += strlen((char*)strNodeName) + 1;
          if (lenAllFlags > 500)
            {
            break;
            }
          strcat((char*)strAllFlags, " ");
          strcat((char*)strAllFlags, (char*)strNodeName);
          }
 
        lenNodeName = 50;
        }
 
      CAMsg::printMsg(LOG_CRIT, "The compile flags of the %s mix are NOT COMPATIBLE with our flags. We have: %s They have: %s  --> The mixes won't run together.\n", a_mixPosition, MIX_VERSION_COMPATIBILITY, strAllFlags);
      return E_UNKNOWN;
 
      }
    }
 
 
  if (!bCompatible)
    {
    return E_UNKNOWN;
    }
 
  return E_SUCCESS;
  }

References E_SUCCESS, E_UNKNOWN, flags, getDOMChildByName(), getDOMElementAttribute(), getNodeName(), len, MIX_VERSION, MIX_VERSION_COMPATIBILITY, NEW_CHANNEL_ENCRYPTION_COMPATIBILITY, NEW_FLOW_CONTROL_COMPATIBILITY, PAYMENT_COMPATIBILITY, CAMsg::printMsg(), and WITH_INTEGRITY_CHECK_COMPATIBILITY.

Referenced by CALastMix::processKeyExchange(), and CAMiddleMix::processKeyExchange().

Here is the call graph for this function:

Here is the caller graph for this function:

clean()

virtual SINT32 CAMix::clean ( )

protectedpure virtual

Implemented in CAMiddleMix, CALastMix, and CAFirstMix.

Referenced by start().

Here is the caller graph for this function:

getDownstreamControlChannelDispatcher()

CAControlChannelDispatcher* CAMix::getDownstreamControlChannelDispatcher ( ) const

inline

Definition at line 115 of file CAMix.hpp.

      {
        return m_pMuxInControlChannelDispatcher;
      }

References m_pMuxInControlChannelDispatcher.

Referenced by CAReplayCtrlChannelMsgProc::CAReplayCtrlChannelMsgProc(), and CAReplayCtrlChannelMsgProc::~CAReplayCtrlChannelMsgProc().

Here is the caller graph for this function:

getLastConnectionTime()

UINT32 CAMix::getLastConnectionTime ( )

inline

Definition at line 125 of file CAMix.hpp.

      {
        return m_lLastConnectionTime;
      }

References m_lLastConnectionTime.

Referenced by CAInfoService::InfoLoop().

Here is the caller graph for this function:

getMixCascadeInfo()

SINT32 CAMix::getMixCascadeInfo ( XERCES_CPP_NAMESPACE::DOMDocument *&  docMixCascadeInfo )

inline

Returns the Mix-Cascade info which should be send to the InfoService.

This is NOT a copy!

Parameters

docMixCascadeInfo

where the XML struct would be stored

Return values

E_SUCCESS

Definition at line 96 of file CAMix.hpp.

      {
        if (m_docMixCascadeInfo != NULL)
          {
            docMixCascadeInfo = m_docMixCascadeInfo;
            return E_SUCCESS;
          }
        else
          {
            return E_UNKNOWN;
          }
      }

References E_SUCCESS, E_UNKNOWN, and m_docMixCascadeInfo.

Referenced by CAInfoService::getCascadeHeloXMLAsString(), and CAAccountingInstance::prepareCCRequest().

Here is the caller graph for this function:

getType()

virtual tMixType CAMix::getType ( ) const

pure virtual

Implemented in CAMiddleMix, CALastMix, and CAFirstMix.

Referenced by CAReplayCtrlChannelMsgProc::initTimestampsMessageTemplate(), CAReplayCtrlChannelMsgProc::proccessGetTimestamp(), and CAReplayCtrlChannelMsgProc::proccessGotTimestamp().

Here is the caller graph for this function:

getUpstreamControlChannelDispatcher()

CAControlChannelDispatcher* CAMix::getUpstreamControlChannelDispatcher ( ) const

inline

Definition at line 120 of file CAMix.hpp.

      {
        return m_pMuxOutControlChannelDispatcher;
      }

References m_pMuxOutControlChannelDispatcher.

Referenced by CAReplayCtrlChannelMsgProc::CAReplayCtrlChannelMsgProc(), and CAReplayCtrlChannelMsgProc::~CAReplayCtrlChannelMsgProc().

Here is the caller graph for this function:

init()

virtual SINT32 CAMix::init ( )

protectedpure virtual

Implemented in CAMiddleMix, CALastMix, and CAFirstMix.

Referenced by start().

Here is the caller graph for this function:

initMixCascadeInfo()

SINT32 CAMix::initMixCascadeInfo ( DOMElement *  mixes )

protectedvirtual

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

Parameters

mixes

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

Return values

E_UNKNOWN	if processing produces an error
E_SUCCESS	otherwise

Reimplemented in CAMiddleMix, and CALastMix.

Definition at line 299 of file CAMix.cpp.

  {
  UINT32 count;
  m_docMixCascadeInfo=createDOMDocument();
  DOMElement* elemRoot=createDOMElement(m_docMixCascadeInfo,"MixCascade");
#ifdef LOG_DIALOG
  setDOMElementAttribute(elemRoot,"study",(UINT8*)"true");
#endif
  if(CALibProxytest::getOptions()->isFirstMix())
    {
    UINT32 maxUsers = CALibProxytest::getOptions()->getMaxNrOfUsers();
    if(maxUsers > 0)
      {
      setDOMElementAttribute(elemRoot,"maxUsers", maxUsers);
      }
    setDOMElementAttribute(elemRoot, "maxOpenChannels", CHANNELS_PER_CLIENT);
 
#ifdef MANIOQ
    setDOMElementAttribute(elemRoot,"context", (UINT8*) "jondonym.business");
#else
 
#ifdef PAYMENT
    setDOMElementAttribute(elemRoot,"context", (UINT8*) "jondonym.premium");
#else
    setDOMElementAttribute(elemRoot,"context", (UINT8*) "jondonym");
#endif
#endif
    }
 
  UINT8 id[50];
  UINT8* cascadeID=NULL;
  CALibProxytest::getOptions()->getMixId(id,50);
 
  UINT8 name[255];
  m_docMixCascadeInfo->appendChild(elemRoot);
  DOMElement* elem = NULL;
 
  if(CALibProxytest::getOptions()->getCascadeName(name,255) == E_SUCCESS)
    {
    elem = createDOMElement(m_docMixCascadeInfo,"Name");
    setDOMElementValue(elem,name);
    elemRoot->appendChild(elem);
    }
  else
    {
    CAMsg::printMsg(LOG_ERR,"No cascade name given!\n");
    }
 
  elem=createDOMElement(m_docMixCascadeInfo,"Network");
  elemRoot->appendChild(elem);
  DOMElement* elemListenerInterfaces=createDOMElement(m_docMixCascadeInfo,"ListenerInterfaces");
  elem->appendChild(elemListenerInterfaces);
 
 
  for(UINT32 i=1; i<=CALibProxytest::getOptions()->getListenerInterfaceCount(); i++)
    {
    CAListenerInterface* pListener=CALibProxytest::getOptions()->getListenerInterface(i);
    if(pListener->isHidden())
      {
      //do nothing
      }
    else if(pListener->getType()==RAW_TCP|| pListener->getType() == RAW_UDP)
      {//Only TCP or UDP interfaces are meaningfull for external connections...
        DOMElement* elemTmpLI=NULL;
        pListener->toDOMElement(elemTmpLI,m_docMixCascadeInfo);
        elemListenerInterfaces->appendChild(elemTmpLI);
      }
    delete pListener;
    pListener = NULL;
    }
 
  DOMNode* elemMixesDocCascade=createDOMElement(m_docMixCascadeInfo,"Mixes");
  DOMElement* elemMix=NULL;
  count=1;
  if(CALibProxytest::getOptions()->isFirstMix())
    {
    addMixInfo(elemMixesDocCascade, false);
    getDOMChildByName(elemMixesDocCascade, "Mix", elemMix, false);
    // create signature
    if (signXML(elemMix) != E_SUCCESS)
      {
      CAMsg::printMsg(LOG_DEBUG,"Could not sign KeyInfo sent to users...\n");
      }
    //if(m_pSignature->signXML(docMixInfo,m_pcertstoreOwnCerts)!=E_SUCCESS)
    //m_pSignature, CALibProxytest::getOptions()->getOwnCertificate()
    /*
        elemMixesDocCascade.appendChild(elemThisMix);*/
    }
  elemRoot->appendChild(elemMixesDocCascade);
 
//    UINT8 cascadeId[255];
//    UINT32 cascadeIdLen=255;
 
  DOMNode* node=mixes->getFirstChild();
  while(node!=NULL)
    {
    if(node->getNodeType()==DOMNode::ELEMENT_NODE&&equals(node->getNodeName(),"Mix"))
      {
      elemMixesDocCascade->appendChild(m_docMixCascadeInfo->importNode(node,true));
      count++;
//           cascadeId = static_cast<const DOM_Element&>(node).getAttribute("id").transcode();
      }
    node=node->getNextSibling();
    }
 
  if(CALibProxytest::getOptions()->isLastMix())
    {
    addMixInfo(elemMixesDocCascade, false);
    ::getLastDOMChildByName(elemMixesDocCascade, "Mix", elemMix);
    // create signature
    if (signXML(elemMix) != E_SUCCESS)
      {
      CAMsg::printMsg(LOG_DEBUG,"Could not sign KeyInfo sent to users...\n");
      }
    cascadeID = id;
    }
  else if(CALibProxytest::getOptions()->isFirstMix())
    {
    cascadeID = id;
    }
 
  if(cascadeID != NULL)
    { setDOMElementAttribute(elemRoot,"id",cascadeID); }
  setDOMElementAttribute(elemMixesDocCascade,"count",count);
 
  DOMNode* elemPayment=createDOMElement(m_docMixCascadeInfo,"Payment");
  elemRoot->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
  return E_SUCCESS;
  }

References addMixInfo(), CHANNELS_PER_CLIENT, createDOMDocument(), createDOMElement(), E_SUCCESS, equals(), getDOMChildByName(), getLastDOMChildByName(), CACmdLnOptions::getListenerInterface(), CACmdLnOptions::getListenerInterfaceCount(), CACmdLnOptions::getMaxNrOfUsers(), CACmdLnOptions::getMixId(), CALibProxytest::getOptions(), CAListenerInterface::getType(), CAListenerInterface::isHidden(), m_docMixCascadeInfo, PAYMENT_VERSION, CAMsg::printMsg(), RAW_TCP, RAW_UDP, setDOMElementAttribute(), setDOMElementValue(), signXML(), and CAListenerInterface::toDOMElement().

Referenced by CALastMix::initMixCascadeInfo().

Here is the call graph for this function:

Here is the caller graph for this function:

initOnce()

SINT32 CAMix::initOnce ( )

protectedvirtual

Reimplemented in CAMiddleMix, CALastMix, and CAFirstMix.

Definition at line 78 of file CAMix.cpp.

  {
#ifdef DATA_RETENTION_LOG
  m_pDataRetentionLog=new CADataRetentionLog();
  CAASymCipher* pKey=NULL;
  CALibProxytest::getOptions()->getDataRetentionPublicEncryptionKey(&pKey);
  if(m_pDataRetentionLog->setPublicEncryptionKey(pKey)!=E_SUCCESS)
    { return E_UNKNOWN; }
  UINT8 strDir[4096];
  strDir[0]=0;
  if(CALibProxytest::getOptions()->getDataRetentionLogDir(strDir,4096)!=E_SUCCESS ||
      m_pDataRetentionLog->setLogDir(strDir)!=E_SUCCESS)
    {
    CAMsg::printMsg(LOG_ERR,"Data Retention Error: Could not set log dir to %s!\n",strDir);
    return E_UNKNOWN;
    }
  else
    {
    CAMsg::printMsg(LOG_INFO,"Data Retention: Set log dir to: %s\n",strDir);
    CAMsg::printMsg(LOG_INFO,"Data Retention: tQueueEntry size is: %u\n",sizeof(tQueueEntry));
    }
 
#endif
  return E_SUCCESS;
  }

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

Referenced by CAFirstMix::initOnce(), CALastMix::initOnce(), and start().

Here is the call graph for this function:

Here is the caller graph for this function:

isConnected()

bool CAMix::isConnected ( )

inline

Definition at line 130 of file CAMix.hpp.

      {
        return m_bConnected;
      }

References m_bConnected.

Referenced by CAInfoService::InfoLoop(), CAInfoService::sendCascadeHelo(), and CAInfoService::sendStatus().

Here is the caller graph for this function:

isShutDown()

virtual bool CAMix::isShutDown ( )

inlinevirtual

Definition at line 77 of file CAMix.hpp.

      {
        return m_bShutDown;
      }

References m_bShutDown.

Referenced by my_terminate().

Here is the caller graph for this function:

loop()

virtual SINT32 CAMix::loop ( )

protectedpure virtual

Implemented in CALastMix, CAFirstMix, CALastMixB, CAFirstMixB, CALastMixA, CAFirstMixA, and CAMiddleMix.

Referenced by start().

Here is the caller graph for this function:

needAutoConfig()

bool CAMix::needAutoConfig ( )

private

This method checks if target interfaces (network adress and port of next mix) have been specified in the config file.

A return value of true means that necessary information to bring the cascade online is missing and must be downloaded from the InfoService (if available).

Return values

false	if the target interfaces are configured one way or another
true	if config file contains no target interface info and InfoService is unavailable

Definition at line 263 of file CAMix.cpp.

  {
  bool ret = false;
 
  if(!CALibProxytest::getOptions()->isLastMix())
    {
    ret = true;
 
    // look for usable target interfaces
    for(UINT32 i=0; i<CALibProxytest::getOptions()->getTargetInterfaceCount(); i++)
      {
      CATargetInterface oNextMix;
      CALibProxytest::getOptions()->getTargetInterface(oNextMix,i+1);
      if(oNextMix.getTargetType()==TARGET_MIX)
        {
        ret = false;
        }
      oNextMix.cleanAddr();
      }
 
    if(!CALibProxytest::getOptions()->hasNextMixTestCertificate())
      { ret = true; }
    }
 
  if(!CALibProxytest::getOptions()->isFirstMix() && !CALibProxytest::getOptions()->hasPrevMixTestCertificate())
    { ret = true; }
 
  return ret;
  }

References CATargetInterface::cleanAddr(), CALibProxytest::getOptions(), CACmdLnOptions::getTargetInterface(), CACmdLnOptions::getTargetInterfaceCount(), CATargetInterface::getTargetType(), and TARGET_MIX.

Referenced by start().

Here is the call graph for this function:

Here is the caller graph for this function:

processKeyExchange()

virtual SINT32 CAMix::processKeyExchange ( )

protectedpure virtual

Implemented in CAMiddleMix, CALastMix, and CAFirstMix.

reconfigure()

virtual SINT32 CAMix::reconfigure ( )

inlinevirtual

Reimplemented in CALastMix, and CAFirstMix.

Definition at line 65 of file CAMix.hpp.

      {
        return E_SUCCESS;
      }

References E_SUCCESS.

shutDown()

virtual void CAMix::shutDown ( )

inlinevirtual

Reimplemented in CAFirstMixA.

Definition at line 71 of file CAMix.hpp.

      {
        m_bShutDown = true;
        m_bLoop=false;
      }

References m_bLoop, and m_bShutDown.

Referenced by my_terminate().

Here is the caller graph for this function:

signXML()

SINT32 CAMix::signXML ( DOMNode *  a_element )

protected

Definition at line 806 of file CAMix.cpp.

  {
  return m_pMultiSignature->signXML(a_element, true);
  /*CACertStore* tmpCertStore=new CACertStore();
 
  CACertificate* ownCert=CALibProxytest::getOptions()->getOwnCertificate();
  if(ownCert==NULL)
    {
      CAMsg::printMsg(LOG_DEBUG,"Own Test Cert is NULL!\n");
    }
 
  // Operator Certificates
  CACertificate* opCert = CALibProxytest::getOptions()->getOpCertificate();
  if(opCert==NULL)
  {
      CAMsg::printMsg(LOG_DEBUG,"Op Test Cert is NULL!\n");
  }
  else
  {
  // Own  Mix Certificates first, then Operator Certificates
  tmpCertStore->add(opCert);
  }
  tmpCertStore->add(ownCert);
 
  if(m_pSignature->signXML(a_element, tmpCertStore)!=E_SUCCESS)
  {
  return E_UNKNOWN;
  }
 
  CASignature* test = new CASignature();
  test->setVerifyKey(ownCert);
 
  if(test->verifyXML(a_element) != E_SUCCESS)
  {
  CAMsg::printMsg(LOG_DEBUG, "Error verifying own Signature!!\n");
  m_pSignature->signXML(a_element, tmpCertStore);
  }
  else
  {
  CAMsg::printMsg(LOG_DEBUG, "Own Signature looks ok!\n");
  }
 
 
  delete ownCert;
  ownCert = NULL;
 
  delete opCert;
  opCert = NULL;
 
  delete tmpCertStore;
  tmpCertStore = NULL;
 
  return E_SUCCESS;*/
  }

References m_pMultiSignature, and CAMultiSignature::signXML().

Referenced by initMixCascadeInfo(), CALastMix::processKeyExchange(), and CAMiddleMix::processKeyExchange().

Here is the call graph for this function:

Here is the caller graph for this function:

start()

SINT32 CAMix::start

(

)

Definition at line 104 of file CAMix.cpp.

  {
  SINT32 initStatus;
  m_bConnected = false;
  m_lLastConnectionTime = 0;
  m_bLoop=true;
 
  if(initOnce()!=E_SUCCESS)
    { return E_UNKNOWN; }
  if(m_pMultiSignature != NULL && CALibProxytest::getOptions()->isInfoServiceEnabled())
    {
    CAMsg::printMsg(LOG_DEBUG, "CAMix start: creating InfoService object\n");
    m_pInfoService=new CAInfoService(this);
 
    //UINT32 opCertLength;
    //CACertificate* opCert = CALibProxytest::getOptions()->getOpCertificate();
    //CACertificate* pOwnCert=CALibProxytest::getOptions()->getOwnCertificate();
    m_pInfoService->setMultiSignature(m_pMultiSignature);
    //delete pOwnCert;
    //pOwnCert = NULL;
    UINT64 currentMillis;
    if (getcurrentTimeMillis(currentMillis) != E_SUCCESS)
      {
      currentMillis = 0;
      }
    m_pInfoService->setSerial(currentMillis);
 
    //delete opCert;
    //opCert = NULL;
 
    bool allowReconf = CALibProxytest::getOptions()->acceptReconfiguration();
    bool needReconf = needAutoConfig();
 
    m_pInfoService->setConfiguring(allowReconf && needReconf);
    CAMsg::printMsg(LOG_DEBUG, "CAMix start: starting InfoService\n");
    m_pInfoService->start();
    }
  else
    {
    m_pInfoService = NULL;
    }
  bool allowReconf = CALibProxytest::getOptions()->acceptReconfiguration();
//#ifdef DYNAMIC_MIX
  /* LERNGRUPPE: We might want to break out of this loop if the mix-type changes */
  while(m_bLoop)
//#else
//  for(;;)
//#endif
    {
    if (m_pInfoService != NULL)
      { m_pInfoService->setConfiguring(allowReconf && needAutoConfig()); }
    while(allowReconf && (needAutoConfig() || m_bReconfiguring))
      {
      CAMsg::printMsg(LOG_DEBUG, "Not configured -> sleeping\n");
      sSleep(20);
      }
//#ifdef DYNAMIC_MIX
    // if we change the mix type, we must not enter init!
    if(!m_bLoop) { goto SKIP; }
//#endif
    CAMsg::printMsg(LOG_DEBUG, "CAMix main: before init()\n");
    initStatus = init();
    if(initStatus == E_SUCCESS)
      {
      m_lLastConnectionTime = time(NULL);
      m_bConnected = true;
      CAMsg::printMsg(LOG_DEBUG, "CAMix main: init() returned success\n");
      if(m_pInfoService != NULL)
        {
        m_pInfoService->setConfiguring(false);
        if( ! m_pInfoService->isRunning())
          {
          m_pInfoService->start();
          }
        m_pInfoService->signal();
        }
 
      CAMsg::printMsg(LOG_INFO, "The mix is now on-line.\n");
#ifdef DYNAMIC_MIX
      m_bReconfiguring = false;
      m_bCascadeEstablished = true;
      m_bReconfigured = false;
      if(CALibProxytest::getOptions()->isFirstMix() && CALibProxytest::getOptions()->isDynamic())
        { m_pInfoService->sendCascadeHelo(); }
#endif
      MONITORING_FIRE_SYS_EVENT(ev_sys_enterMainLoop);
      loop();
      MONITORING_FIRE_SYS_EVENT(ev_sys_leavingMainLoop);
#ifdef DYNAMIC_MIX
      m_bCascadeEstablished = false;
      if(!m_bReconfiguring)
        { m_pInfoService->dynamicCascadeConfiguration(); }
#endif
      CAMsg::printMsg(LOG_DEBUG, "CAMix main: loop() returned, maybe connection lost.\n");
      }
    else if (initStatus == E_SHUTDOWN)
      {
      CAMsg::printMsg(LOG_DEBUG, "Mix has been stopped. Waiting for shutdown...\n");
      //break;
      }
    else
      {
      CAMsg::printMsg(LOG_DEBUG, "init() failed, maybe no connection.\n");
      }
//#ifdef DYNAMIC_MIX
SKIP:
//#endif
    if(m_pInfoService != NULL)
      {
//#ifndef DYNAMIC_MIX
//      if(CALibProxytest::getOptions()->acceptReconfiguration())
//#else
      // Only keep the InfoService alive if the Mix-Type doesn't change
      if(CALibProxytest::getOptions()->acceptReconfiguration() && m_bLoop)
//#endif
        m_pInfoService->setConfiguring(true);
      /*else
      {
      CAMsg::printMsg(LOG_DEBUG, "CAMix main: stopping InfoService\n");
          m_pInfoService->stop();
      }*/
      // maybe Cascade information (e.g. certificate validity) will change on next connection
      UINT64 currentMillis;
      if (getcurrentTimeMillis(currentMillis) != E_SUCCESS)
        {
        currentMillis = 0;
        }
      m_pInfoService->setSerial(currentMillis);
      }
    m_bConnected = false;
    m_lLastConnectionTime = 0;
    CAMsg::printMsg(LOG_DEBUG, "CAMix main: before clean()\n");
    clean();
    CAMsg::printMsg(LOG_DEBUG, "CAMix main: after clean()\n");
//#ifdef DYNAMIC_MIX
    if(m_bLoop)
//#endif
      sSleep(10);
    }// Big loop....
  if(m_pInfoService != NULL)
    {
    m_pInfoService->stop();
    delete m_pInfoService;
    m_pInfoService = NULL;
    }
  m_pInfoService=NULL;
  return E_SUCCESS;
  }

References CACmdLnOptions::acceptReconfiguration(), clean(), E_SHUTDOWN, E_SUCCESS, E_UNKNOWN, ev_sys_enterMainLoop, ev_sys_leavingMainLoop, getcurrentTimeMillis(), CALibProxytest::getOptions(), init(), initOnce(), CAInfoService::isRunning(), loop(), m_bConnected, m_bLoop, m_bReconfiguring, m_lLastConnectionTime, m_pInfoService, m_pMultiSignature, MONITORING_FIRE_SYS_EVENT, needAutoConfig(), CAMsg::printMsg(), CAInfoService::sendCascadeHelo(), CAInfoService::setConfiguring(), CAInfoService::setMultiSignature(), CAInfoService::setSerial(), CAInfoService::signal(), sSleep(), CAInfoService::start(), and CAInfoService::stop().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

m_acceptReconfiguration

bool CAMix::m_acceptReconfiguration

protected

Definition at line 189 of file CAMix.hpp.

Referenced by acceptsReconfiguration(), and CAMix().

m_bConnected

volatile bool CAMix::m_bConnected

protected

Definition at line 190 of file CAMix.hpp.

Referenced by CAMix(), isConnected(), and start().

m_bLoop

volatile bool CAMix::m_bLoop

protected

Definition at line 135 of file CAMix.hpp.

Referenced by CAMix(), shutDown(), CAFirstMixA::shutDown(), and start().

m_bReconfiguring

bool CAMix::m_bReconfiguring

protected

Definition at line 143 of file CAMix.hpp.

Referenced by CAMix(), and start().

m_bShutDown

volatile bool CAMix::m_bShutDown

protected

Definition at line 144 of file CAMix.hpp.

Referenced by CAMix(), CAMiddleMix::clean(), isShutDown(), and shutDown().

m_docMixCascadeInfo

XERCES_CPP_NAMESPACE::DOMDocument* CAMix::m_docMixCascadeInfo

protected

Definition at line 193 of file CAMix.hpp.

Referenced by CAMix(), getMixCascadeInfo(), CALastMix::initMixCascadeInfo(), and initMixCascadeInfo().

m_lLastConnectionTime

volatile UINT32 CAMix::m_lLastConnectionTime

protected

Definition at line 191 of file CAMix.hpp.

Referenced by CAMix(), getLastConnectionTime(), and start().

m_pInfoService

CAInfoService* CAMix::m_pInfoService

protected

Definition at line 184 of file CAMix.hpp.

Referenced by CAFirstMix::CAFirstMix(), CALastMix::CALastMix(), CAMiddleMix::CAMiddleMix(), CAMix(), CAFirstMix::clean(), CAFirstMixA::shutDown(), and start().

m_pMultiSignature

CAMultiSignature* CAMix::m_pMultiSignature

protected

Definition at line 183 of file CAMix.hpp.

Referenced by CALastMix::CALastMix(), CAMiddleMix::CAMiddleMix(), CAMix(), CAFirstMix::doUserLogin_internal(), CAFirstMix::initOnce(), CALastMix::initOnce(), CAMiddleMix::initOnce(), CAMiddleMix::processKeyExchange(), signXML(), and start().

m_pMuxInControlChannelDispatcher

CAControlChannelDispatcher* CAMix::m_pMuxInControlChannelDispatcher

protected

Definition at line 196 of file CAMix.hpp.

Referenced by CAMix(), CALastMix::clean(), getDownstreamControlChannelDispatcher(), CAMiddleMix::init(), CALastMixA::loop(), and CALastMixB::loop().

m_pMuxOutControlChannelDispatcher

CAControlChannelDispatcher* CAMix::m_pMuxOutControlChannelDispatcher

protected

Definition at line 195 of file CAMix.hpp.

Referenced by CAMix(), CAFirstMix::clean(), getUpstreamControlChannelDispatcher(), and CAFirstMix::init().

m_u32KeepAliveRecvInterval

UINT32 CAMix::m_u32KeepAliveRecvInterval

protected

Definition at line 186 of file CAMix.hpp.

Referenced by CAMix(), CALastMix::processKeyExchange(), and CAMiddleMix::processKeyExchange().

m_u32KeepAliveSendInterval

UINT32 CAMix::m_u32KeepAliveSendInterval

protected

Definition at line 187 of file CAMix.hpp.

Referenced by CAMix(), CALastMix::processKeyExchange(), and CAMiddleMix::processKeyExchange().

TIMEOUT_MIX_CONNECTION_ESTABLISHEMENT

const UINT32 CAMix::TIMEOUT_MIX_CONNECTION_ESTABLISHEMENT = 60000

static

Definition at line 59 of file CAMix.hpp.

Referenced by CALastMix::processKeyExchange(), and CAMiddleMix::processKeyExchange().

---

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

• CAMix.hpp
• CAMix.cpp