This class "dispatches" messages which it receives via proccessMixPacket() to the associated control channel. More...

#include <CAControlChannelDispatcher.hpp>

Collaboration diagram for CAControlChannelDispatcher:

Public Member Functions
	CAControlChannelDispatcher (CAQueue pSendQueue, UINT8 keyRecv, UINT8 *keySent)
	Constructs a new dispatcher. More...

	~CAControlChannelDispatcher ()

void	deleteAllControlChannels (void)
	Deregisters all control channels and calls delete on every registered control channel object. More...

SINT32	registerControlChannel (CAAbstractControlChannel *pControlChannel)
	Registers a control channel for receiving messages. More...

SINT32	removeControlChannel (UINT32 id)

bool	proccessMixPacket (const MIXPACKET *pPacket)

SINT32	sendMessages (UINT32 id, const UINT8 *msg, UINT32 msglen)

SINT32	encryptMessage (const UINT8 in, UINT32 inlen, UINT8 out, UINT32 *outlen)
	Encrypts a control channel message. More...

SINT32	decryptMessage (const UINT8 in, UINT32 inlen, UINT8 out, UINT32 *outlen)
	Decrypts a control channel message, which has to be of form: cipher text auth tag - 16 bytes. More...

bool	isKeySet ()
	Temp workaorund function - to be removed soon... More...

Private Attributes
CAQueue *	m_pSendQueue

MIXPACKET *	m_pMixPacket

CAAbstractControlChannel **	m_arControlChannels

tQueueEntry *	m_pQueueEntry

CAMutex *	m_pcsSendMsg

CAMutex *	m_pcsRegisterChannel

CAMutex *	m_pcsEnc

CAMutex *	m_pcsDec

gcm_ctx_64k *	m_pGCMCtxEnc

gcm_ctx_64k *	m_pGCMCtxDec

UINT32	m_nEncMsgCounter

UINT32 *	m_pEncMsgIV

UINT32	m_nDecMsgCounter

UINT8 *	m_pDecMsgIV

Detailed Description

This class "dispatches" messages which it receives via proccessMixPacket() to the associated control channel.

Definition at line 38 of file CAControlChannelDispatcher.hpp.

Constructor & Destructor Documentation

◆ CAControlChannelDispatcher()

CAControlChannelDispatcher::CAControlChannelDispatcher	(	CAQueue *	pSendQueue,
		UINT8 *	keyRecv,
		UINT8 *	keySent
	)

inline

Constructs a new dispatcher.

Parameters

pSendQueue send queue in which the mix packets will be puted, if a control channel sends a message

Definition at line 45 of file CAControlChannelDispatcher.hpp.

       {
         m_pSendQueue=pSendQueue;
         m_pQueueEntry=new tQueueEntry;
         m_pMixPacket=&m_pQueueEntry->packet;
         m_arControlChannels=new CAAbstractControlChannel*[256];
         memset(m_arControlChannels,0,256*sizeof(CAAbstractControlChannel*));
         m_pcsSendMsg=new CAMutex();
         m_pcsRegisterChannel=new CAMutex();
         m_pcsEnc=new CAMutex();
         m_pcsDec=new CAMutex();
         m_nEncMsgCounter=0;
         m_pEncMsgIV=new UINT32[3];
         memset(m_pEncMsgIV,0,12);
         m_nDecMsgCounter=0;
         m_pDecMsgIV=new UINT8[12];
         memset(m_pDecMsgIV,0,12);
         if(keySent!=NULL)
         {
           m_pGCMCtxEnc=new gcm_ctx_64k;
           m_pGCMCtxDec=new gcm_ctx_64k;
           gcm_init_64k(m_pGCMCtxEnc,keySent,128);
           gcm_init_64k(m_pGCMCtxDec,keyRecv,128);
         }
         else
         {
           m_pGCMCtxEnc=NULL;
           m_pGCMCtxDec=NULL;
         }
       }

References m_arControlChannels, m_nDecMsgCounter, m_nEncMsgCounter, m_pcsDec, m_pcsEnc, m_pcsRegisterChannel, m_pcsSendMsg, m_pDecMsgIV, m_pEncMsgIV, m_pGCMCtxDec, m_pGCMCtxEnc, m_pMixPacket, m_pQueueEntry, m_pSendQueue, and t_queue_entry::packet.

◆ ~CAControlChannelDispatcher()

CAControlChannelDispatcher::~CAControlChannelDispatcher ( )

inline

Definition at line 76 of file CAControlChannelDispatcher.hpp.

       {
         delete m_pcsSendMsg;
         m_pcsSendMsg = NULL;
         delete m_pcsRegisterChannel;
         m_pcsRegisterChannel = NULL;
         delete[] m_arControlChannels;
         m_arControlChannels = NULL;
         delete m_pQueueEntry;
         m_pQueueEntry = NULL;
         if(m_pGCMCtxEnc!=NULL)
           delete m_pGCMCtxEnc;
         if(m_pGCMCtxDec!=NULL)
           delete m_pGCMCtxDec;
         delete []m_pEncMsgIV;
         delete m_pcsEnc;
         delete []m_pDecMsgIV;
         delete m_pcsDec;
       }

References m_arControlChannels, m_pcsDec, m_pcsEnc, m_pcsRegisterChannel, m_pcsSendMsg, m_pDecMsgIV, m_pEncMsgIV, m_pGCMCtxDec, m_pGCMCtxEnc, and m_pQueueEntry.

Member Function Documentation

◆ decryptMessage()

SINT32 CAControlChannelDispatcher::decryptMessage	(	const UINT8 *	in,
		UINT32	inlen,
		UINT8 *	out,
		UINT32 *	outlen
	)

Decrypts a control channel message, which has to be of form: cipher text auth tag - 16 bytes.

Definition at line 108 of file CAControlChannelDispatcher.cpp.

   {
     if(m_pGCMCtxDec!=NULL)
       {
         m_pcsDec->lock();
         UINT32 iv=htonl(m_nDecMsgCounter);
         m_nDecMsgCounter++;
         memcpy(m_pDecMsgIV+8,&iv,4);
         ::gcm_decrypt_64k(m_pGCMCtxDec,(UINT32*) m_pDecMsgIV , in,inlen-16,in+inlen-16,out);
         *outlen=inlen-16;
         m_pcsDec->unlock();
       }
     else
     {
       memcpy(out,in,inlen);
       *outlen=inlen;
     }
       return E_SUCCESS;
   }

References E_SUCCESS, CAMutex::lock(), m_nDecMsgCounter, m_pcsDec, m_pDecMsgIV, m_pGCMCtxDec, and CAMutex::unlock().

Referenced by CASyncControlChannel::proccessMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ deleteAllControlChannels()

void CAControlChannelDispatcher::deleteAllControlChannels ( void )

Deregisters all control channels and calls delete on every registered control channel object.

Definition at line 57 of file CAControlChannelDispatcher.cpp.

   {
     m_pcsRegisterChannel->lock();
     for(UINT32 i=0;i<256;i++)
     {
       delete m_arControlChannels[i];
       m_arControlChannels[i]=NULL;
     }
     m_pcsRegisterChannel->unlock();
   }

References CAMutex::lock(), m_arControlChannels, m_pcsRegisterChannel, and CAMutex::unlock().

Referenced by CAFirstMixChannelList::remove().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ encryptMessage()

SINT32 CAControlChannelDispatcher::encryptMessage	(	const UINT8 *	in,
		UINT32	inlen,
		UINT8 *	out,
		UINT32 *	outlen
	)

Encrypts a control channel message.

The output format is: cipher text auth tag - 16 bytes

Definition at line 89 of file CAControlChannelDispatcher.cpp.

   {
     if(m_pGCMCtxEnc!=NULL)
     {
       m_pcsEnc->lock();
       m_pEncMsgIV[2]=htonl(m_nEncMsgCounter);
       m_nEncMsgCounter++;
       ::gcm_encrypt_64k(m_pGCMCtxEnc, m_pEncMsgIV , in,inlen,out,(UINT32*)(out+inlen));
       *outlen=inlen+16;
       m_pcsEnc->unlock();
     }
     else
     {
       memcpy(out,in,inlen);
       *outlen=inlen;
     }
       return E_SUCCESS;
   }

References E_SUCCESS, CAMutex::lock(), m_nEncMsgCounter, m_pcsEnc, m_pEncMsgIV, m_pGCMCtxEnc, and CAMutex::unlock().

Referenced by CAAbstractControlChannel::sendXMLMessage().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ isKeySet()

bool CAControlChannelDispatcher::isKeySet ( )

inline

Temp workaorund function - to be removed soon...

Definition at line 116 of file CAControlChannelDispatcher.hpp.

       {
         return m_pGCMCtxEnc!=NULL;
       }

References m_pGCMCtxEnc.

Referenced by CASyncControlChannel::proccessMessage().

Here is the caller graph for this function:

◆ proccessMixPacket()

bool CAControlChannelDispatcher::proccessMixPacket ( const MIXPACKET * pPacket )

Definition at line 68 of file CAControlChannelDispatcher.cpp.

   {
     if(pPacket->channel < 256 && pPacket->channel > 0)
     {
       m_pcsRegisterChannel->lock();
       CAAbstractControlChannel* pControlChannel=m_arControlChannels[pPacket->channel];
       if (pControlChannel != NULL)
       {
         bool ret = (pControlChannel->proccessMessage(pPacket->data,pPacket->flags) == E_SUCCESS);
         m_pcsRegisterChannel->unlock();
         return ret;
       }
       else
       {
         m_pcsRegisterChannel->unlock();
         return true;
       }
     }
     return false;
   }

References t_MixPacket::channel, t_MixPacket::data, E_SUCCESS, t_MixPacket::flags, CAMutex::lock(), m_arControlChannels, m_pcsRegisterChannel, CAAbstractControlChannel::proccessMessage(), and CAMutex::unlock().

Referenced by CAFirstMix::doUserLogin_internal(), CAFirstMixA::loop(), CALastMixA::loop(), CAFirstMixB::loop(), and CALastMixB::loop().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ registerControlChannel()

SINT32 CAControlChannelDispatcher::registerControlChannel ( CAAbstractControlChannel * pControlChannel )

Registers a control channel for receiving messages.

Definition at line 34 of file CAControlChannelDispatcher.cpp.

   {
     if(pControlChannel==NULL||pControlChannel->getID()>255)
       return E_UNKNOWN;
     m_pcsRegisterChannel->lock();
     pControlChannel->setDispatcher(this);
     m_arControlChannels[pControlChannel->getID()]= pControlChannel;
     m_pcsRegisterChannel->unlock();
     return E_SUCCESS;
   }

References E_SUCCESS, E_UNKNOWN, CAAbstractControlChannel::getID(), CAMutex::lock(), m_arControlChannels, m_pcsRegisterChannel, CAAbstractControlChannel::setDispatcher(), and CAMutex::unlock().

Referenced by CAReplayCtrlChannelMsgProc::CAReplayCtrlChannelMsgProc(), and CAFirstMix::doUserLogin_internal().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ removeControlChannel()

SINT32 CAControlChannelDispatcher::removeControlChannel ( UINT32 id )

Definition at line 45 of file CAControlChannelDispatcher.cpp.

   {
     if(id>255)
       return E_UNKNOWN;
     m_pcsRegisterChannel->lock();
     delete m_arControlChannels[id];
     m_arControlChannels[id]=NULL;
     m_pcsRegisterChannel->unlock();
     return E_SUCCESS;
   }

References E_SUCCESS, E_UNKNOWN, CAMutex::lock(), m_arControlChannels, m_pcsRegisterChannel, and CAMutex::unlock().

Referenced by CAReplayCtrlChannelMsgProc::~CAReplayCtrlChannelMsgProc().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sendMessages()

SINT32 CAControlChannelDispatcher::sendMessages	(	UINT32	id,
		const UINT8 *	msg,
		UINT32	msglen
	)

Definition at line 128 of file CAControlChannelDispatcher.cpp.

   {
     #ifdef DEBUG
       CAMsg::printMsg(LOG_DEBUG,"dispatch - sendMesg()\n");
     #endif
     if(msg==NULL)
       return E_UNKNOWN;
     m_pcsSendMsg->lock();
     m_pMixPacket->channel=id;
     UINT32 aktIndex=0;
  
     //prevent data garbage from old messages to be transmitted again
     memset(m_pMixPacket->data, 0, DATA_SIZE);
     while(msglen>0)
     {
       if(msglen>DATA_SIZE)
       {
         m_pMixPacket->flags=DATA_SIZE;
       }
       else
       {
         m_pMixPacket->flags=(UINT16)msglen;
       }
       memcpy(m_pMixPacket->data,msg+aktIndex,m_pMixPacket->flags);
       m_pSendQueue->add(m_pQueueEntry,sizeof(tQueueEntry));
       aktIndex+=m_pMixPacket->flags;
       msglen-=m_pMixPacket->flags;
     }
     m_pcsSendMsg->unlock();
     return E_SUCCESS;
   }