implementation of a per-user control-channel for the AccountingInstance. More...

#include <CAAccountingControlChannel.hpp>

Inheritance diagram for CAAccountingControlChannel:

Collaboration diagram for CAAccountingControlChannel:

Public Member Functions
	CAAccountingControlChannel (fmHashTableEntry *pHashEntry)
	Creates a new accounting controlchannel and stores a pointer to this in the pHashEntry. More...

virtual	~CAAccountingControlChannel ()

SINT32	processXMLMessage (const XERCES_CPP_NAMESPACE::DOMDocument *a_doc)
	processMessage - receives an XML msg and appends it to the AI message queue where it will be processed asynchronously More...

Public Member Functions inherited from CASyncControlChannel
	CASyncControlChannel (UINT8 id, bool bIsEncrypted)
	Constructor for a synchronized (e.g. More...

virtual	~CASyncControlChannel ()

Public Member Functions inherited from CAAbstractControlChannel
	CAAbstractControlChannel (UINT8 id, bool bIsEncrypted)

virtual	~CAAbstractControlChannel ()

SINT32	sendXMLMessage (const XERCES_CPP_NAMESPACE::DOMDocument *pDocMsg) const
	Call to send a XML message via this control channel. More...

SINT32	sendXMLMessage (const UINT8 *msgXML, UINT32 msgLen) const
	Call to send a XML message via this control channel. More...

UINT32	getID () const
	Returns the id of this control channel. More...

Private Attributes
fmHashTableEntry *	m_pHashEntry

Additional Inherited Members
Protected Member Functions inherited from CASyncControlChannel
SINT32	proccessMessage (const UINT8 *msg, UINT32 msglen)
	Processes some bytes of a message we got from the communication channel. More...

SINT32	proccessMessageComplete ()
	Parses the bytes in m_MsgBuff and calls processXMLMessage() More...

Protected Member Functions inherited from CAAbstractControlChannel
SINT32	setDispatcher (CAControlChannelDispatcher *pDispatcher)
	Sets the Dispatcher. More...

Protected Attributes inherited from CASyncControlChannel
UINT8 *	m_MsgBuff
	buffer for assembling the parts of the message More...

UINT32	m_aktIndex
	how much bytes have we received already? More...

UINT32	m_MsgBytesLeft
	how much bytes we need until all bytes are received? More...

Protected Attributes inherited from CAAbstractControlChannel
CAControlChannelDispatcher *	m_pDispatcher

bool	m_bIsEncrypted

UINT32	m_ID

Detailed Description

implementation of a per-user control-channel for the AccountingInstance.

All incoming messages are appended to the AccountingInstance queue where they are processed in an own thread.

Author: Bastian Voigt

Definition at line 43 of file CAAccountingControlChannel.hpp.

Constructor & Destructor Documentation

◆ CAAccountingControlChannel()

CAAccountingControlChannel::CAAccountingControlChannel ( fmHashTableEntry * pHashEntry )

Creates a new accounting controlchannel and stores a pointer to this in the pHashEntry.

Definition at line 37 of file CAAccountingControlChannel.cpp.

  : CASyncControlChannel(ACCOUNT_CONTROL_CHANNEL_ID, true)
   {
     m_pHashEntry = pHashEntry;
     if (m_pHashEntry == NULL)
     {
       CAMsg::printMsg(LOG_CRIT,"CAAccountingControlChannel: User hash entry is NULL - creating control channel will fail!");
     }
     if (CAAccountingInstance::initTableEntry(m_pHashEntry) == E_SUCCESS)
     {
       m_pHashEntry->pAccountingInfo->pControlChannel = this;
     }
   }

References E_SUCCESS, CAAccountingInstance::initTableEntry(), m_pHashEntry, t_fmhashtableentry::pAccountingInfo, t_accountinginfo::pControlChannel, and CAMsg::printMsg().

Here is the call graph for this function:

◆ ~CAAccountingControlChannel()

CAAccountingControlChannel::~CAAccountingControlChannel ( )

virtual

Definition at line 52 of file CAAccountingControlChannel.cpp.

   {
     // todo cleanup hashtable entry
     #ifdef DEBUG
       CAMsg::printMsg(LOG_DEBUG, "~CAAccountingControlChannel destructor\n");
     #endif
     CAAccountingInstance::cleanupTableEntry(m_pHashEntry);
   }

References CAAccountingInstance::cleanupTableEntry(), m_pHashEntry, and CAMsg::printMsg().

Here is the call graph for this function:

Member Function Documentation

◆ processXMLMessage()

SINT32 CAAccountingControlChannel::processXMLMessage ( const XERCES_CPP_NAMESPACE::DOMDocument * a_doc )

virtual

processMessage - receives an XML msg and appends it to the AI message queue where it will be processed asynchronously

Implements CASyncControlChannel.

Definition at line 66 of file CAAccountingControlChannel.cpp.

   {
     #ifdef DEBUG
       CAMsg::printMsg(LOG_DEBUG, "Invoking processJapMessage\n");
     #endif
     return CAAccountingInstance::processJapMessage( m_pHashEntry,a_doc );
   }