Public Member Functions
	CAChain (UINT8 *a_chainId)
	~CAChain (void)
UINT8 *	getChainId ()
void	setSocket (CASocket *a_socket)
void	addChannel (t_lastMixBChannelListEntry *a_channel, bool a_fastResponse)
void	addDataToUpstreamQueue (UINT8 *a_buffer, UINT32 a_size)
void	signalConnectionError ()
void	signalUnknownChain ()
void	closeUpstream ()
void	closeDownstream ()
UINT8 *	getPrintableChainId ()
void	addToSocketGroup (CASocketGroupEpoll *a_socketGroup)
void	removeFromSocketGroup (CASocketGroupEpoll *a_socketGroup)
bool	isSignaledInSocketGroup (CASocketGroupEpoll *a_socketGroup)
UINT32	sendUpstreamData (UINT32 a_maxLength, CASocketGroupEpoll *a_removedSocketGroup)
SINT32	processDownstream (CASocketGroupEpoll a_signalingGroup, MIXPACKET a_downstreamPacket, UINT32 *a_processedBytes)
	Returns: 0, if a packet was created.
Private Member Functions
void	closeChainInternal ()
void	forceImmediateResponsesInternal ()
void	removeFromAllSocketGroupsInternal ()
UINT32	sendUpstreamDataInternal (UINT32 a_maxLength)
Private Attributes
UINT8 *	m_chainId
SINT32	m_lastAccessTime
CASocket *	m_socket
CAQueue *	m_upstreamSendQueue
t_channelEntry *	m_firstChannel
t_socketGroupEntry *	m_firstSocketGroup
bool	m_connectionError
bool	m_downstreamClosed
bool	m_upstreamClosed
bool	m_firstDownstreamPacket
bool	m_unknownChainId

Constructor & Destructor Documentation

CAChain::CAChain ( UINT8 * a_chainId )

References DATA_SIZE, getcurrentTimeMicros(), m_chainId, m_connectionError, m_downstreamClosed, m_firstChannel, m_firstDownstreamPacket, m_firstSocketGroup, m_lastAccessTime, m_socket, m_unknownChainId, m_upstreamClosed, and m_upstreamSendQueue.

Member Function Documentation

void CAChain::addChannel	(	t_lastMixBChannelListEntry *	a_channel,
		bool	a_fastResponse
	)

References t_channelEntry::channel, CHANNEL_DOWNSTREAM_PACKETS, CHANNEL_TIMEOUT, t_deadlineEntry::deadline, t_lastMixBChannelListEntry::firstResponseDeadline, forceImmediateResponsesInternal(), getcurrentTime(), m_downstreamClosed, m_firstChannel, m_lastAccessTime, m_upstreamClosed, t_channelEntry::nextChannel, t_deadlineEntry::nextDeadline, t_lastMixBChannelListEntry::remainingDownstreamPackets, and signalConnectionError().

Referenced by CALastMixB::loop().

void CAChain::addDataToUpstreamQueue	(	UINT8 *	a_buffer,
		UINT32	a_size
	)

References CAQueue::add(), m_upstreamClosed, and m_upstreamSendQueue.

Referenced by CALastMixB::loop().

void CAChain::addToSocketGroup ( CASocketGroupEpoll * a_socketGroup )

References CASocketGroup::add(), m_firstSocketGroup, m_socket, t_socketGroupEntry::nextSocketGroup, and t_socketGroupEntry::socketGroup.

Referenced by CALastMixB::loop().

void CAChain::closeChainInternal ( ) [private]

References CAQueue::clean(), CASocket::close(), forceImmediateResponsesInternal(), m_downstreamClosed, m_socket, m_upstreamClosed, m_upstreamSendQueue, and removeFromAllSocketGroupsInternal().

Referenced by closeDownstream(), closeUpstream(), processDownstream(), signalConnectionError(), and signalUnknownChain().

void CAChain::closeDownstream ( )

References closeChainInternal().

Referenced by processDownstream().

void CAChain::closeUpstream ( )

References closeChainInternal().

Referenced by CALastMixB::loop().

void CAChain::forceImmediateResponsesInternal ( ) [private]

References t_channelEntry::channel, t_deadlineEntry::deadline, t_lastMixBChannelListEntry::firstResponseDeadline, getcurrentTime(), m_firstChannel, t_channelEntry::nextChannel, and t_deadlineEntry::nextDeadline.

Referenced by addChannel(), and closeChainInternal().

UINT8 * CAChain::getChainId ( )

References m_chainId.

Referenced by CAChainTable::getEntryInternal(), and CALastMixB::loop().

UINT8 * CAChain::getPrintableChainId ( )

References bytes2hex(), CHAIN_ID_LENGTH, m_chainId, and strtrim().

Referenced by processDownstream(), and ~CAChain().

bool CAChain::isSignaledInSocketGroup ( CASocketGroupEpoll * a_socketGroup )

References CASocketGroupEpoll::isSignaled(), and m_socket.

Referenced by CALastMixB::loop(), and processDownstream().

SINT32 CAChain::processDownstream	(	CASocketGroupEpoll *	a_signalingGroup,
		MIXPACKET *	a_downstreamPacket,
		UINT32 *	a_processedBytes
	)

Returns: 0, if a packet was created.

1, if currently nothing can be done. 2, if a packet was created and the chain can be removed from the chaintable. 3, if no packet was created, but the chain can be removed from the chaintable.

References t_lastMixBChannelListEntry::associatedChannelList, CHAIN_ID_LENGTH, CHAIN_TIMEOUT, CHAINFLAG_CONNECTION_ERROR, CHAINFLAG_STREAM_CLOSED, CHAINFLAG_UNKNOWN_CHAIN, chainId, t_first_downstream_chain_cell::chainId, t_channelEntry::channel, t_MixPacket::channel, CHANNEL_CLOSE, CHANNEL_DATA, t_lastMixBChannelListEntry::channelCipher, t_lastMixBChannelListEntry::channelId, closeChainInternal(), closeDownstream(), CASymCipher::crypt2(), t_MixPacket::data, t_first_downstream_chain_cell::data, t_sequel_downstream_chain_cell::data, DATA_SIZE, t_deadlineEntry::deadline, DEADLINE_TIMEOUT, t_downstream_chain_cell::firstCell, t_lastMixBChannelListEntry::firstResponseDeadline, t_MixPacket::flags, getcurrentTime(), getPrintableChainId(), getRandom(), isSignaledInSocketGroup(), t_downstream_chain_cell::lengthAndFlags, m_chainId, m_connectionError, m_downstreamClosed, m_firstChannel, m_firstDownstreamPacket, m_lastAccessTime, m_socket, m_unknownChainId, m_upstreamClosed, MAX_FIRST_DOWNSTREAM_CHAINCELL_PAYLOAD, MAX_SEQUEL_DOWNSTREAM_CHAINCELL_PAYLOAD, t_channelEntry::nextChannel, t_deadlineEntry::nextDeadline, CAMsg::printMsg(), CASocket::receive(), t_lastMixBChannelListEntry::remainingDownstreamPackets, CALastMixBChannelList::removeFromTable(), t_downstream_chain_cell::sequelCell, and signalConnectionError().