CAControlChannelDispatcher Class Reference

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

List of all members.

Public Member Functions
	CAControlChannelDispatcher (CAQueue *pSendQueue, UINT8 *keyRecv, UINT8 *keySent)
	Constructs a new dispatcher.
	~CAControlChannelDispatcher ()
void	deleteAllControlChannels (void)
	Deregisters all control channels and calls delete on every registered control channel object.
SINT32	registerControlChannel (CAAbstractControlChannel *pControlChannel)
	Registers a control channel for receiving messages.
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.
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.
bool	isKeySet ()
	Temp workaorund function - to be removed soon...
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.

---

Constructor & Destructor Documentation

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

Constructs a new dispatcher.

Parameters:

pSendQueue

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

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

(

)

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

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.

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

Referenced by CASyncControlChannel::proccessMessage().

void CAControlChannelDispatcher::deleteAllControlChannels

(

void

)

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

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

Referenced by CAFirstMixChannelList::remove().

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

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

Referenced by CAAbstractControlChannel::sendXMLMessage().

bool CAControlChannelDispatcher::isKeySet

(

)

Temp workaorund function - to be removed soon...

References m_pGCMCtxEnc.

Referenced by CASyncControlChannel::proccessMessage().

bool CAControlChannelDispatcher::proccessMixPacket

(

const MIXPACKET *

pPacket

)

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(), fm_loopReadFromMix(), CALastMixA::loop(), CAFirstMixB::loop(), CAFirstMixA::loop(), and CALastMixB::loop().

SINT32 CAControlChannelDispatcher::registerControlChannel

(

CAAbstractControlChannel *

pControlChannel

)

Registers a control channel for receiving messages.

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

SINT32 CAControlChannelDispatcher::removeControlChannel

(

UINT32

id

)

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

Referenced by CAReplayCtrlChannelMsgProc::~CAReplayCtrlChannelMsgProc().

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

References CAQueue::add(), t_MixPacket::channel, t_MixPacket::data, DATA_SIZE, E_SUCCESS, E_UNKNOWN, t_MixPacket::flags, CAMutex::lock(), m_pcsSendMsg, m_pMixPacket, m_pQueueEntry, m_pSendQueue, CAMsg::printMsg(), and CAMutex::unlock().

Referenced by CAAbstractControlChannel::sendXMLMessage().

---

Member Data Documentation

CAAbstractControlChannel** CAControlChannelDispatcher::m_arControlChannels [private]

Referenced by CAControlChannelDispatcher(), deleteAllControlChannels(), proccessMixPacket(), registerControlChannel(), removeControlChannel(), and ~CAControlChannelDispatcher().

UINT32 CAControlChannelDispatcher::m_nDecMsgCounter [private]

Referenced by CAControlChannelDispatcher(), and decryptMessage().

UINT32 CAControlChannelDispatcher::m_nEncMsgCounter [private]

Referenced by CAControlChannelDispatcher(), and encryptMessage().

CAMutex* CAControlChannelDispatcher::m_pcsDec [private]

Referenced by CAControlChannelDispatcher(), decryptMessage(), and ~CAControlChannelDispatcher().

CAMutex* CAControlChannelDispatcher::m_pcsEnc [private]

Referenced by CAControlChannelDispatcher(), encryptMessage(), and ~CAControlChannelDispatcher().

CAMutex* CAControlChannelDispatcher::m_pcsRegisterChannel [private]

Referenced by CAControlChannelDispatcher(), deleteAllControlChannels(), proccessMixPacket(), registerControlChannel(), removeControlChannel(), and ~CAControlChannelDispatcher().

CAMutex* CAControlChannelDispatcher::m_pcsSendMsg [private]

Referenced by CAControlChannelDispatcher(), sendMessages(), and ~CAControlChannelDispatcher().

UINT8* CAControlChannelDispatcher::m_pDecMsgIV [private]

Referenced by CAControlChannelDispatcher(), decryptMessage(), and ~CAControlChannelDispatcher().

UINT32* CAControlChannelDispatcher::m_pEncMsgIV [private]

Referenced by CAControlChannelDispatcher(), encryptMessage(), and ~CAControlChannelDispatcher().

gcm_ctx_64k* CAControlChannelDispatcher::m_pGCMCtxDec [private]

Referenced by CAControlChannelDispatcher(), decryptMessage(), and ~CAControlChannelDispatcher().

gcm_ctx_64k* CAControlChannelDispatcher::m_pGCMCtxEnc [private]

Referenced by CAControlChannelDispatcher(), encryptMessage(), isKeySet(), and ~CAControlChannelDispatcher().

MIXPACKET* CAControlChannelDispatcher::m_pMixPacket [private]

Referenced by CAControlChannelDispatcher(), and sendMessages().

tQueueEntry* CAControlChannelDispatcher::m_pQueueEntry [private]

Referenced by CAControlChannelDispatcher(), sendMessages(), and ~CAControlChannelDispatcher().

CAQueue* CAControlChannelDispatcher::m_pSendQueue [private]

Referenced by CAControlChannelDispatcher(), and sendMessages().