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

Classes

class  CAFirstMixA
 

Functions

THREAD_RETURN fm_loopPacketProcessing (void *params)
 

Function Documentation

◆ fm_loopPacketProcessing()

THREAD_RETURN fm_loopPacketProcessing ( void *  params)

References CAFirstMixA::accountTrafficUpstream(), CASocketGroup::add(), CAQueue::add(), CAFirstMixChannelToQueueList::add(), CAFirstMixChannelList::addChannel(), t_fmhashtableentry::bRecoverTimeout, t_MixPacket::channel, CHANNEL_CLOSE, CHANNEL_DATA, CHANNEL_DEBUG, CHANNEL_DUMMY, CHANNEL_OPEN, CHANNEL_SIG_CRIME, t_firstmixchannellist::channelIn, t_firstmixchannellist::channelOut, CAFirstMixA::checkUserConnections(), CAFirstMixA::closeConnection(), t_fmhashtableentry::countryID, CASymCipher::crypt1(), CASymCipher::crypt2(), t_MixPacket::data, DATA_SIZE, diff64(), E_SUCCESS, FIRST_MIX_SIZE_OF_SYMMETRIC_KEYS, t_MixPacket::flags, CAQueue::get(), CAFirstMixChannelList::get(), getcurrentTimeMicros(), CAFirstMixChannelList::getFirst(), CAFirstMixChannelList::getNext(), CALibProxytest::getOptions(), getRandom(), CAQueue::getSize(), t_fmhashtableentry::id, tUINT32withLock::inc(), CAFirstMix::incMixedPackets(), CADatabase::insert(), CASocketGroup::isSignaled(), CAMutex::lock(), LOG_ENCRYPTED, CAFirstMix::m_bRestart, CAFirstMix::m_nUser, CAFirstMix::m_PacketsPerCountryIN, CAFirstMix::m_PacketsPerCountryOUT, CAFirstMix::m_pChannelToQueueList, CAFirstMix::m_pmutexLogin, CAFirstMix::m_pQueueSendToMix, CAMixWithReplayDB::m_pReplayDB, MAX_NEXT_MIX_QUEUE_SIZE, MIXPACKET_SIZE, msSleep(), t_queue_entry::packet, t_firstmixchannellist::pCipher, t_fmhashtableentry::pControlChannelDispatcher, t_fmhashtableentry::peerIP, fm_packet_proccessing_loop_args_t::pFirstMix, t_firstmixchannellist::pHead, fm_packet_proccessing_loop_args_t::pIncomingPacketQueue, pMix, t_fmhashtableentry::pMuxSocket, t_fmhashtableentry::pQueueSend, CAMsg::printMsg(), CAControlChannelDispatcher::proccessMixPacket(), t_fmhashtableentry::pSymCipher, CAMuxSocket::receive(), CAFirstMixChannelToQueueList::removeChannel(), CAFirstMixChannelList::removeChannel(), RSA_SIZE, CASocketGroup::select(), CAFirstMixA::sendToUsers(), set64(), CAFirstMixChannelList::setDelayParameters(), CASymCipher::setIV2(), CASymCipher::setKeys(), setZero64(), THREAD_RETURN_SUCCESS, and CAMutex::unlock().