CAMiddleMix.cpp File Reference

Defines
#define	MIDDLE_MIX_SIZE_OF_SYMMETRIC_KEYS   2*KEY_SIZE
#define	MIDDLE_MIX_ASYM_PADDING_SIZE   42
#define	RETRIES   100
#define	RETRYTIME   10
Functions
THREAD_RETURN	mm_loopSendToMixAfter (void *param)
	UPSTREAM (to WEB) Take the packets from the Queue and write them to the Socket.
THREAD_RETURN	mm_loopSendToMixBefore (void *param)
	DOWNSTREAM (to Client) Take the packets from the Queue and write them to the Socket.
THREAD_RETURN	mm_loopReadFromMixBefore (void *param)
THREAD_RETURN	mm_loopReadFromMixAfter (void *param)

---

Define Documentation

#define MIDDLE_MIX_ASYM_PADDING_SIZE   42

Referenced by mm_loopReadFromMixBefore().

#define MIDDLE_MIX_SIZE_OF_SYMMETRIC_KEYS   2*KEY_SIZE

Referenced by mm_loopReadFromMixBefore().

#define RETRIES   100

Referenced by CAMiddleMix::connectToNextMix().

#define RETRYTIME   10

Referenced by CAMiddleMix::connectToNextMix().

---

Function Documentation

THREAD_RETURN mm_loopReadFromMixAfter

(

void *

param

)

References CASocketGroup::add(), CAQueue::add(), t_MixPacket::channel, CHANNEL_ALLOWED_FLAGS, CHANNEL_CLOSE, CHANNEL_DUMMY, CHANNEL_SIG_CRIME, CASymCipher::crypt2(), t_MixPacket::data, DATA_SIZE, DUMMY_CHANNEL, E_SUCCESS, E_TIMEDOUT, ev_net_nextConnectionClosed, t_MixPacket::flags, GET_NET_ERROR, GET_NET_ERROR_STR, CAMiddleMixChannelList::getOutToIn(), getRandom(), CAQueue::getSize(), CAMiddleMix::m_bRun, CAMiddleMix::m_pMiddleMixChannelList, CAMiddleMix::m_pMuxIn, CAMiddleMix::m_pMuxOut, CAMiddleMix::m_pQueueSendToMixAfter, CAMiddleMix::m_pQueueSendToMixBefore, MAX_READ_FROM_NEXT_MIX_QUEUE_SIZE, MIX_POOL_TIMEOUT, MONITORING_FIRE_NET_EVENT, msSleep(), t_queue_entry::packet, pMix, CAPool::pool(), CAMsg::printMsg(), CAMuxSocket::receive(), CAMiddleMixChannelList::remove(), REPLAY_CONTROL_CHANNEL_ID, CASocketGroup::select(), CAMuxSocket::send(), SOCKET_ERROR, THREAD_RETURN_SUCCESS, and CALockAble::unlock().

THREAD_RETURN mm_loopReadFromMixBefore

(

void *

param

)

References CASocketGroup::add(), CAQueue::add(), CAMiddleMixChannelList::add(), t_MixPacket::channel, CHANNEL_ALLOWED_FLAGS, CHANNEL_CLOSE, CHANNEL_DUMMY, CHANNEL_OPEN, CASymCipher::crypt1(), t_MixPacket::data, DATA_SIZE, CAASymCipher::decryptOAEP(), DUMMY_CHANNEL, E_SUCCESS, E_TIMEDOUT, ev_net_prevConnectionClosed, t_MixPacket::flags, CAMiddleMixChannelList::getInToOut(), getRandom(), CAQueue::getSize(), CADatabase::insert(), CAMiddleMix::m_bRun, CAMiddleMix::m_pMiddleMixChannelList, CAMiddleMix::m_pMuxIn, CAMiddleMix::m_pMuxOut, CAMiddleMix::m_pQueueSendToMixAfter, CAMiddleMix::m_pQueueSendToMixBefore, CAMixWithReplayDB::m_pReplayDB, CAMiddleMix::m_pRSA, CAMixWithReplayDB::m_u64ReferenceTime, MAX_READ_FROM_PREV_MIX_QUEUE_SIZE, MIDDLE_MIX_ASYM_PADDING_SIZE, MIDDLE_MIX_SIZE_OF_SYMMETRIC_KEYS, MIX_POOL_TIMEOUT, MONITORING_FIRE_NET_EVENT, msSleep(), t_queue_entry::packet, pMix, CAPool::pool(), CAMsg::printMsg(), CAMuxSocket::receive(), CAMiddleMixChannelList::remove(), REPLAY_BASE, RSA_SIZE, CASocketGroup::select(), CAMuxSocket::send(), CASymCipher::setKeys(), SOCKET_ERROR, THREAD_RETURN_SUCCESS, and CALockAble::unlock().

THREAD_RETURN mm_loopSendToMixAfter

(

void *

param

)

UPSTREAM (to WEB) Take the packets from the Queue and write them to the Socket.

References BEGIN_STACK, t_MixPacket::channel, CHANNEL_DUMMY, t_MixPacket::data, DATA_SIZE, DUMMY_CHANNEL, E_SUCCESS, E_TIMEDOUT, ev_net_nextConnectionClosed, FINISH_STACK, t_MixPacket::flags, getcurrentTimeMicros(), CAQueue::getOrWait(), getRandom(), INIT_STACK, isZero64(), len, CAMiddleMix::m_bRun, CAMiddleMix::m_pMuxOut, CAMiddleMix::m_u32KeepAliveSendInterval2, MIXPACKET_SIZE, MONITORING_FIRE_NET_EVENT, t_queue_entry::packet, CAMsg::printMsg(), CAMuxSocket::send(), and THREAD_RETURN_SUCCESS.

THREAD_RETURN mm_loopSendToMixBefore

(

void *

param

)

DOWNSTREAM (to Client) Take the packets from the Queue and write them to the Socket.

References BEGIN_STACK, t_MixPacket::channel, CHANNEL_DUMMY, t_MixPacket::data, DATA_SIZE, DUMMY_CHANNEL, E_SUCCESS, E_TIMEDOUT, ev_net_prevConnectionClosed, FINISH_STACK, t_MixPacket::flags, getcurrentTimeMicros(), CAQueue::getOrWait(), getRandom(), INIT_STACK, isZero64(), len, CAMiddleMix::m_bRun, CAMiddleMix::m_pMuxIn, CAMix::m_u32KeepAliveSendInterval, MIXPACKET_SIZE, MONITORING_FIRE_NET_EVENT, t_queue_entry::packet, CAMsg::printMsg(), CAMuxSocket::send(), and THREAD_RETURN_SUCCESS.