Mixes for Privacy and Anonymity in the Internet
Classes | Functions
CALastMixA.hpp File Reference

Classes

class  CALastMixA
 

Functions

THREAD_RETURN lm_loopPacketProcessing (void *params)
 

Function Documentation

◆ lm_loopPacketProcessing()

THREAD_RETURN lm_loopPacketProcessing ( void *  params)

Do not realy close the connection - just inform the Queue that it is closed, so that the remaining data will be sent to the server

NEW_MIX_TYPE

Do not realy close the connection - just inform the Queue that it is closed, so that the remaining data will be sent to the server

NEW_MIX_TYPE

References CASocketGroup::add(), CAQueue::add(), CALastMixChannelList::add(), t_MixPacket::channel, CHANNEL_CLOSE, CHANNEL_DATA, CHANNEL_DEBUG, CHANNEL_OPEN, CHANNEL_SIG_CRIME, t_lastmixchannellist::channelIn, CASocket::close(), CAQueue::close(), CASocket::connect(), CONNECTION_ERROR_FLAG, CASocket::create(), CASymCipher::crypt1(), CASymCipher::crypt2(), t_MixPacketPayload::data, t_MixPacket::data, DATA_SIZE, CASymCipher::decryptMessage(), CAASymCipher::decryptOAEP(), E_SUCCESS, E_UNKNOWN, CASymCipher::encryptMessage(), t_MixPacket::flags, FLOW_CONTROL_SENDME_HARD_LIMIT, FLOW_CONTROL_SENDME_SOFT_LIMIT, GCM_MAC_SIZE, CACacheLoadBalancing::get(), CAQueue::get(), CALastMixChannelList::get(), getcurrentTimeMicros(), getcurrentTimeMillis(), CACacheLoadBalancing::getElementCount(), CALastMixChannelList::getFirstSocket(), CASocket::getLocalIP(), CASocket::getLocalPort(), CALastMixChannelList::getNextSocket(), CALibProxytest::getOptions(), getRandom(), CAQueue::getSize(), CALastMixChannelList::getSize(), CAQueue::getSizeLookFree(), CADatabase::insert(), INTEGRITY_ERROR_FLAG, CAQueue::isClosed(), CAQueue::isEmpty(), isGreater64(), CASocketGroup::isSignaled(), KEY_SIZE, LAST_MIX_SIZE_OF_SYMMETRIC_KEYS, LAST_MIX_TO_PROXY_CONNECT_TIMEOUT, LAST_MIX_TO_PROXY_SEND_TIMEOUT, len, t_MixPacketPayload::len, LOG_ENCRYPTED, CALastMix::m_bRestart, CALastMix::m_pCacheLB, CALastMix::m_pMuxIn, CALastMix::m_pQueueSendToMix, CAMixWithReplayDB::m_pReplayDB, CALastMix::m_pRSA, CALastMix::m_pSocksLB, CALastMix::m_pVPNLB, CAMixWithReplayDB::m_u64ReferenceTime, max, MAX_MIXIN_SEND_QUEUE_SIZE, min, MIX_PAYLOAD_SOCKS, MIX_PAYLOAD_VPN, MIXPACKET_SIZE, msSleep(), NEW_FLOW_CONTROL_FLAG, t_queue_entry::packet, t_MixPacket::payload, PAYLOAD_HEADER_SIZE, PAYLOAD_LEN_MASK, PAYLOAD_SIZE, t_lastmixchannellist::pCipher, CAQueue::peek(), lm_packet_proccessing_loop_args_t::pIncomingPacketQueue, lm_packet_proccessing_loop_args_t::pLastMix, pMix, t_lastmixchannellist::pQueueSend, CAMsg::printMsg(), t_lastmixchannellist::pSocket, CASocket::receive(), CAQueue::remove(), CASocketGroup::remove(), CALastMixChannelList::removeChannel(), REPLAY_BASE, RSA_SIZE, CASocketGroup::select(), CASocket::send(), t_lastmixchannellist::sendmeCounterDownstream, t_lastmixchannellist::sendmeCounterUpstream, CASocket::sendTimeOut(), set64(), CASymCipher::setGCMKeys(), CASymCipher::setKeys(), CASocket::setNonBlocking(), CASocket::setRecvBuff(), CASocket::setSendBuff(), setZero64(), SOCKET_ERROR, and t_MixPacketPayload::type.