Protected Member Functions | |
| SINT32 | loop () |
Member Function Documentation
| SINT32 CALastMixA::loop | ( | ) | [protected, virtual] |
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
Implements CALastMix.
References CASocketGroup::add(), CAQueue::add(), CALastMixChannelList::add(), add64(), t_MixPacket::channel, CHANNEL_CLOSE, CHANNEL_DATA, 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(), CADatabase::insert(), INTEGRITY_ERROR_FLAG, CAQueue::isClosed(), CAQueue::isEmpty(), isGreater64(), CASocketGroup::isSignaled(), CAThread::join(), KEY_SIZE, LAST_MIX_SIZE_OF_SYMMETRIC_KEYS, LAST_MIX_TO_PROXY_CONNECT_TIMEOUT, LAST_MIX_TO_PROXY_SEND_TIMEOUT, t_MixPacketPayload::len, len, CALastMix::lm_loopLog, LOG_ENCRYPTED, CALastMix::m_bRestart, CALastMix::m_bRunLog, CALastMix::m_logDownloadedBytes, CALastMix::m_logDownloadedPackets, CALastMix::m_logUploadedBytes, CALastMix::m_logUploadedPackets, CALastMix::m_pCacheLB, CALastMix::m_pChannelList, CALastMix::m_pMuxIn, CAMix::m_pMuxInControlChannelDispatcher, CALastMix::m_pQueueReadFromMix, CALastMix::m_pQueueSendToMix, CAMixWithReplayDB::m_pReplayDB, CALastMix::m_pRSA, CALastMix::m_pSocksLB, CAMixWithReplayDB::m_u64ReferenceTime, MAX_MIXIN_SEND_QUEUE_SIZE, MIX_PAYLOAD_SOCKS, 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(), t_lastmixchannellist::pQueueSend, CAMsg::printMsg(), CAControlChannelDispatcher::proccessMixPacket(), 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(), CAThread::setMainLoop(), CASocket::setNonBlocking(), CASocket::setRecvBuff(), CASocket::setSendBuff(), setZero64(), SOCKET_ERROR, CAThread::start(), and t_MixPacketPayload::type.
