Public Member Functions
	CAMuxSocket ()
	~CAMuxSocket ()
SINT32	getHashKey ()
	Returns a Hashkey which uniquely identifies this socket.
SINT32	accept (UINT16 port)
SINT32	accept (const CASocketAddr &oAddr)
	Waits for an incoming connection on oAddr.
SINT32	connect (CASocketAddr &psa)
SINT32	connect (CASocketAddr &psa, UINT retry, UINT32 time)
SINT32	close ()
	Closes the underlying socket.
SINT32	send (MIXPACKET *pPacket)
	Sends a MixPacket over the Network.
SINT32	send (MIXPACKET pPacket, UINT8 buff)
SINT32	prepareForSend (MIXPACKET *inoutPacket)
SINT32	receive (MIXPACKET *pPacket)
	Receives a whole MixPacket.
SINT32	receive (MIXPACKET *pPacket, UINT32 timeout)
	Trys to receive a Mix-Packet.
SINT32	receiveFully (UINT8 *buff, UINT32 len)
	Receives some "plain" bytes from the underlying socket - just a convenient function...
SINT32	receiveFully (UINT8 *buff, UINT32 len, UINT32 msTimeOut)
CASocket *	getCASocket ()
SOCKET	getSocket ()
SINT32	setCrypt (bool b)
bool	getIsEncrypted ()
SINT32	setKey (UINT8 *key, UINT32 keyLen)
	Sets the symmetric keys used for de-/encrypting the Mux connection.
SINT32	setSendKey (UINT8 *key, UINT32 keyLen)
SINT32	setReceiveKey (UINT8 *key, UINT32 keyLen)
Private Attributes
CASocket	m_Socket
UINT32	m_aktBuffPos
UINT8 *	m_Buff
CASymCipher	m_oCipherIn
CASymCipher	m_oCipherOut
bool	m_bIsCrypted
CAMutex	m_csSend
CAMutex	m_csReceive
t_hashkeylistEntry *	m_pHashKeyEntry
Static Private Attributes
static t_hashkeylistEntry *	ms_phashkeylistAvailableHashKeys = NULL
static SINT32	ms_nMaxHashKeyValue = 0
static CAMutex *	ms_pcsHashKeyList = new CAMutex()

Constructor & Destructor Documentation

CAMuxSocket::CAMuxSocket ( )

References __t_hash_key_entry__::hashkey, CAMutex::lock(), m_aktBuffPos, m_bIsCrypted, m_Buff, m_pHashKeyEntry, MIXPACKET_SIZE, ms_nMaxHashKeyValue, ms_pcsHashKeyList, ms_phashkeylistAvailableHashKeys, __t_hash_key_entry__::next, and CAMutex::unlock().

CAMuxSocket::~CAMuxSocket ( )

References close(), CAMutex::lock(), m_Buff, m_pHashKeyEntry, ms_pcsHashKeyList, ms_phashkeylistAvailableHashKeys, __t_hash_key_entry__::next, and CAMutex::unlock().

Member Function Documentation

SINT32 CAMuxSocket::accept ( UINT16 port )

References CASocket::accept(), CASocket::close(), CASocket::create(), E_SUCCESS, E_UNKNOWN, CASocket::listen(), m_aktBuffPos, m_Socket, and CASocket::setReuseAddr().

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

SINT32 CAMuxSocket::accept ( const CASocketAddr & oAddr )

Waits for an incoming connection on oAddr.

Return values:

E_SUCCESS,if	successful
E_SOCKET_BIND,E_SOCKET_LISTEN
E_UNKOWN

References CASocket::accept(), CASocket::close(), CASocket::create(), E_SUCCESS, E_UNKNOWN, CASocketAddr::getType(), CASocket::listen(), m_aktBuffPos, m_Socket, and CASocket::setReuseAddr().

SINT32 CAMuxSocket::close ( )

Closes the underlying socket.

References CASocket::close(), m_aktBuffPos, and m_Socket.

Referenced by CALocalProxy::clean(), CAMiddleMix::clean(), CALastMix::clean(), CAFirstMix::clean(), CAFirstMixB::loop(), CALastMixB::loop(), CAMiddleMix::loop(), and ~CAMuxSocket().

SINT32 CAMuxSocket::connect ( CASocketAddr & psa )

Referenced by CAMiddleMix::connectToNextMix(), CAFirstMix::connectToNextMix(), and CALocalProxy::init().

SINT32 CAMuxSocket::connect	(	CASocketAddr &	psa,
		UINT	retry,
		UINT32	time
	)

References CASocket::connect(), m_aktBuffPos, and m_Socket.

CASocket* CAMuxSocket::getCASocket ( )

References m_Socket.

Referenced by CAFirstMixChannelList::add(), CAFirstMix::doUserLogin_internal(), fm_loopAcceptUsers(), CALocalProxy::init(), CAMiddleMix::init(), CALastMix::init(), CAFirstMix::init(), CAFirstMixB::loop(), CALocalProxy::processKeyExchange(), CAMiddleMix::processKeyExchange(), CALastMix::processKeyExchange(), CAFirstMix::processKeyExchange(), CAFirstMixA::sendToUsers(), and CAFirstMixChannelList::test().

SINT32 CAMuxSocket::getHashKey ( )

Returns a Hashkey which uniquely identifies this socket.

References __t_hash_key_entry__::hashkey, and m_pHashKeyEntry.

Referenced by CAFirstMixChannelList::add(), CAFirstMixChannelList::addChannel(), CAFirstMixChannelList::get(), CAFirstMixChannelList::getFirstChannelForSocket(), CAFirstMixChannelList::remove(), and CAFirstMixChannelList::removeChannel().

bool CAMuxSocket::getIsEncrypted ( )

References m_bIsCrypted.

SOCKET CAMuxSocket::getSocket ( )

References CASocket::getSocket(), and m_Socket.

Referenced by CASocketGroupEpoll::add(), CASocketGroup::add(), CASocketGroup::isSignaled(), CAFirstMixB::loop(), and CASocketGroup::remove().

SINT32 CAMuxSocket::prepareForSend ( MIXPACKET * inoutPacket )

References t_MixPacket::channel, CASymCipher::crypt1(), t_MixPacket::flags, CAMutex::lock(), m_csSend, m_oCipherOut, MIXPACKET_SIZE, and CAMutex::unlock().

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

SINT32 CAMuxSocket::receive ( MIXPACKET * pPacket )

Receives a whole MixPacket.

Blocks until a packet is received or a socket error occurs.

Parameters:

pPacket on return stores the received MixPacket

Return values:

SOCKET_ERROR,in	case of an error
MIXPACKET_SIZE	otherwise

References CASymCipher::crypt1(), E_SUCCESS, E_UNKNOWN, CAMutex::lock(), m_bIsCrypted, m_csReceive, m_oCipherIn, m_Socket, MIXPACKET_SIZE, CAMsg::printMsg(), CAClientSocket::receiveFully(), SOCKET_ERROR, and CAMutex::unlock().

Referenced by CAFirstMix::doUserLogin_internal(), fm_loopReadFromMix(), lm_loopReadFromMix(), CAFirstMixB::loop(), CAFirstMixA::loop(), CALocalProxy::loop(), mm_loopReadFromMixAfter(), and mm_loopReadFromMixBefore().

SINT32 CAMuxSocket::receive	(	MIXPACKET *	pPacket,
		UINT32	msTimeout
	)

Trys to receive a Mix-Packet.

If after timout milliseconds not a whole packet is available E_AGAIN will be returned. In this case you should later try to get the rest of the packet

References CASocketGroup::add(), add64(), t_MixPacket::channel, CASymCipher::crypt1(), diff64(), E_AGAIN, E_NOT_CONNECTED, E_SUCCESS, E_UNKNOWN, t_MixPacket::flags, GET_NET_ERROR, GET_NET_ERROR_STR, getcurrentTimeMillis(), CASocket::isClosed(), isEqual64(), isGreater64(), len, CAMutex::lock(), m_aktBuffPos, m_bIsCrypted, m_Buff, m_csReceive, m_oCipherIn, m_Socket, MIXPACKET_SIZE, CAMsg::printMsg(), CASocket::receive(), CASocketGroup::select(), and CAMutex::unlock().

SINT32 CAMuxSocket::receiveFully	(	UINT8 *	buff,
		UINT32	len
	)

Receives some "plain" bytes from the underlying socket - just a convenient function...

References m_Socket, and CAClientSocket::receiveFully().

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

SINT32 CAMuxSocket::receiveFully	(	UINT8 *	buff,
		UINT32	len,
		UINT32	msTimeOut
	)

References m_Socket, and CASocket::receiveFullyT().

SINT32 CAMuxSocket::send ( MIXPACKET * pPacket )

Sends a MixPacket over the Network.

Will block until the whole packet is send.

Parameters:

pPacket MixPacket to send

Return values:

MIXPACKET_SIZE	if MixPacket was successful send
E_UNKNOWN	otherwise

References t_MixPacket::channel, CASymCipher::crypt1(), E_SUCCESS, E_UNKNOWN, t_MixPacket::flags, GET_NET_ERROR, CAMutex::lock(), m_bIsCrypted, m_csSend, m_oCipherOut, m_Socket, MIXPACKET_SIZE, CAMsg::printMsg(), CASocket::sendFully(), and CAMutex::unlock().

Referenced by fm_loopSendToMix(), lm_loopSendToMix(), CALocalProxy::loop(), mm_loopReadFromMixAfter(), mm_loopReadFromMixBefore(), mm_loopSendToMixAfter(), mm_loopSendToMixBefore(), and CALocalProxy::processKeyExchange().

SINT32 CAMuxSocket::send	(	MIXPACKET *	pPacket,
		UINT8 *	buff
	)

References t_MixPacket::channel, CASymCipher::crypt1(), t_MixPacket::flags, CAMutex::lock(), m_bIsCrypted, m_csSend, m_oCipherOut, MIXPACKET_SIZE, and CAMutex::unlock().

SINT32 CAMuxSocket::setCrypt ( bool b )

References E_SUCCESS, CAMutex::lock(), m_bIsCrypted, m_csReceive, m_csSend, and CAMutex::unlock().

Referenced by CAFirstMix::doUserLogin_internal(), CAMiddleMix::loop(), CALocalProxy::processKeyExchange(), CALastMix::processKeyExchange(), and CAFirstMix::processKeyExchange().

SINT32 CAMuxSocket::setKey	(	UINT8 *	key,
		UINT32	keyLen
	)

Sets the symmetric keys used for de-/encrypting the Mux connection.

Parameters:

key	buffer conntaining the key bits
keyLen	size of the buffer (keys) if keylen=16, then the key is used for incomming and outgoing direction (key only) if keylen=32, then the first bytes are used for incoming and the last bytes are used for outgoing

Return values: